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–2024 The Apache Software Foundation. All rights reserved.