How to do when Scala Object as input in Flink

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

How to do when Scala Object as input in Flink

Xiaohua
Hi,

Can Scala object be input in Flink?

eg,
class AA;
select   AA.id,AA.name from table where AA.id >'10'

Could you please give some example about scala object as input in Flink?
Specially in Select and Where case.

Thank you so much~

BR
Xiaohua



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/