Package org.apache.flink.sql.tests

Class Summary

Class	Description
StreamSQLTestProgram	End-to-end test for Stream SQL queries.
StreamSQLTestProgram.Generator	Data-generating source function.
StreamSQLTestProgram.GeneratorTableSource	TableSource for generated data.
StreamSQLTestProgram.KeyBucketAssigner	Use first field for buckets.
StreamSQLTestProgram.KillMapper	Kills the first execution attempt of an application when it receives the second record.