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

Reply via email to