public static void checkRequiredOptions() throws MissingOptionException { OptionGroup[] groups = {contentGroup}; for(OptionGroup group : groups) { ArrayList<Option> groupOptions = new ArrayList<Option>(group.getOptions()); boolean groupIsGiven = false; for (Option option : groupOptions){ if (commandLine.hasOption(option.getOpt())) { groupIsGiven = true; break; } } if (!groupIsGiven){ throw new MissingOptionException(groupOptions); } } }
public MixtureOptionPack() { super(); alg = new OptionGroup(); alg.addOption(reuse = new Option("Reuse","Use the reuse algorithm")) .addOption(neal8 = new Option("Neal8","Use Neal's algorithm 8")) .addOption(slice = new Option("Slice","Use the slice algorithm")); alg.setRequired(true); marg = new OptionGroup(); marg.addOption(marginalized = new Option("Marginalized","Marginalize out cluster parameters")) .addOption(sampled = new Option("Sampled","Sample cluster parameters")); marg.setRequired(true); addOptionGroup(alg); addOptionGroup(marg); addOption("NumEmptyClusters", true, "Number of empty clusters to maintain (reuse,neal8)"); //options.addOption("MaxEmptyClusters", true, "Maximum number of empty clusters to introduce (slice)"); }
private static Options getOptions() { Options options = new Options(); options.addOption("b", "bind", true, "Address to bind the Thrift server to. [default: 0.0.0.0]"); options.addOption("p", "port", true, "Port to bind to [default: " + DEFAULT_LISTEN_PORT + "]"); options.addOption("f", "framed", false, "Use framed transport"); options.addOption("c", "compact", false, "Use the compact protocol"); options.addOption("w", "workers", true, "How many worker threads to use."); options.addOption("h", "help", false, "Print help information"); options.addOption(null, "infoport", true, "Port for web UI"); options.addOption("t", READ_TIMEOUT_OPTION, true, "Amount of time in milliseconds before a server thread will timeout " + "waiting for client to send data on a connected socket. Currently, " + "only applies to TBoundedThreadPoolServer"); OptionGroup servers = new OptionGroup(); servers.addOption( new Option("nonblocking", false, "Use the TNonblockingServer. This implies the framed transport.")); servers.addOption(new Option("hsha", false, "Use the THsHaServer. This implies the framed transport.")); servers.addOption(new Option("threadpool", false, "Use the TThreadPoolServer. This is the default.")); options.addOptionGroup(servers); return options; }
private void init() { options.addOption("v", "verbose", false, "Verbose output; emits file and meta data delimiters"); options.addOption("p", "printkv", false, "Print key/value pairs"); options.addOption("e", "printkey", false, "Print keys"); options.addOption("m", "printmeta", false, "Print meta data of file"); options.addOption("b", "printblocks", false, "Print block index meta data"); options.addOption("h", "printblockheaders", false, "Print block headers for each block."); options.addOption("k", "checkrow", false, "Enable row order check; looks for out-of-order keys"); options.addOption("a", "checkfamily", false, "Enable family check"); options.addOption("w", "seekToRow", true, "Seek to this row and print all the kvs for this row only"); options.addOption("s", "stats", false, "Print statistics"); OptionGroup files = new OptionGroup(); files.addOption(new Option("f", "file", true, "File to scan. Pass full-path; e.g. hdfs://a:9000/hbase/hbase:meta/12/34")); files.addOption(new Option("r", "region", true, "Region to scan. Pass region name; e.g. 'hbase:meta,,1'")); options.addOptionGroup(files); }
private static Options getCommandLineOptions() { // create the Options final Options options = new Options(); final OptionGroup startup = new OptionGroup(); final Option port = Option.builder("p") .longOpt("port") .desc("the port that the server will listen on.") .type(Integer.class) .numberOfArgs(1) .build(); startup.addOption(port); options.addOptionGroup(startup); options.addOption("h", "help", false, "print these usage instructions and exit."); options.addOption("?", "help", false, "print these usage instructions and exit."); options.addOption("v", "version", false, "print product version and exit."); return options; }
/** * Appends the usage clause for an OptionGroup to a StringBuilder. The clause * is wrapped in square brackets if the group is not required. The display of * the options is handled by appendOption * * @param buff * the StringBuilder to append to * @param group * the group to append * @see #appendOption(StringBuffer,Option,boolean) */ protected void appendOptionGroup(final StringBuilder buff, final OptionGroup group) { if (!group.isRequired()) { buff.append('['); } ArrayList<Object> optList = new ArrayList<Object>(group.getOptions()); Collections.sort(optList, getOptionComparator()); // for each option in the OptionGroup for (Iterator<?> i = optList.iterator(); i.hasNext();) { // whether the option is required or not is handled at group level appendOption(buff, (Option)i.next(), true); if (i.hasNext()) { buff.append(" | "); } } if (!group.isRequired()) { buff.append(']'); } }
/** * Creates the options needed by command line interface * * @return the options this CLI can handle */ public static Options createCLIOptions() { options = new Options(); typeGroup = new OptionGroup(); Option msgTypeOpt = new Option("t", "message_type", true, "message type"); typeGroup.addOption(msgTypeOpt); options.addOptionGroup(typeGroup); options.addOption("h", "help", false, "show help."); options.addOption("r", "response_file", true, "file to store the response in, optional"); options.addOption("d", "debug", false, "enable debug traces"); options.addOption("mp", "messaging_protocol", true, "name of messaging protocol to be used, e.g. eiffel3, semantics"); contentGroup = new OptionGroup(); contentGroup.addOption(new Option("f", "content_file", true, "message content file")); contentGroup.addOption(new Option("json", "json_content", true, "json content")); options.addOptionGroup(contentGroup); options.addOption("v", "list_versions", false, "lists the versions of generate and all loaded protocols"); return options; }
public static void checkRequiredOptions() throws MissingOptionException { OptionGroup[] groups = {typeGroup, contentGroup}; for(OptionGroup group : groups) { ArrayList<Option> groupOptions = new ArrayList<Option>(group.getOptions()); boolean groupIsGiven = false; for (Option option : groupOptions){ if (commandLine.hasOption(option.getOpt())) { groupIsGiven = true; break; } } if (!groupIsGiven){ throw new MissingOptionException(groupOptions); } } }
private static Options getOptions() { Options options = new Options(); options.addOption("b", "bind", true, "Address to bind the Thrift server to. Not supported by the Nonblocking and HsHa server [default: 0.0.0.0]"); options.addOption("p", "port", true, "Port to bind to [default: " + DEFAULT_LISTEN_PORT + "]"); options.addOption("f", "framed", false, "Use framed transport"); options.addOption("c", "compact", false, "Use the compact protocol"); options.addOption("h", "help", false, "Print help information"); options.addOption(null, "infoport", true, "Port for web UI"); OptionGroup servers = new OptionGroup(); servers.addOption( new Option("nonblocking", false, "Use the TNonblockingServer. This implies the framed transport.")); servers.addOption(new Option("hsha", false, "Use the THsHaServer. This implies the framed transport.")); servers.addOption(new Option("threadpool", false, "Use the TThreadPoolServer. This is the default.")); options.addOptionGroup(servers); return options; }
/** * Populates the default command line arguments that are common to all analyses. * * @param options The command line options object that should be modified. */ private void parseDefaultCommandLineArguments(Options options) { OptionGroup modelGroup = new OptionGroup(); modelGroup.addOption(Option.builder("model").desc("Path to the model directory.").hasArg() .argName("model directory").build()); modelGroup.addOption(Option.builder("cmodel").desc("Path to the compiled model.").hasArg() .argName("compiled model").build()); modelGroup.setRequired(false); options.addOptionGroup(modelGroup); options.addOption(Option.builder("cp").desc("The classpath for the analysis.").hasArg() .argName("classpath").required().longOpt("classpath").build()); options.addOption(Option.builder("in").desc("The input code for the analysis.").hasArg() .argName("input").required().longOpt("input").build()); options.addOption(Option.builder("out").desc("The output directory or file.").hasArg() .argName("output").longOpt("output").build()); options.addOption(Option.builder("traversemodeled").desc("Propagate through modeled classes.") .hasArg(false).build()); options.addOption("modeledtypesonly", false, "Only infer modeled types."); options.addOption(Option.builder("threadcount") .desc("The maximum number of threads that should be used.").hasArg() .argName("thread count").type(Number.class).build()); }
private static Options getOptions() { Options options = new Options(); options.addOption("b", "bind", true, "Address to bind the Thrift server to. [default: 0.0.0.0]"); options.addOption("p", "port", true, "Port to bind to [default: " + DEFAULT_LISTEN_PORT + "]"); options.addOption("f", "framed", false, "Use framed transport"); options.addOption("c", "compact", false, "Use the compact protocol"); options.addOption("h", "help", false, "Print help information"); options.addOption(null, "infoport", true, "Port for web UI"); OptionGroup servers = new OptionGroup(); servers.addOption( new Option("nonblocking", false, "Use the TNonblockingServer. This implies the framed transport.")); servers.addOption(new Option("hsha", false, "Use the THsHaServer. This implies the framed transport.")); servers.addOption(new Option("threadpool", false, "Use the TThreadPoolServer. This is the default.")); options.addOptionGroup(servers); return options; }
private static Options createOptions() { final Options options = new Options(); final OptionGroup group = new OptionGroup(); group.addOption(new Option("h", "help", false, "Print this help message")); group.addOption(new Option("i", "input-file", true, "Input file path")); group.setRequired(true); options.addOptionGroup(group); options.addOption("b", "database-file", true, "File to read database from"); options.addOption("e", "epoch-size", true, "Range for epoch size (default " + Parameters.DEFAULT_EPOCH_SIZE + ")"); options.addOption("t", "train-threshold", true, "Range for training threshold (default " + Parameters.DEFAULT_TRAIN_THRESHOLD + ")"); options.addOption("d", "detection-threshold", true, "Range for detection threshold (default " + Parameters.DEFAULT_TEST_THRESHOLD + ")"); options.addOption("v", "verbose", true, "Verbose level (default 0)"); options.addOption("o", "output-file", true, "Output file path"); return options; }
public CubeMetaExtractor() { super(); OptionGroup realizationOrProject = new OptionGroup(); realizationOrProject.addOption(OPTION_CUBE); realizationOrProject.addOption(OPTION_PROJECT); realizationOrProject.addOption(OPTION_HYBRID); realizationOrProject.addOption(OPTION_All_PROJECT); realizationOrProject.setRequired(true); options.addOptionGroup(realizationOrProject); options.addOption(OPTION_INCLUDE_SEGMENTS); options.addOption(OPTION_INCLUDE_JOB); options.addOption(OPTION_INCLUDE_SEGMENT_DETAILS); options.addOption(OPTION_INCLUDE_ONLY_JOB_OUTPUT); options.addOption(OPTION_STORAGE_TYPE); options.addOption(OPTION_ENGINE_TYPE); }
public static Options buildPa11yOptions() { Options options = new Options(); OptionGroup mutuallyExclusiveOptions = new OptionGroup(); mutuallyExclusiveOptions.addOption(getCreateTaskOption()); mutuallyExclusiveOptions.addOption(getListTasksOption()); mutuallyExclusiveOptions.addOption(getRunOption()); mutuallyExclusiveOptions.addOption(getRetrieveTaskOption()); mutuallyExclusiveOptions.addOption(getDeleteTaskOption()); options.addOptionGroup(mutuallyExclusiveOptions); options.addOption(getNameOption()); options.addOption(getUrlOption()); options.addOption(getStandardOption()); options.addOption(getLastResultOption()); options.addOption(getTaskIdOption()); return options; }
@Test public void testBuildPa11yOptions() throws Exception { Options options = OptionsBuilder.buildPa11yOptions(); assertEquals(10, options.getOptions().size()); assertPa11yOptions(options); OptionGroup optionGroup = options.getOptionGroup(options.getOption("c")); Collection<String> optionGroupNames = optionGroup.getNames(); assertTrue(optionGroupNames.contains("c")); assertTrue(optionGroupNames.contains("l")); assertTrue(optionGroupNames.contains("r")); assertTrue(optionGroupNames.contains("g")); assertTrue(optionGroupNames.contains("d")); }
private void init() { options.addOption("v", "verbose", false, "Verbose output; emits file and meta data delimiters"); options.addOption("p", "printkv", false, "Print key/value pairs"); options.addOption("e", "printkey", false, "Print keys"); options.addOption("m", "printmeta", false, "Print meta data of file"); options.addOption("b", "printblocks", false, "Print block index meta data"); options.addOption("h", "printblockheaders", false, "Print block headers for each block."); options.addOption("k", "checkrow", false, "Enable row order check; looks for out-of-order keys"); options.addOption("a", "checkfamily", false, "Enable family check"); options.addOption("w", "seekToRow", true, "Seek to this row and print all the kvs for this row only"); options.addOption("s", "stats", false, "Print statistics"); options.addOption("i", "checkMobIntegrity", false, "Print all cells whose mob files are missing"); OptionGroup files = new OptionGroup(); files.addOption(new Option("f", "file", true, "File to scan. Pass full-path; e.g. hdfs://a:9000/hbase/hbase:meta/12/34")); files.addOption(new Option("r", "region", true, "Region to scan. Pass region name; e.g. 'hbase:meta,,1'")); options.addOptionGroup(files); }
private Options createCommandLineOptions() { Options options = new Options(); OptionGroup actionGroup = new OptionGroup(); actionGroup.addOption(new Option("h", HELP_OPT, false, "Shows the help message.")); actionGroup.addOption(new Option("d", DETAILS_OPT, false, "Show details about a job/task.")); actionGroup.addOption(new Option("l", LIST_OPT, false, "List jobs/tasks.")); actionGroup.addOption(new Option("p", PROPS_OPT, false, "Fetch properties with the query.")); actionGroup.setRequired(true); options.addOptionGroup(actionGroup); OptionGroup idGroup = new OptionGroup(); idGroup.addOption(new Option("j", NAME_OPT, true, "Find job(s) matching given job name.")); idGroup.addOption(new Option("i", ID_OPT, true, "Find the job/task with the given id.")); options.addOptionGroup(idGroup); options.addOption("n", true, "Limit the number of results returned. (default:" + DEFAULT_RESULTS_LIMIT + ")"); options.addOption("r", RECENT_OPT, false, "List the most recent jobs (instead of a list of unique jobs)"); return options; }
public static Options getOptions() { Options opts = new Options(); opts.addOption(O_Q); OptionGroup og = new OptionGroup(); og.addOption(O_START); og.addOption(O_RESUME); opts.addOptionGroup(og); opts.addOption(O_END); opts.addOption(O_DAYS); opts.addOption(O_MAXBIB); opts.addOption(O_MAXTIME); opts.addOption(O_CONFIG); return opts; }
private Options createAdminOptions() { Options adminOptions = new Options(); Option url = new Option(URL_OPTION, true, "Ivory URL"); adminOptions.addOption(url); OptionGroup group = new OptionGroup(); // Option status = new Option(STATUS_OPTION, false, // "show the current system status"); Option version = new Option(VERSION_OPTION, false, "show Ivory server build version"); Option help = new Option("help", false, "show Ivory help"); group.addOption(version); group.addOption(help); adminOptions.addOptionGroup(group); return adminOptions; }
private static Options getOptions() { Options options = new Options(); options.addOption("b", "bind", true, "Address to bind the Thrift server to. [default: 0.0.0.0]"); options.addOption("p", "port", true, "Port to bind to [default: " + DEFAULT_LISTEN_PORT + "]"); options.addOption("f", "framed", false, "Use framed transport"); options.addOption("c", "compact", false, "Use the compact protocol"); options.addOption("h", "help", false, "Print help information"); OptionGroup servers = new OptionGroup(); servers.addOption( new Option("nonblocking", false, "Use the TNonblockingServer. This implies the framed transport.")); servers.addOption(new Option("hsha", false, "Use the THsHaServer. This implies the framed transport.")); servers.addOption(new Option("threadpool", false, "Use the TThreadPoolServer. This is the default.")); options.addOptionGroup(servers); return options; }
private Options createAdminOptions() { Options adminOptions = new Options(); Option url = new Option(URL_OPTION, true, "Falcon URL"); adminOptions.addOption(url); OptionGroup group = new OptionGroup(); // Option status = new Option(STATUS_OPTION, false, // "show the current system status"); Option version = new Option(VERSION_OPTION, false, "show Falcon server build version"); Option help = new Option("help", false, "show Falcon help"); group.addOption(version); group.addOption(help); adminOptions.addOptionGroup(group); return adminOptions; }
@Override public Command getCommand() { return new Command() { @Override public String getName() { return "afs"; } @Override public String getTheme() { return "Application file system"; } @Override public String getDescription() { return "application file system command line tool"; } @Override public Options getOptions() { Options options = new Options(); OptionGroup optionGroup = new OptionGroup(); optionGroup.addOption(Option.builder() .longOpt(LS) .desc("list files") .hasArg() .optionalArg(true) .argName("PATH") .build()); options.addOptionGroup(optionGroup); return options; } @Override public String getUsageFooter() { return null; } }; }
@Override void populate(Options options) { OptionGroup verbosityGroup = new OptionGroup(); verbosityGroup.setRequired(false); verbosityGroup.addOption(new OptionBuilder("s", "silent").required(false).build()); verbosityGroup.addOption(new OptionBuilder("v", "verbose").required(false).build()); options.addOptionGroup(verbosityGroup); }
static OptionGroup createOptionGroup() { OptionGroup group = new OptionGroup(); for (ImplType t : values()) { group.addOption(new Option(t.option, t.getDescription())); } return group; }
@NotNull private static Options createOptions() { final Options options = new Options(); final OptionGroup inputModeOptionGroup = new OptionGroup(); inputModeOptionGroup.addOption(Option.builder(INPUT_MODE_S3).required().desc("read input BAM from s3").build()); inputModeOptionGroup.addOption(Option.builder(INPUT_MODE_FILE).required().desc("read input BAM from file").build()); options.addOptionGroup(inputModeOptionGroup); return options; }
private void buildOptionsGroup(Options options) { OptionGroup firstGroup = new OptionGroup(); OptionGroup secondGroup = new OptionGroup(); firstGroup.setRequired(true); secondGroup.setRequired(true); firstGroup.addOption(Option.builder("d") .longOpt("db") .hasArg() .argName("table-name") .build()); firstGroup.addOption(Option.builder("f") .longOpt("flat-file") .hasArg() .argName("input.csv") .build()); options.addOptionGroup(firstGroup); secondGroup.addOption(Option.builder("x") .hasArg() .argName("arg1") .build()); secondGroup.addOption(Option.builder("s") .build()); secondGroup.addOption(Option.builder("p") .hasArg() .argName("arg1") .build()); options.addOptionGroup(secondGroup); }
private static Options getOptions() { Options options = new Options(); options.addOption(new Option("h", HELP_OPTION, false, "print this help message")); options.addOptionGroup(new OptionGroup() .addOption(new Option("l", LOAD_ONLY_OPTION, false, "load the config, but do not start the server")) .addOption(new Option("p", PROPERTY_DISPLAY_OPTION, true, "displays the calculated value of a property"))); options.addOptionGroup(new OptionGroup() .addOption(new Option("q", QUIET_OPTION, false, "be quiet during startup")) .addOption(new Option("v", VERBOSE_OPTION, false, "be verbose during startup"))); return options; }