@Test public void testCreateTables() { JobConf job = new JobConf(); String tableName = "test_create_tables"; Properties cp = Accumulo.newClientProperties().to("test", "zk").as("blah", "blah").build(); AccumuloOutputFormat.configure().clientProperties(cp).defaultTable(tableName).createTables(true) .store(job); assertEquals("Should have been able to create table", true, OutputConfigurator.canCreateTables(AccumuloOutputFormat.class, job)); }
public static OutputFormatBuilder.ClientParams<JobConf> configure() { return new OutputFormatBuilderImpl<>(CLASS); }
AccumuloOutputFormat implements OutputFormat<Text,Mutation> { public static OutputFormatBuilder.ClientParams<JobConf> configure() { return new OutputFormatBuilderImpl<>(CLASS); } }
AccumuloOutputFormat implements OutputFormat<Text,Mutation> { public static OutputFormatBuilder.ClientParams<JobConf> configure() { return new OutputFormatBuilderImpl<>(CLASS); }  }
AccumuloOutputFormat implements OutputFormat<Text,Mutation> { public static OutputFormatBuilder.ClientParams<JobConf> configure() { return new OutputFormatBuilderImpl<>(CLASS); }  @Override void checkOutputSpecs(FileSystem ignored, JobConf job); @Override RecordWriter<Text,Mutation> getRecordWriter(FileSystem ignored, JobConf job, String name,
      Progressable progress); static OutputFormatBuilder.ClientParams<JobConf> configure(); }
AccumuloOutputFormat implements OutputFormat<Text,Mutation> { public static OutputFormatBuilder.ClientParams<JobConf> configure() { return new OutputFormatBuilderImpl<>(CLASS); }  @Override void checkOutputSpecs(FileSystem ignored, JobConf job); @Override RecordWriter<Text,Mutation> getRecordWriter(FileSystem ignored, JobConf job, String name,
      Progressable progress); static OutputFormatBuilder.ClientParams<JobConf> configure();  }