Package org.apache.flink.test

Class Summary

Class	Description
StatefulStreamingJob	A simple stateful job that will be used to test avro state evolution and general state migration.
StatefulStreamingJob.MySource	Stub source that emits one record per second.
StatefulStreamingJob.MyStatefulFunction	A stateful RichMapFunction that keeps the required types of state.