DirectPipelineRunner.EvaluationResults (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

com.google.cloud.dataflow.sdk.runners

Interface DirectPipelineRunner.EvaluationResults

    • Method Detail

      • getPCollection

        <T> List<T> getPCollection(PCollection<T> pc)
        Retrieves the value of the given PCollection. Throws an exception if the PCollection's value hasn't already been set.
      • getPCollectionWindowedValues

        <T> List<com.google.cloud.dataflow.sdk.util.WindowedValue<T>> getPCollectionWindowedValues(PCollection<T> pc)
        Retrieves the windowed value of the given PCollection. Throws an exception if the PCollection's value hasn't already been set.
      • getPCollectionList

        <T> List<List<T>> getPCollectionList(PCollectionList<T> pcs)
        Retrieves the values of each PCollection in the given PCollectionList. Throws an exception if the PCollectionList's value hasn't already been set.
      • getPCollectionView

        <T,WindowedT> Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<?>> getPCollectionView(PCollectionView<T> view)
        Retrieves the values indicated by the given PCollectionView. Note that within the DoFn.Context implementation a PCollectionView should convert from this representation to a suitable side input value.


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

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

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