DataflowPipelineRunner.See: Description
| Class | Description |
|---|---|
| AvroIOTranslator |
Avro transform support code for the Dataflow backend.
|
| AvroIOTranslator.ReadTranslator |
Implements AvroIO Read translation for the Dataflow backend.
|
| AvroIOTranslator.WriteTranslator |
Implements AvroIO Write translation for the Dataflow backend.
|
| BasicSerializableSourceFormat |
A helper class for supporting sources defined as
Source. |
| BasicSerializableSourceFormat.BoundedSourceSplit<T> |
A
DynamicSplitResult specified explicitly by a pair of BoundedSource
objects describing the primary and residual sources. |
| BigQueryIOTranslator |
BigQuery transform support code for the Dataflow backend.
|
| BigQueryIOTranslator.ReadTranslator |
Implements BigQueryIO Read translation for the Dataflow backend.
|
| BigQueryIOTranslator.WriteTranslator |
Implements BigQueryIO Write translation for the Dataflow backend.
|
| DataflowAggregatorTransforms |
A mapping relating
Aggregators and the PTransform in which they are used. |
| DataflowMetricUpdateExtractor |
Methods for extracting the values of an
Aggregator from a collection of MetricUpdates. |
| MapAggregatorValues<T> |
An
AggregatorValues implementation that is backed by an in-memory map. |
| PubsubIOTranslator |
Pubsub transform support code for the Dataflow backend.
|
| PubsubIOTranslator.ReadTranslator<T> |
Implements PubsubIO Read translation for the Dataflow backend.
|
| PubsubIOTranslator.WriteTranslator<T> |
Implements PubsubIO Write translation for the Dataflow backend.
|
| ReadTranslator |
Translator for the
Read PTransform for the Dataflow back-end. |
| TextIOTranslator |
TextIO transform support code for the Dataflow backend.
|
| TextIOTranslator.ReadTranslator |
Implements TextIO Read translation for the Dataflow backend.
|
| TextIOTranslator.WriteTranslator |
Implements TextIO Write translation for the Dataflow backend.
|
DataflowPipelineRunner.