@Test public void testOutputSchema() throws Exception { StringMapsMerger udf = new StringMapsMerger(); Schema inputSchema = new Schema(); inputSchema.add(new FieldSchema(null, DataType.CHARARRAY)); Schema resultSchema = udf.outputSchema(inputSchema); assertTrue(inputSchema.getField(0).schema == resultSchema); }
@Override public Schema outputSchema(Schema input) { try { return input.getField(0).schema; } catch (FrontendException ex) { return null; } }
StringMapsMerger extends EvalFunc<Map<String, String>> { @Override public Schema outputSchema(Schema input) { try { return input.getField(0).schema; } catch (FrontendException ex) { return null; } } }
StringMapsMerger extends EvalFunc<Map<String, String>> { @Override public Schema outputSchema(Schema input) { try { return input.getField(0).schema; } catch (FrontendException ex) { return null; } }  }
StringMapsMerger extends EvalFunc<Map<String, String>> { @Override public Schema outputSchema(Schema input) { try { return input.getField(0).schema; } catch (FrontendException ex) { return null; } }  @Override Map<String, String> exec(Tuple tuple); @Override Schema outputSchema(Schema input); }
StringMapsMerger extends EvalFunc<Map<String, String>> { @Override public Schema outputSchema(Schema input) { try { return input.getField(0).schema; } catch (FrontendException ex) { return null; } }  @Override Map<String, String> exec(Tuple tuple); @Override Schema outputSchema(Schema input);  }