@Test public void testGetIteratorSettings() throws Exception { Job job = Job.getInstance(); IteratorSetting iter1 = new IteratorSetting(1, "WholeRow", WholeRowIterator.class.getName()); IteratorSetting iter2 = new IteratorSetting(2, "Versions", VersioningIterator.class.getName()); IteratorSetting iter3 = new IteratorSetting(3, "Count", CountingIterator.class.getName()); AccumuloInputFormat.configure().clientProperties(clientProperties).table("test") .auths(Authorizations.EMPTY).addIterator(iter1).addIterator(iter2).addIterator(iter3) .store(job); List<IteratorSetting> list = InputConfigurator.getIterators(AccumuloInputFormat.class, job.getConfiguration()); assertEquals(3, list.size()); IteratorSetting setting = list.get(0); assertEquals(1, setting.getPriority()); assertEquals(WholeRowIterator.class.getName(), setting.getIteratorClass()); assertEquals("WholeRow", setting.getName()); setting = list.get(1); assertEquals(2, setting.getPriority()); assertEquals(VersioningIterator.class.getName(), setting.getIteratorClass()); assertEquals("Versions", setting.getName()); setting = list.get(2); assertEquals(3, setting.getPriority()); assertEquals(CountingIterator.class.getName(), setting.getIteratorClass()); assertEquals("Count", setting.getName()); }
public static InputFormatBuilder.ClientParams<Job> configure() { return new InputFormatBuilderImpl<>(CLASS); }
AccumuloInputFormat extends InputFormat<Key,Value> { public static InputFormatBuilder.ClientParams<Job> configure() { return new InputFormatBuilderImpl<>(CLASS); } }
AccumuloInputFormat extends InputFormat<Key,Value> { public static InputFormatBuilder.ClientParams<Job> configure() { return new InputFormatBuilderImpl<>(CLASS); }  }
AccumuloInputFormat extends InputFormat<Key,Value> { public static InputFormatBuilder.ClientParams<Job> configure() { return new InputFormatBuilderImpl<>(CLASS); }  @Override List<InputSplit> getSplits(JobContext context); @Override RecordReader<Key,Value> createRecordReader(InputSplit split, TaskAttemptContext context); static InputFormatBuilder.ClientParams<Job> configure(); }
AccumuloInputFormat extends InputFormat<Key,Value> { public static InputFormatBuilder.ClientParams<Job> configure() { return new InputFormatBuilderImpl<>(CLASS); }  @Override List<InputSplit> getSplits(JobContext context); @Override RecordReader<Key,Value> createRecordReader(InputSplit split, TaskAttemptContext context); static InputFormatBuilder.ClientParams<Job> configure();  }