flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetzger <...@git.apache.org>
Subject [GitHub] flink pull request: [FLINK-1525][FEEDBACK] Introduction of a small...
Date Mon, 11 May 2015 14:20:14 GMT
Github user rmetzger commented on the pull request:

    https://github.com/apache/flink/pull/664#issuecomment-100923321
  
    @aljoscha:
    
    Is this the API you were thinking of?
    ```java
    RequiredParameters required = new RequiredParameters();
    Option input = required.add("input").alt("i").description("Path to input file or directory");
// parameter with long and short variant
    required.add("output"); // parameter only with long variant
    Option parallelism = required.add("parallelism").alt("p").type(Integer.class); // parameter
with type
    Option spOption = required.add("sourceParallelism").alt("sp").defaultValue(12).description("Number
specifying the number of parallel data source instances"); // parameter with default value,
specifying the type.
    
    ParameterUtil parameter = ParameterUtil.fromArgs(new String[]{"-i", "someinput", "--output",
"someout", "-p", "15"});
    
    required.check(parameter);
    required.printHelp();
    required.checkAndPopulate(parameter);
    
    String inputString = input.get();
    int par = parallelism.getInteger();
    String output = parameter.get("output");
    int sourcePar = parameter.getInteger(spOption.getName());
    ```


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastructure@apache.org or file a JIRA ticket
with INFRA.
---

Mime
View raw message