Re: DataSet/DataStream of scala type class interface

2020-04-13 Thread Salva Alcántara
FYI, I have posted the same question (a bit more polished) in https://stackoverflow.com/questions/61193662/dataset-datastream-of-type-class-interface Also, you can find the code in this repo: https://github.com/salvalcantara/flink-events-and-polymorphism -- Sent from: http://apache-flink-use

DataSet/DataStream of scala type class interface

2020-04-13 Thread Salva Alcántara
I am just experimenting with the usage of Scala type classes within Flink. I have defined the following type class interface: ```scala trait LikeEvent[T] { def timestamp(payload: T): Int } ``` Now, I want to consider a `DataSet` of `LikeEvent[_]` like this: ```scala // existing classes t