Pipeline.PipelineVisitor (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1


Interface Pipeline.PipelineVisitor

    • Method Detail

      • enterCompositeTransform

        void enterCompositeTransform(TransformTreeNode node)
        Called for each composite transform after all topological predecessors have been visited but before any of its component transforms.
      • leaveCompositeTransform

        void leaveCompositeTransform(TransformTreeNode node)
        Called for each composite transform after all of its component transforms and their outputs have been visited.
      • visitTransform

        void visitTransform(TransformTreeNode node)
        Called for each primitive transform after all of its topological predecessors and inputs have been visited.
      • visitValue

        void visitValue(PValue value,
                        TransformTreeNode producer)
        Called for each value after the transform that produced the value has been visited.

이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

Dataflow: Stream & Batch Processing
도움이 필요하시나요? 지원 페이지를 방문하세요.