@Test public void testEmptyColumnFamily() throws Exception { Set<IteratorSetting.Column> cols = new HashSet<>(); cols.add(new IteratorSetting.Column(new Text(""), null)); cols.add(new IteratorSetting.Column(new Text("foo"), new Text("bar"))); cols.add(new IteratorSetting.Column(new Text(""), new Text("bar"))); cols.add(new IteratorSetting.Column(new Text(""), new Text(""))); cols.add(new IteratorSetting.Column(new Text("foo"), new Text(""))); AccumuloInputFormat.configure().clientProperties(clientProperties).table("test") .auths(Authorizations.EMPTY).fetchColumns(cols).store(job); assertEquals(cols, InputConfigurator.getFetchedColumns(AccumuloInputFormat.class, job)); }
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();  }