Google Cloud Dataflow SDK for Java, version 1.9.1
Package com.google.cloud.dataflow.sdk.testing
Defines utilities for unit testing Dataflow pipelines.
See: Description
-
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.RunnableOnService Category tag for tests that can be run on theDataflowPipelineRunner
if therunIntegrationTestOnService
System property is set to true.TestDataflowPipelineOptions A set of options used to configure theTestPipeline
.TestStream.Event<T> An event in aTestStream
. -
Class Summary Class Description CoderProperties Properties for use inCoder
tests.DataflowAssert An assertion on the contents of aPCollection
incorporated into the pipeline.DataflowAssert.GroupThenAssert<T> A transform that applies an assertion-checking function over iterables ofActualT
to 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 aPCollection
.DataflowAssert.OneSideInputAssert<ActualT> An assertion checker that takes a singlePCollectionView<ActualT>
and an assertion overActualT
, and checks it within a Beam pipeline.SourceTestUtils Helper functions and test harnesses for checking correctness ofSource
implementations.TestDataflowPipelineRunner TestDataflowPipelineRunner
is a pipeline runner that wraps aDataflowPipelineRunner
when running tests against theTestPipeline
.TestPipeline A 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 unboundedPCollection
of elements, advancing the watermark and processing time as elements are emitted.TestStream.Builder<T> An incompleteTestStream
.TestStream.ElementEvent<T> AnTestStream.Event
that produces elements.TestStream.ProcessingTimeEvent<T> AnTestStream.Event
that advances the processing time clock.TestStream.WatermarkEvent<T> AnTestStream.Event
that advances the watermark.WindowFnTestUtils A utility class for testingWindowFn
s. -
Enum Summary Enum Description SourceTestUtils.ExpectedSplitOutcome Expected outcome ofBoundedSource.BoundedReader.splitAtFraction(double)
.TestStream.EventType The types ofTestStream.Event
that are supported byTestStream
.
Package com.google.cloud.dataflow.sdk.testing Description
Defines utilities for unit testing Dataflow pipelines. The tests for the
PTransform
s and
examples included the Dataflow SDK provide examples of using these utilities.