@Test public void testSetIterator() throws Exception { Job job = Job.getInstance(); IteratorSetting is = new IteratorSetting(1, "WholeRow", WholeRowIterator.class); AccumuloInputFormat.configure().clientProperties(clientProperties).table("test") .auths(Authorizations.EMPTY).addIterator(is).store(job); Configuration conf = job.getConfiguration(); ByteArrayOutputStream baos = new ByteArrayOutputStream(); is.write(new DataOutputStream(baos)); String iterators = conf.get("AccumuloInputFormat.ScanOpts.Iterators"); assertEquals(Base64.getEncoder().encodeToString(baos.toByteArray()), iterators); }
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();  }