org.apache.flink.streaming.tests

Class DataStreamStateTTLTestProgram

java.lang.Object

org.apache.flink.streaming.tests.DataStreamStateTTLTestProgram

public class DataStreamStateTTLTestProgram
extends Object

A test job for State TTL feature.

The test pipeline does the following: - generates random keyed state updates for each state TTL verifier (state type) - performs update of created state with TTL for each verifier - keeps previous updates in other state - verifies expected result of last update against preserved history of updates

Program parameters:

• update_generator_source.keyspace (int, default - 100): Number of different keys for updates emitted by the update generator.
• update_generator_source.sleep_time (long, default - 0): Milliseconds to sleep after emitting updates in the update generator. Set to 0 to disable sleeping.
• update_generator_source.sleep_after_elements (long, default - 0): Number of updates to emit before sleeping in the update generator. Set to 0 to disable sleeping.
• state_ttl_verifier.ttl_milli (long, default - 1000): State time-to-live.
• report_stat.after_updates_num (long, default - 200): Report state update statistics after certain number of updates (average update chain length and clashes).

Constructor Summary

Constructors

Constructor and Description
DataStreamStateTTLTestProgram()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataStreamStateTTLTestProgram

public DataStreamStateTTLTestProgram()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception