flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Radu Tudoran <radu.tudo...@huawei.com>
Subject question for generic streams
Date Thu, 20 Oct 2016 16:15:19 GMT

I am trying to read the types of an input stream from a file and then generate the datastream
resulting from parsing a source accordingly (e.g. DataStream<TupleN<type1,type2...>>).
Finally this will be registered as a table.
What would be the best way to do this?

I am trying currently to use the generic type of Tuple for the datastream which then will
be instantiated based on the arity of the number of types. However, this does not seem to
be a good way (and did not really figure out how to actually implement it)

Any suggestions are welcome

View raw message