| Interface | Description |
|---|---|
| WindowedWordCount.Options |
Options supported by
WindowedWordCount. |
| WordCount.WordCountOptions |
Options supported by
WordCount. |
| Class | Description |
|---|---|
| MinimalWordCount |
An example that counts words in Shakespeare.
|
| 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 lines to Google Cloud PubSub.
|
| PubsubFileInjector.Unbound |
An incomplete
PubsubFileInjector transform with unbound output topic. |
| WindowedWordCount |
An example that counts words in text, and can run over either unbounded or bounded input
collections.
|
| WordCount |
An example that counts words in Shakespeare and includes Dataflow best practices.
|
| WordCount.CountWords |
A PTransform that converts a PCollection containing lines of text into a PCollection of
formatted word counts.
|
| WordCount.FormatAsTextFn |
A DoFn that converts a Word and Count into a printable string.
|
| WordCount.WordCountOptions.OutputFactory |
Returns "gs://${YOUR_STAGING_DIRECTORY}/counts.txt" as the default destination.
|