public class DataStreamAllroundTestJobFactory extends Object
The components can be configured for different state backends, including memory, file, and RocksDB state backends. It also allows specifying the processing guarantee semantics, which will also be verified by the job itself according to the specified semantic.
|Constructor and Description|
|Modifier and Type||Method and Description|
public static void setupEnvironment(StreamExecutionEnvironment env, ParameterTool pt) throws Exception
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.