IdConfidenceTupleDeduplicator extends EvalFunc<DataBag> { @Override public Schema outputSchema(Schema input) { return input; } IdConfidenceTupleDeduplicator();  IdConfidenceTupleDeduplicator(int confidenceLevelPosition);  IdConfidenceTupleDeduplicator(String confidenceLevelPosition); @Override DataBag exec(Tuple tuple); @Override Schema outputSchema(Schema input);  }
@Test public void testOutputSchema() throws Exception { IdConfidenceTupleDeduplicator udf = new IdConfidenceTupleDeduplicator(); Schema inputSchema = new Schema(); inputSchema.add(new FieldSchema(null, DataType.CHARARRAY)); Schema resultSchema = udf.outputSchema(inputSchema); assertTrue(inputSchema == resultSchema); }