outputSchema

[John Smith <le...@gmail.com>]

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