public class DataStreamAllroundTestProgram extends Object
The job is constructed of generic components from DataStreamAllroundTestJobFactory
.
It currently covers the following aspects that are frequently present in Flink DataStream jobs:
KryoSerializer
.ValueState
.The cli job configuration options are described in DataStreamAllroundTestJobFactory
.
Constructor and Description |
---|
DataStreamAllroundTestProgram() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.