DataStreamAllroundTestProgram (Flink : 2.0-SNAPSHOT API)

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 Description
  
  DataStreamAllroundTestProgram()
- Method Summary
  
  All Methods Static Methods Concrete Methods
  Modifier and Type Method 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