Package org.apache.flink.streaming.tests

Interface Summary

Interface	Description
ElasticsearchClient	The version-agnostic Elasticsearch client interface.
UpdateRequestFactory	Factory for creating UpdateRequests.

Class Summary

Class	Description
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.
Elasticsearch6Client	The type Elasticsearch 6 client.
Elasticsearch7Client	The type Elasticsearch 7 client.
ElasticsearchDataReader	Elasticsearch data reader.
ElasticsearchSinkE2ECaseBase<T extends Comparable<T>>	Base classs for end to end ElasticsearchSink tests based on connector testing framework.
ElasticsearchSinkExternalContextFactoryBase<T extends ExternalContext>	The base class for Elasticsearch sink context factory base.
ElasticsearchTestEmitter	Test emitter for performing ElasticSearch indexing requests.
Event	The event type of records used in the DataStreamAllroundTestProgram.
FailureMapper<T>	This mapper simulates failure by throwing exceptions.
KeyValue<K extends Comparable<? super K>,V extends Comparable<? super V>>	A Comparable holder for key-value pairs.
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.
QueryParams	Holder class for Elasticsearch query parameters.
QueryParams.Builder	QueryParams builder static inner class.
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.
UpdateRequest6Factory	Factory for creating UpdateRequests of Elasticsearch6.
UpdateRequest7Factory	Factory for creating UpdateRequests of Elasticsearch7.

Enum Summary

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