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: billy.newp...@gs.com<mailto:edward.new...@gs.com>, KD2DKQ