Hi,
I know that might be a trivial question, but im struggling here... I want
to define outputSchema to return one bag with two tuples. Below is a code
which apparently doesnt work and does something different ;-(
expected schema { tup1 (), tup2 () }
.... outputSchema(Schema input) ... {
Schema sSet = new Schema();
Schema nSet = new Schema();
Schema outputTuple = new Schema();
outputTuple.add(new Schema.FieldSchema("tup1", sSet,
DataType.TUPLE));
Schema outputTuple2 = new Schema();
outputTuple2.add(new Schema.FieldSchema("tup2", nSet,
DataType.TUPLE));
//bag
Schema outputBag = new Schema();
outputBag.add(new Schema.FieldSchema(null, outputTuple,
DataType.BAG));
outputBag.add(new Schema.FieldSchema(null, outputTuple2,
DataType.BAG));
return new Schema(new
Schema.FieldSchema(getSchemaName(this.getClass().getName().toLowerCase(),
input),
outputBag, DataType.BAG));
}
thank you