flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Егор Литвиненко <e.v.litvinenk...@gmail.com>
Subject Questions
Date Thu, 27 Jul 2017 06:46:22 GMT
Hi

Is there a way to process mapping errors in Flink?
For example when string is valid double write in one table, otherwise in
another?
If not, what problems you see reffered to this opportunity and if I will
make PR, where I should start to implenent this feature?

I saw Tuple1, 2, etc. Many methods for different tuples to define types of
DataSet.
But I don't see Tuple with custom size. I mean something like new
Tuple(List<Class<?>> types)
Did I miss something?

In best regards, Egor Litvinenko

Mime
View raw message