Interface PipelineComposer

  • All Known Implementing Classes:
    FlinkPipelineComposer

    public interface PipelineComposer
    Composer for translating a pipeline definition to an execution.
    • Method Detail

      • compose

        PipelineExecution compose​(PipelineDef pipelineDef)
        Composing pipeline execution from the specified pipeline definition.
        Parameters:
        pipelineDef - definition of the pipeline