POutput (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1


Interface POutput

    • Method Detail

      • recordAsOutput

        void recordAsOutput(AppliedPTransform<?,?,?> transform)
        Records that this POutput is an output of the given PTransform.

        For a compound POutput, it is advised to call this method on each component POutput.

        This is not intended to be invoked by user code, but is automatically invoked as part of applying the producing PTransform.

      • finishSpecifyingOutput

        void finishSpecifyingOutput()
        As part of applying the producing PTransform, finalizes this output to make it ready for being used as an input and for running.

        This includes ensuring that all PCollections have Coders specified or defaulted.

        Automatically invoked whenever this POutput is used as a PInput to another PTransform, or if never used as a PInput, when Pipeline.run() is called, so users do not normally call this explicitly.

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

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

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