Hi,
I have written a UDF which will return Tuple and i am giving Tuple to
another command, but that function expects schema for that Tuple.
i have got the sample but schema is not defining, below is the sample.
public Schema outputSchema(Schema input) {
try{
Schema tupleSchema = new Schema();
tupleSchema.add(input.getField(4));
tupleSchema.add(input.getField(3));
tupleSchema.add(input.getField(2));
tupleSchema.add(input.getField(1));
tupleSchema.add(input.getField(0));
System.out.println("inside schema");
return new Schema(new
Schema.FieldSchema(getSchemaName(this.getClass().getName().toLowerCase(),
input),
tupleSchema, DataType.TUPLE));
}catch (Exception e){
return null;
}
}
// this how i am initializing.
Tuple result = TupleFactory.getInstance().newTuple(5);
//values to the tuple are been added.
result.set(0, 10);
result.set(1, 20);
result.set(2, 30);
result.set(3, 40);
result.set(4, 50);
I am going wrong,
so how to define schema for Tuple in java.