Google Cloud Dataflow SDK for Java, version 1.9.1
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 theDirectPipelineRunner
, including reading and writing the values ofPCollection
s andPCollectionView
s.
-
-
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 givenPCollectionView
.<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 givenPCollectionView
. Note that within theDoFn.Context
implementation aPCollectionView
should convert from this representation to a suitable side input value.
-
-