| Interface | Description |
|---|---|
| DataflowExampleOptions |
Options that can be used to configure the Dataflow examples.
|
| DataflowExampleUtils.DataflowExampleUtilsOptions |
Define an interface that supports the PubSub and BigQuery example options.
|
| ExampleBigQueryTableOptions |
Options that can be used to configure BigQuery tables in Dataflow examples.
|
| ExamplePubsubTopicOptions |
Options that can be used to configure Pub/Sub topic in Dataflow examples.
|
| Class | Description |
|---|---|
| DataflowExampleUtils |
The utility class that sets up and tears down external resources, starts the Google Cloud Pub/Sub
injector, and cancels the streaming and the injector pipelines once the program terminates.
|
| ExampleBigQueryTableOptions.BigQueryTableFactory |
Returns the job name as the default BigQuery table name.
|
| ExamplePubsubTopicOptions.PubsubTopicFactory |
Returns a default Pub/Sub topic based on the project and the job names.
|
| PubsubFileInjector |
A batch Dataflow pipeline for injecting a set of GCS files into
a PubSub topic line by line.
|
| PubsubFileInjector.Bound |
A DoFn that publishes non-empty lines to Google Cloud PubSub.
|
| PubsubFileInjector.Unbound |
An incomplete
PubsubFileInjector transform with unbound output topic. |