For the following map, what would the hint be:
@ForwardedField("f0->f1") // Correct?
public class Tuplator extends FlatMapBase<GenericRecord, Tuple2<Void,
GenericRecord>>
{
/**
*
*/
private static final long serialVersionUID = 4443299154253252672L;
public Tuplator(SerializableAvroRecordBuilder avroRecordBuilder)
{
super(avroRecordBuilder);
}
@Override
public void flatMap(GenericRecord value, Collector<Tuple2<Void,
GenericRecord>> out) throws Exception
{
out.collect(new Tuple2<Void, GenericRecord>(null, value));
}
}
Given the input is not a tuple, can I even still use hints?
Billy Newport
Data Architecture, Goldman Sachs & Co.
30 Hudson | 37th Floor | Jersey City, NJ
Tel: +1 (212) 8557773 | Cell: +1 (507) 254-0134
Email: [email protected]<mailto:[email protected]>, KD2DKQ
