flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: FieldForwarding hints
Date Tue, 07 Feb 2017 22:30:52 GMT
The correct annotation would be:

@ForwardedField("*->f1")

The asterisk / wildcard addresses the complete input type. The DataSet API
also performs a type-based validation. If the types of the fields on the
left and right are not correct, it should fail.

Best, Fabian

2017-02-07 23:13 GMT+01:00 Newport, Billy <Billy.Newport@gs.com>:

> 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 <(212)%20855-7773> |  Cell:  +1 (507) 254-0134
> <(507)%20254-0134>
> Email: billy.newport@gs.com <edward.newman@gs.com>, KD2DKQ
>
>
>

Mime
View raw message