@Test(expected=IllegalArgumentException.class) public void testAddNamedOutputInvalid() throws Exception { String namedOutput = "invalid.name"; Configuration conf = new Configuration(); doReturn(conf).when(job).getConfiguration(); AvroMultipleOutputs.addNamedOutput(job, namedOutput, outputFormatClass, Identifier.SCHEMA$); }
@SuppressWarnings("rawtypes") public static void addNamedOutput(Job job, String namedOutput, Class<? extends OutputFormat> outputFormatClass, Schema keySchema) { addNamedOutput(job,namedOutput,outputFormatClass,keySchema,null); }
AvroMultipleOutputs { @SuppressWarnings("rawtypes") public static void addNamedOutput(Job job, String namedOutput, Class<? extends OutputFormat> outputFormatClass, Schema keySchema) { addNamedOutput(job,namedOutput,outputFormatClass,keySchema,null); } }
AvroMultipleOutputs { @SuppressWarnings("rawtypes") public static void addNamedOutput(Job job, String namedOutput, Class<? extends OutputFormat> outputFormatClass, Schema keySchema) { addNamedOutput(job,namedOutput,outputFormatClass,keySchema,null); } AvroMultipleOutputs(
      TaskInputOutputContext<?, ?, ?, ?> context); }
AvroMultipleOutputs { @SuppressWarnings("rawtypes") public static void addNamedOutput(Job job, String namedOutput, Class<? extends OutputFormat> outputFormatClass, Schema keySchema) { addNamedOutput(job,namedOutput,outputFormatClass,keySchema,null); } AvroMultipleOutputs(
      TaskInputOutputContext<?, ?, ?, ?> context); @SuppressWarnings("rawtypes") static void addNamedOutput(Job job, String namedOutput,
      Class<? extends OutputFormat> outputFormatClass,
      Schema keySchema); @SuppressWarnings("rawtypes") static void addNamedOutput(Job job, String namedOutput,
      Class<? extends OutputFormat> outputFormatClass,
      Schema keySchema, Schema valueSchema); static void setCountersEnabled(Job job, boolean enabled); static boolean getCountersEnabled(JobContext job); Set<String> getNamedOutputs(); void write(String namedOutput, Object key); void write(String namedOutput, Object key, Object value); @SuppressWarnings("unchecked") void write(String namedOutput, Object key, Object value,
      String baseOutputPath); void write(Object key, Object value, String baseOutputPath); @SuppressWarnings({ "unchecked", "deprecation" }) void write(Object key, Object value, Schema keySchema,
      Schema valSchema, String baseOutputPath); @SuppressWarnings("rawtypes") synchronized RecordWriter getRecordWriter(
      TaskAttemptContext taskContext, String baseFileName); @SuppressWarnings("deprecation") TaskAttemptContext getContext(String nameOutput); void close(); }
AvroMultipleOutputs { @SuppressWarnings("rawtypes") public static void addNamedOutput(Job job, String namedOutput, Class<? extends OutputFormat> outputFormatClass, Schema keySchema) { addNamedOutput(job,namedOutput,outputFormatClass,keySchema,null); } AvroMultipleOutputs(
      TaskInputOutputContext<?, ?, ?, ?> context); @SuppressWarnings("rawtypes") static void addNamedOutput(Job job, String namedOutput,
      Class<? extends OutputFormat> outputFormatClass,
      Schema keySchema); @SuppressWarnings("rawtypes") static void addNamedOutput(Job job, String namedOutput,
      Class<? extends OutputFormat> outputFormatClass,
      Schema keySchema, Schema valueSchema); static void setCountersEnabled(Job job, boolean enabled); static boolean getCountersEnabled(JobContext job); Set<String> getNamedOutputs(); void write(String namedOutput, Object key); void write(String namedOutput, Object key, Object value); @SuppressWarnings("unchecked") void write(String namedOutput, Object key, Object value,
      String baseOutputPath); void write(Object key, Object value, String baseOutputPath); @SuppressWarnings({ "unchecked", "deprecation" }) void write(Object key, Object value, Schema keySchema,
      Schema valSchema, String baseOutputPath); @SuppressWarnings("rawtypes") synchronized RecordWriter getRecordWriter(
      TaskAttemptContext taskContext, String baseFileName); @SuppressWarnings("deprecation") TaskAttemptContext getContext(String nameOutput); void close();  }