com.google.cloud.dataflow.sdk.testing (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

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 the DataflowPipelineRunner if the runIntegrationTestOnService System property is set to true.
  TestDataflowPipelineOptions	A set of options used to configure the TestPipeline.
  TestStream.Event<T>	An event in a TestStream.

• Class Summary 

  Class	Description
  CoderProperties	Properties for use in Coder tests.
  DataflowAssert	An assertion on the contents of a PCollection incorporated into the pipeline.
  DataflowAssert.GroupThenAssert<T>	A transform that applies an assertion-checking function over iterables of ActualT 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 a PCollection.
  DataflowAssert.OneSideInputAssert<ActualT>	An assertion checker that takes a single PCollectionView<ActualT> and an assertion over ActualT, and checks it within a Beam pipeline.
  SourceTestUtils	Helper functions and test harnesses for checking correctness of Source implementations.
  TestDataflowPipelineRunner	TestDataflowPipelineRunner is a pipeline runner that wraps a DataflowPipelineRunner when running tests against the TestPipeline.
  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 unbounded PCollection of elements, advancing the watermark and processing time as elements are emitted.
  TestStream.Builder<T>	An incomplete TestStream.
  TestStream.ElementEvent<T>	An TestStream.Event that produces elements.
  TestStream.ProcessingTimeEvent<T>	An TestStream.Event that advances the processing time clock.
  TestStream.WatermarkEvent<T>	An TestStream.Event that advances the watermark.
  WindowFnTestUtils	A utility class for testing WindowFns.

• Enum Summary 

  Enum	Description
  SourceTestUtils.ExpectedSplitOutcome	Expected outcome of BoundedSource.BoundedReader.splitAtFraction(double).
  TestStream.EventType	The types of TestStream.Event that are supported by TestStream.

Package com.google.cloud.dataflow.sdk.testing Description

Defines utilities for unit testing Dataflow pipelines. The tests for the PTransforms and examples included the Dataflow SDK provide examples of using these utilities.