AddTimestampDoFn extracts an event time from a LogEntry.

[START countwords_composite] CountWords is a function that builds a composite PTransform to count the number of times each word appears.

Create demonstrates using beam.CreateList.

CreateAndSplit is a helper function that creates.

PipelineConstruction contains snippets for the initial sections of the Beam Programming Guide, from initializing to submitting a pipeline.

PipelineOptions shows basic pipeline options using flags.

PipelineOptionsCustom shows slightly less basic pipeline options using flags.

ComputeWordLengthFn is the DoFn to perform on each element in the input PCollection.

CustomWatermarkEstimator is a custom watermark estimator.

TimestampNanosProvider implements the beam.SchemaProvider interface.

WatermarkState is a custom type.` It is optional to write your own state type when making a custom estimator.

LogEntry is a dummy type for documentation purposes.

TimestampNanos is a logical type using time.Time, but encodes as a schema type.