fromParallelCollection
Posted by
rimin515 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/fromParallelCollection-tp8882.html
Hi,
val env = StreamExecutionEnvironment.getExecutionEnvironment
val tr = env.fromParallelCollection(data)
the data i do not know initialize,some one can tell me..
--------------------------------