@Test public void testAddIterator() throws Exception { InputFormatOptions<JobConf> opts = AccumuloInputFormat.configure() .clientProperties(clientProperties).table("test").auths(Authorizations.EMPTY); IteratorSetting iter1 = new IteratorSetting(1, "WholeRow", WholeRowIterator.class); IteratorSetting iter2 = new IteratorSetting(2, "Versions", VersioningIterator.class); IteratorSetting iter3 = new IteratorSetting(3, "Count", CountingIterator.class); iter3.addOption("v1", "1"); iter3.addOption("junk", "\0omg:!\\xyzzy"); opts.addIterator(iter1).addIterator(iter2).addIterator(iter3).store(job); List<IteratorSetting> list = InputConfigurator.getIterators(AccumuloInputFormat.class, job); assertEquals(3, list.size()); IteratorSetting setting = list.get(0); assertEquals(1, setting.getPriority()); assertEquals(WholeRowIterator.class.getName(), setting.getIteratorClass()); assertEquals("WholeRow", setting.getName()); assertEquals(0, setting.getOptions().size()); setting = list.get(1); assertEquals(2, setting.getPriority()); assertEquals(VersioningIterator.class.getName(), setting.getIteratorClass()); assertEquals("Versions", setting.getName()); assertEquals(0, setting.getOptions().size()); setting = list.get(2); assertEquals(3, setting.getPriority()); assertEquals(CountingIterator.class.getName(), setting.getIteratorClass()); assertEquals("Count", setting.getName()); assertEquals(2, setting.getOptions().size()); assertEquals("1", setting.getOptions().get("v1")); assertEquals("\0omg:!\\xyzzy", setting.getOptions().get("junk")); }
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();  }