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	Deprecated This class is based on the SourceFunction API, which is due to be removed.
StatefulStreamingJob.MyStatefulFunction	A stateful RichMapFunction that keeps the required types of state.