EmptyMap extends EvalFunc<Map<String, String>> { @Override public Schema outputSchema(Schema input) { try { return Utils.getSchemaFromString("m:map[chararray]"); } catch (ParserException e) { return null; } }  @Override Map<String, String> exec(Tuple tuple); @Override Schema outputSchema(Schema input);  }
@Test public void testOutputSchema() throws Exception { Schema irrelevantSchema = null; Schema resultSchema = udf.outputSchema(irrelevantSchema); assertNotNull(resultSchema); assertEquals(1, resultSchema.getFields().size()); assertEquals(DataType.MAP, resultSchema.getField(0).type); }