Class Hierarchy
- java.lang.Object
- org.apache.flink.sql.tests.StreamSQLTestProgram
- org.apache.flink.sql.tests.StreamSQLTestProgram.Generator (implements org.apache.flink.streaming.api.checkpoint.CheckpointedFunction, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>, org.apache.flink.streaming.api.functions.source.legacy.SourceFunction<T>)
- org.apache.flink.sql.tests.StreamSQLTestProgram.GeneratorTableSource (implements org.apache.flink.table.legacy.sources.DefinedFieldMapping, org.apache.flink.table.legacy.sources.DefinedRowtimeAttributes, org.apache.flink.legacy.table.sources.StreamTableSource<T>)
- org.apache.flink.sql.tests.StreamSQLTestProgram.KeyBucketAssigner (implements org.apache.flink.streaming.api.functions.sink.filesystem.BucketAssigner<IN,BucketID>)
- org.apache.flink.sql.tests.StreamSQLTestProgram.KillMapper (implements org.apache.flink.streaming.api.checkpoint.CheckpointedFunction, org.apache.flink.api.common.functions.MapFunction<T,O>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>)