org.apache.flink.sql.tests

Class StreamSQLTestProgram

java.lang.Object

org.apache.flink.sql.tests.StreamSQLTestProgram

public class StreamSQLTestProgram
extends Object

End-to-end test for Stream SQL queries.

Includes the following SQL features: - OVER window aggregation - keyed and non-keyed GROUP BY TUMBLE aggregation - windowed INNER JOIN - TableSource with event-time attribute

The stream is bounded and will complete after about a minute. The result is always constant. The job is killed on the first attempt and restarted.

Parameters: -outputPath Sets the path to where the result data is written.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StreamSQLTestProgram.Generator Data-generating source function.
static class	StreamSQLTestProgram.GeneratorTableSource TableSource for generated data.
static class	StreamSQLTestProgram.KillMapper Kills the first execution attempt of an application when it receives the second record.

Constructor Summary

Constructors

Constructor and Description
StreamSQLTestProgram()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamSQLTestProgram

public StreamSQLTestProgram()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception