DirectPipelineRunner.EvaluationResults (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, Dataflow will not run jobs using Dataflow 1.x and below. See Migrating from Dataflow SDK 1.x for Java for migration guidance.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

com.google.cloud.dataflow.sdk.runners

Interface DirectPipelineRunner.EvaluationResults

• All Superinterfaces:

  PipelineResult

  All Known Subinterfaces:

  DirectPipelineRunner.EvaluationContext

  Enclosing class:

  DirectPipelineRunner

  ---

  
  

  public static interface DirectPipelineRunner.EvaluationResults
  extends PipelineResult

  The interface provided to registered callbacks for interacting with the DirectPipelineRunner, including reading and writing the values of PCollections and PCollectionViews.

• • Nested Class Summary

    • Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.PipelineResult

      PipelineResult.State

  • Method Summary

    All Methods Instance Methods Abstract Methods 

    Modifier and Type	Method and Description
    <T> List<T>	getPCollection(PCollection<T> pc) Retrieves the value of the given PCollection.
    <T> List<List<T>>	getPCollectionList(PCollectionList<T> pcs) Retrieves the values of each PCollection in the given PCollectionList.
    <T,WindowedT> Iterable<com.google.cloud.dataflow.sdk.util.WindowedValue<?>>	getPCollectionView(PCollectionView<T> view) Retrieves the values indicated by the given PCollectionView.
    <T> List<com.google.cloud.dataflow.sdk.util.WindowedValue<T>>	getPCollectionWindowedValues(PCollection<T> pc) Retrieves the windowed value of the given PCollection.

    • Methods inherited from interface com.google.cloud.dataflow.sdk.PipelineResult

      getAggregatorValues, getState

• • 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.