BagStateParDo tests a DoFn that uses bag state.

BagStateParDoClear tests a DoFn that uses bag state.

Checkpoints is a small test pipeline to establish the correctness of the simple test case.

CoGBK tests CoGBK.

CombiningStateParDo tests a DoFn that uses value state.

CreateAndSplit makes a KV PCollection from a list of stringPair types.

Drain tests the SDF truncation during drain.

Flatten tests flatten.

FlattenDups tests flatten with the same input multiple times.

GBKShortRead tests GBK with a short read on the iterator.

MapStateParDo tests a DoFn that uses value state.

MapStateParDoClear tests clearing and removing from a DoFn that uses map state.

OomParDo tests a DoFn that OOMs.

Panes constructs a teststream and applies a pardo to get the pane timings.

ParDoKVSideInput computes the sum of ints using a KV side input.

ParDoMultiMapSideInput checks that the multimap side input access pattern works correctly, properly producing the correct output with an asymmetric join.

ParDoMultiOutput test a DoFn with multiple output.

ParDoPipelineOptions creates a pipeline with flag options to validate that a DoFn can access them as PipelineOptions.

ParDoSideInput computes the sum of ints using a side input.

Reshuffle tests Reshuffle.

ReshuffleKV tests Reshuffle with KV PCollections.

SetStateParDo tests a DoFn that uses set state.

SetStateParDoClear tests clearing and removing from a DoFn that uses set state.

TestStreamBoolSequence tests the TestStream primitive by inserting boolean elements then advancing the watermark past the point where they were inserted.

TestStreamByteSliceSequence tests the TestStream primitive by inserting byte slice elements then advancing the watermark to infinity and comparing the output..

TestStreamFloat64Sequence tests the TestStream primitive by inserting float64 elements then advancing the watermark past the point where they were inserted.

TestStreamInt16Sequence validates that a non-beam standard coder works with test stream.

TestStreamInt64Sequence tests the TestStream primitive by inserting int64 elements then advancing the watermark past the point where they were inserted.

TestStreamSimple is a trivial pipeline where teststream sends a single element to a DoFn that checks that it's received the value.

TestStreamSimple_InfinityDefault is the same trivial pipeline that validates that the watermark is automatically advanced to infinity even when the user doesn't set it.

TestStreamSequence tests the TestStream primitive by inserting string elements then advancing the watermark past the point where they were inserted.

TestStreamTimersEventTime validates event time timers in a test stream "driven" pipeline.

TestStreamToGBK is a trivial pipeline where teststream sends a single element to a GBK.

TestStreamTwoBoolSequences tests the TestStream primitive by inserting two sets of boolean elements that arrive on-time into the TestStream.

TestStreamTwoFloat64Sequences tests the TestStream primitive by inserting two sets of float64 elements that arrive on-time into the TestStream.

TestStreamTwoInt64Sequences tests the TestStream primitive by inserting two sets of int64 elements that arrive on-time into the TestStream.

TestStreamTwoUserTypeSequences tests the TestStream primitive by inserting two sets of boolean elements that arrive on-time into the TestStream.

TimersEventTimeBounded validates event time timers in a bounded pipeline.

TimersEventTimeUnbounded validates event time timers in an unbounded pipeline.

TimersProcessingTimeBounded validates processing time timers in a bounded pipeline.

TimersProcessingTimeBounded validates processing time timers in an unbounded pipeline.

TimersProcessingTimeTestStream_Infinity validates processing time timers in a bounded pipeline kicked along by TestStream.

TriggerAfterAll tests AfterAll trigger.

TriggerAfterAny tests AfterAny trigger.

TriggerAfterEach tests AfterEach trigger.

TriggerAfterEndOfWindow tests the AfterEndOfWindow Trigger.

TriggerAfterProcessingTime tests the AfterProcessingTime Trigger, it fires output panes once 't' processing time has passed Not yet supported by the flink runner: java.lang.UnsupportedOperationException: Advancing Processing time is not supported by the Flink Runner.

TriggerAfterSynchronizedProcessingTime tests AfterSynchronizedProcessingTime trigger.

TriggerAlways tests the Always trigger, it is expected to receive every input value as the output.

TriggerDefault tests the default trigger which fires the pane after the end of the window.

TriggerElementCount tests the ElementCount Trigger, it waits for atleast N elements to be ready to fire an output pane.

TriggerNever tests Never Trigger.

TriggerOrFinally tests OrFinally trigger.

TriggerRepeat tests the repeat trigger.

ValidateWindowedSideInputs checks that side inputs have accurate windowing information when used.

ValueStateParDo tests a DoFn that uses value state.

ValueStateParDoClear tests that a DoFn that uses value state can be cleared.

ValueStateParDoWindowed tests a DoFn that uses windowed value state.

WindowSums produces a pipeline that generates the numbers of a 3x3 magic square, and configures the pipeline so that PCollection.

RangeEstimator implements the offsetrange.RangeEndEstimator interface.

TruncateFn is an SDF.