org.apache.flink.streaming.tests

Class DataStreamAllroundTestProgram

java.lang.Object

org.apache.flink.streaming.tests.DataStreamAllroundTestProgram

public class DataStreamAllroundTestProgram
extends Object

A general purpose test job for Flink's DataStream API operators and primitives.

The job is constructed of generic components from DataStreamAllroundTestJobFactory. It currently covers the following aspects that are frequently present in Flink DataStream jobs:

• A generic Kryo input type.
• A state type for which we register a KryoSerializer.
• Operators with ValueState.
• Operators with union state.
• Operators with broadcast state.

The cli job configuration options are described in DataStreamAllroundTestJobFactory.

Constructor Summary

Constructors

Constructor and Description
DataStreamAllroundTestProgram()

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

DataStreamAllroundTestProgram

public DataStreamAllroundTestProgram()

Method Detail

main

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

Throws:

Exception