PBegin (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1


Class PBegin

    • Method Detail

      • apply

        public <OutputT extends POutput> OutputT apply(String name,
                                                       PTransform<? super PBegin,OutputT> t)
        Applies the given PTransform to this input PBegin, using name to identify this specific application of the transform. This name is used in various places, including the monitoring UI, logging, and to stably identify this application node in the job graph.
      • finishSpecifying

        public void finishSpecifying()
        Description copied from interface: PInput
        After building, finalizes this PInput to make it ready for being used as an input to a PTransform.

        Automatically invoked whenever apply() is invoked on this PInput, so users do not normally call this explicitly.

        Specified by:
        finishSpecifying in interface PInput

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

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

도움이 필요하시나요? 지원 페이지를 방문하세요.