Behrouz Derakhshan created FLINK-2621:
-----------------------------------------
Summary: Add support for positional arguments to ParameterTool
Key: FLINK-2621
URL: https://issues.apache.org/jira/browse/FLINK-2621
Project: Flink
Issue Type: Sub-task
Components: flink-contrib
Reporter: Behrouz Derakhshan
While working on FLINK-2021, the need for positional argument support became
needed, since after FLINK-2021 is merged, all training materials and guides
that are pointing to old way of executing the examples will not work anymore.
What I have in mind is something like this:
{code}
// ------------------ Constructors ------------------------
public static ParameterTool fromArgs(String[] args) {
isPositional = true;
// check if arg type is positional
for(String arg:args){
if (arg.contains("--")){
isPositional = false;
}
}
if(isPositional){
return fromPositionalArgument(args);
}
...
// create ParameterTool for positional arguments
public static ParameterTool fromPositionalArgument(String[] args){
return new ParameterTool(args);
}
...
// underlying storage for arguments
private String[] dataPositional;
private ParameterTool(String[] args){
this.dataPositional = args;
}
// return the positional argument based on the given index
public String get(int position){
if(!isPositional){
throw new RuntimeException("Arguments are of type of
key, value");
}
return dataPositional[position];
}
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
