org.apache.beam.sdk.testing (Apache Beam 2.8.0)

Interface Summary
Interface	Description
FlattenWithHeterogeneousCoders	Category tag for tests that use a `Flatten` where the input `PCollectionList` contains `PCollections` heterogeneous `coders`.
LargeKeys	Category tags for tests which validate that a Beam runner can handle keys up to a given size.
LargeKeys.Above100KB	Tests if a runner supports 100KB keys.
LargeKeys.Above100MB	Tests if a runner supports 100MB keys.
LargeKeys.Above10KB	Tests if a runner supports 10KB keys.
LargeKeys.Above10MB	Tests if a runner supports 10MB keys.
LargeKeys.Above1MB	Tests if a runner supports 1MB keys.
NeedsRunner	Category tag for validation tests which utilize `TestPipeline` for execution and expect to be executed by a `PipelineRunner`.
PAssert.IterableAssert<T>	Builder interface for assertions applicable to iterables and PCollection contents.
PAssert.SingletonAssert<T>	Builder interface for assertions applicable to a single value.
SerializableMatcher<T>	A `Matcher` that is also `Serializable`.
SerializableMatchers.SerializableSupplier<T>	Supplies values of type `T`, and is serializable.
StreamingIT	Deprecated tests which use unbounded PCollections should be in the category `UsesUnboundedPCollections`.
TestPipeline.TestValueProviderOptions	Implementation detail of `TestPipeline.newProvider(T)`, do not use.
TestPipelineOptions	`TestPipelineOptions` is a set of options for test pipelines.
TestStream.Event<T>	An event in a `TestStream`.
UsesBoundedSplittableParDo	Category tag for validation tests which utilize splittable `ParDo` with a `DoFn.BoundedPerElement` `DoFn`.
UsesCommittedMetrics	Category tag for validation tests which utilize `Metrics`.
UsesCustomWindowMerging	Category tag for validation tests which utilize custom window merging.
UsesFailureMessage	Category tag for tests which validate that currect failure message is provided by failed pipeline.
UsesMapState	Category tag for validation tests which utilize `MapState`.
UsesMetricsPusher	Category tag for validation tests which utilize the metrics pusher feature.
UsesParDoLifecycle	Category tag for the ParDoLifecycleTest for exclusion (BEAM-3241).
UsesSchema	Category tag for validation tests which utilize schemas.
UsesSetState	Category tag for validation tests which utilize `SetState`.
UsesSplittableParDoWithWindowedSideInputs	Category tag for validation tests which utilize splittable `ParDo` and use windowed side inputs.
UsesStatefulParDo	Category tag for validation tests which utilize stateful `ParDo`.
UsesTestStream	Category tag for tests that use `TestStream`, which is not a part of the Beam model but a special feature currently only implemented by the direct runner.
UsesTimersInParDo	Category tag for validation tests which utilize timers in `ParDo`.
UsesUnboundedPCollections	Category tag for validation tests which utilize at least one unbounded `PCollection`.
UsesUnboundedSplittableParDo	Category tag for validation tests which utilize splittable `ParDo` with a `DoFn.UnboundedPerElement` `DoFn`.
ValidatesRunner	Category tag for tests which validate that a Beam runner is correctly implemented.

Class Summary
Class	Description
CoderProperties	Properties for use in `Coder` tests.
CoderProperties.TestElementByteSizeObserver	An `ElementByteSizeObserver` that records the observed element sizes for testing purposes.
CombineFnTester	Utilities for testing `CombineFns`.
CrashingRunner	A `PipelineRunner` that applies no overrides and throws an exception on calls to `Pipeline.run()`.
FileChecksumMatcher	Matcher to verify file checksum in E2E test.
PAssert	An assertion on the contents of a `PCollection` incorporated into the pipeline.
PAssert.DefaultConcludeTransform	Default transform to check that a PAssert was successful.
PAssert.GroupThenAssert<T>	A transform that applies an assertion-checking function over iterables of `ActualT` to the entirety of the contents of its input.
PAssert.GroupThenAssertForSingleton<T>	A transform that applies an assertion-checking function to a single iterable contained as the sole element of a `PCollection`.
PAssert.OneSideInputAssert<ActualT>	An assertion checker that takes a single `PCollectionView<ActualT>` and an assertion over `ActualT`, and checks it within a Beam pipeline.
PAssert.PAssertionSite	Track the place where an assertion is defined.
PAssert.PCollectionContentsAssert<T>	An `PAssert.IterableAssert` about the contents of a `PCollection`.
PAssert.PCollectionContentsAssert.MatcherCheckerFn<T>	Check that the passed-in matchers match the existing data.
RegexMatcher	Hamcrest matcher to assert a string matches a pattern.
SerializableMatchers	Static class for building and using `SerializableMatcher` instances.
SourceTestUtils	Helper functions and test harnesses for checking correctness of `Source` implementations.
SuccessOrFailure	Output of `PAssert`.
TestPipeline	A creator of test pipelines that can be used inside of tests that can be configured to run locally or against a remote pipeline runner.
TestPipelineOptions.AlwaysPassMatcher	Matcher which will always pass.
TestPipelineOptions.AlwaysPassMatcherFactory	Factory for `PipelineResult` matchers which always pass.
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>	A `TestStream.Event` that produces elements.
TestStream.ProcessingTimeEvent<T>	A `TestStream.Event` that advances the processing time clock.
TestStream.WatermarkEvent<T>	A `TestStream.Event` that advances the watermark.
UsesAttemptedMetrics	Category tag for validation tests which utilize `Metrics`.
UsesCounterMetrics	Category tag for validation tests which utilize `Counter`.
UsesDistributionMetrics	Category tag for validation tests which utilize `Distribution`.
UsesGaugeMetrics	Category tag for validation tests which utilize `Gauge`.
UsesImpulse	Category for tests that use `Impulse` transformations.
WindowFnTestUtils	A utility class for testing `WindowFn`s.

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`.

Exception Summary
Exception	Description
TestPipeline.AbandonedNodeException	An exception thrown in case an abandoned `PTransform` is detected, that is, a `PTransform` that has not been run.
TestPipeline.PipelineRunMissingException	An exception thrown in case a test finishes without invoking `Pipeline.run()`.

Package org.apache.beam.sdk.testing Description

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