Hi,val env = StreamExecutionEnvironment.getExecutionEnvironment          val tr 
= env.fromParallelCollection(data)
the data i do not know initialize,some one can tell me..
--------------------------------





Reply via email to