FieldForwarding hints

Posted by Newport, Billy on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/FieldForwarding-hints-tp11515.html

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:  [phone] |  Cell:  [phone]
Email: [hidden email], KD2DKQ