Package org.apache.flink.streaming.tests.artificialstate

Class Summary

Class	Description
ArtificalOperatorStateMapper<IN,OUT>	A self-verifiable RichMapFunction used to verify checkpointing and restore semantics for various kinds of operator state.
ArtificialKeyedStateMapper<IN,OUT>	A generic, stateful MapFunction that allows specifying what states to maintain based on a provided list of ArtificialStateBuilders.
ComplexPayload	A state type used in the DataStreamAllroundTestProgram.
ComplexPayload.InnerPayLoad	Nested class in state type.
StatefulComplexPayloadSerializer	A custom stateful serializer to test that serializers are not used concurrently.
StatefulComplexPayloadSerializer.Snapshot	Snapshot for the StatefulComplexPayloadSerializer.