Package | Description |
---|---|
org.apache.flink.api.java.utils | |
org.apache.flink.hadoopcompatibility | |
org.apache.flink.streaming.kafka.test.base | |
org.apache.flink.streaming.tests |
Modifier and Type | Method and Description |
---|---|
static ParameterTool |
ParameterTool.fromArgs(String[] args)
Returns
ParameterTool for the given arguments. |
static ParameterTool |
ParameterTool.fromMap(Map<String,String> map)
Returns
ParameterTool for the given map. |
static ParameterTool |
ParameterTool.fromPropertiesFile(File file)
Returns
ParameterTool for the given Properties file. |
static ParameterTool |
ParameterTool.fromPropertiesFile(InputStream inputStream)
Returns
ParameterTool for the given InputStream from Properties file. |
static ParameterTool |
ParameterTool.fromPropertiesFile(String path)
Returns
ParameterTool for the given Properties file. |
static ParameterTool |
ParameterTool.fromSystemProperties()
Returns
ParameterTool from the system properties. |
ParameterTool |
ParameterTool.mergeWith(ParameterTool other)
Merges two
ParameterTool . |
Modifier and Type | Method and Description |
---|---|
ParameterTool |
ParameterTool.mergeWith(ParameterTool other)
Merges two
ParameterTool . |
Modifier and Type | Method and Description |
---|---|
static ParameterTool |
HadoopUtils.paramsFromGenericOptionsParser(String[] args)
Returns
ParameterTool for the arguments parsed by GenericOptionsParser . |
Modifier and Type | Method and Description |
---|---|
static StreamExecutionEnvironment |
KafkaExampleUtil.prepareExecutionEnv(ParameterTool parameterTool) |
Modifier and Type | Method and Description |
---|---|
static void |
DataStreamAllroundTestJobFactory.setupEnvironment(StreamExecutionEnvironment env,
ParameterTool pt) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.