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