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.


Was this page helpful? Let us know how we did:

Send feedback about...

Cloud Dataflow