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.