com.google.cloud.dataflow.examples

Class WindowingWordCount

java.lang.Object

com.google.cloud.dataflow.examples.WindowingWordCount

public class WindowingWordCount
extends java.lang.Object

An example that counts words in Shakespeare. For a detailed walkthrough of this example see: https://cloud.google.com/dataflow/java-sdk/wordcount-example

To execute this pipeline locally, specify general pipeline configuration: --project= and a local output file or output prefix on GCS: --output=[ | gs://

]

To execute this pipeline using the Dataflow service, specify pipeline configuration: --project= --stagingLocation=gs:// --runner=BlockingDataflowPipelineRunner and an output prefix on GCS: --output=gs://

The input file defaults to gs://dataflow-samples/shakespeare/kinglear.txt and can be overridden with --input.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WindowingWordCount.CountWords A PTransform that converts a PCollection containing lines of text into a PCollection of formatted word counts.

Constructor Summary

Constructors

Constructor and Description
WindowingWordCount()

Method Summary

Methods

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WindowingWordCount

public WindowingWordCount()

Method Detail

main

public static void main(java.lang.String[] args)