in phrasecount/src/main/java/phrasecount/cmd/Mini.java [57:113]
public static void main(String[] args) throws Exception {
Parameters params = new Parameters();
JCommander jc = new JCommander(params);
try {
jc.parse(args);
if (params.args == null || params.args.size() != 2) {
throw new ParameterException("Expected two arguments");
}
} catch (ParameterException pe) {
System.out.println(pe.getMessage());
jc.setProgramName(Mini.class.getSimpleName());
jc.usage();
System.exit(-1);
}
MiniAccumuloConfig cfg = new MiniAccumuloConfig(new File(params.args.get(0)), "secret");
cfg.setZooKeeperPort(params.zookeeperPort);
cfg.setNumTservers(params.tabletServers);
if (params.moreMemory) {
cfg.setMemory(ServerType.TABLET_SERVER, 2, MemoryUnit.GIGABYTE);
Map<String, String> site = new HashMap<>();
site.put("tserver.cache.data.size", "768M");
site.put("tserver.cache.index.size", "256M");
cfg.setSiteConfig(site);
}
MiniAccumuloCluster cluster = new MiniAccumuloCluster(cfg);
cluster.start();
FluoConfiguration fluoConfig = new FluoConfiguration();
fluoConfig.setMiniStartAccumulo(false);
fluoConfig.setAccumuloInstance(cluster.getInstanceName());
fluoConfig.setAccumuloUser("root");
fluoConfig.setAccumuloPassword("secret");
fluoConfig.setAccumuloZookeepers(cluster.getZooKeepers());
fluoConfig.setInstanceZookeepers(cluster.getZooKeepers() + "/fluo");
fluoConfig.setAccumuloTable("data");
fluoConfig.setWorkerThreads(params.workerThreads);
fluoConfig.setApplicationName("phrasecount");
Application.configure(fluoConfig, new Application.Options(17, 17, cluster.getInstanceName(),
cluster.getZooKeepers(), "root", "secret", "pcExport"));
FluoFactory.newAdmin(fluoConfig).initialize(new InitializationOptions());
MiniFluo miniFluo = FluoFactory.newMiniFluo(fluoConfig);
miniFluo.getClientConfiguration().save(new File(params.args.get(1)));
System.out.println();
System.out.println("Wrote : " + params.args.get(1));
}