Package org.apache.flink.streaming.tests

Class Summary

Class	Description
BucketingSinkTestProgram	End-to-end test for the bucketing sink.
BucketingSinkTestProgram.Generator	Data-generating source function.
BucketingSinkTestProgram.KeyBucketer	Use first field for buckets.
BucketingSinkTestProgram.SubtractingMapper	Subtracts the timestamp of the previous element from the current element.
ClassLoaderTestProgram	End-to-end test program for verifying that the classloader.resolve-order setting is being honored by Flink.
DataStreamAllroundTestJobFactory	A factory for components of general purpose test jobs for Flink's DataStream API operators and primitives.
DataStreamAllroundTestProgram	A general purpose test job for Flink's DataStream API operators and primitives.
DataStreamStateTTLTestProgram	A test job for State TTL feature.
DistributedCacheViaBlobTestProgram	End-to-end test program for verifying that files are distributed via BlobServer and later accessible through DistribitutedCache.
Elasticsearch5SinkExample	End to end test for Elasticsearch5Sink.
Elasticsearch6SinkExample	End to end test for Elasticsearch6Sink.
Elasticsearch7SinkExample	End to end test for Elasticsearch6Sink.
Event	The event type of records used in the DataStreamAllroundTestProgram.
FailureMapper<T>	This mapper simulates failure by throwing exceptions.
NettyShuffleMemoryControlTestProgram	Test program to verify the direct memory consumption of Netty.
ParentChildTestingVehicle	This is used for test_streaming_classloader.sh.
PeriodicStreamingJob	This is a periodic streaming job that runs for CLI testing purposes.
PeriodicStreamingJob.PeriodicSourceGenerator	Data-generating source function.
RocksDBStateMemoryControlTestProgram	The test program for a job that simply accumulates data in various states.
SemanticsCheckMapper	This mapper validates exactly-once and at-least-once semantics in connection with SequenceGeneratorSource.
SequenceGeneratorSource	This source function generates a sequence of long values per key.
SingleThreadAccessCheckingTypeInfo<T>	Custom TypeInformation to test custom TypeSerializer.
SlidingWindowCheckMapper	This mapper validates sliding event time window.
StatefulStreamJobUpgradeTestProgram	Test upgrade of generic stateful job for Flink's DataStream API operators and primitives.
StickyAllocationAndLocalRecoveryTestJob	Automatic end-to-end test for local recovery (including sticky allocation).
StickyAllocationAndLocalRecoveryTestJob.MapperSchedulingAndFailureInfo	Records the information required to check sticky scheduling after a restart.

Enum Summary

Enum	Description
TestOperatorEnum	Enum of names and uids of all test operators used in DataStreamAllroundTestProgram.