@Test public void testIteratorOptionEncoding() throws Throwable { String key = "colon:delimited:key"; String value = "comma,delimited,value"; IteratorSetting iter1 = new IteratorSetting(1, "iter1", WholeRowIterator.class); iter1.addOption(key, value); InputFormatOptions<JobConf> opts = AccumuloInputFormat.configure() .clientProperties(clientProperties).table("test").auths(Authorizations.EMPTY); opts.addIterator(iter1).store(job); List<IteratorSetting> list = InputConfigurator.getIterators(AccumuloInputFormat.class, job); assertEquals(1, list.size()); assertEquals(1, list.get(0).getOptions().size()); assertEquals(list.get(0).getOptions().get(key), value); IteratorSetting iter2 = new IteratorSetting(1, "iter2", WholeRowIterator.class); iter2.addOption(key, value); iter2.addOption(key + "2", value); opts.addIterator(iter1).addIterator(iter2).store(job); list = InputConfigurator.getIterators(AccumuloInputFormat.class, job); assertEquals(2, list.size()); assertEquals(1, list.get(0).getOptions().size()); assertEquals(list.get(0).getOptions().get(key), value); assertEquals(2, list.get(1).getOptions().size()); assertEquals(list.get(1).getOptions().get(key), value); assertEquals(list.get(1).getOptions().get(key + "2"), value); }
public static InputFormatBuilder.ClientParams<JobConf> configure() { return new InputFormatBuilderImpl<>(CLASS); }
AccumuloInputFormat implements InputFormat<Key,Value> { public static InputFormatBuilder.ClientParams<JobConf> configure() { return new InputFormatBuilderImpl<>(CLASS); } }
AccumuloInputFormat implements InputFormat<Key,Value> { public static InputFormatBuilder.ClientParams<JobConf> configure() { return new InputFormatBuilderImpl<>(CLASS); }  }
AccumuloInputFormat implements InputFormat<Key,Value> { public static InputFormatBuilder.ClientParams<JobConf> configure() { return new InputFormatBuilderImpl<>(CLASS); }  @Override InputSplit[] getSplits(JobConf job, int numSplits); @Override RecordReader<Key,Value> getRecordReader(InputSplit split, JobConf job, Reporter reporter); static InputFormatBuilder.ClientParams<JobConf> configure(); }
AccumuloInputFormat implements InputFormat<Key,Value> { public static InputFormatBuilder.ClientParams<JobConf> configure() { return new InputFormatBuilderImpl<>(CLASS); }  @Override InputSplit[] getSplits(JobConf job, int numSplits); @Override RecordReader<Key,Value> getRecordReader(InputSplit split, JobConf job, Reporter reporter); static InputFormatBuilder.ClientParams<JobConf> configure();  }