Interface Summary Interface Description DataflowAssert.IterableAssert<T>Builder interface for assertions applicable to iterables and PCollection contents. DataflowAssert.SingletonAssert<T>Builder interface for assertions applicable to a single value. RunnableOnServiceCategory tag for tests that can be run on the
runIntegrationTestOnServiceSystem property is set to true.
TestDataflowPipelineOptionsA set of options used to configure the
TestStream.Event<T>An event in a
Class Summary Class Description CoderPropertiesProperties for use in
DataflowAssertAn assertion on the contents of a
PCollectionincorporated into the pipeline.
DataflowAssert.GroupThenAssert<T>A transform that applies an assertion-checking function over iterables of
ActualTto the entirety of the contents of its input.
DataflowAssert.GroupThenAssertForSingleton<T>A transform that applies an assertion-checking function to a single iterable contained as the sole element of a
DataflowAssert.OneSideInputAssert<ActualT>An assertion checker that takes a single
PCollectionView<ActualT>and an assertion over
ActualT, and checks it within a Beam pipeline.
SourceTestUtilsHelper functions and test harnesses for checking correctness of
TestDataflowPipelineRunner TestPipelineA creator of test pipelines that can be used inside of tests that can be configured to run locally or against the live service. TestStream<T>A testing input that generates an unbounded
PCollectionof elements, advancing the watermark and processing time as elements are emitted.
TestStream.Eventthat produces elements.
TestStream.Eventthat advances the processing time clock.
TestStream.Eventthat advances the watermark.
WindowFnTestUtilsA utility class for testing
Enum Summary Enum Description SourceTestUtils.ExpectedSplitOutcomeExpected outcome of
Package com.google.cloud.dataflow.sdk.testing Description
PTransforms and examples included the Dataflow SDK provide examples of using these utilities.