Hiļ¼val env = StreamExecutionEnvironment.getExecutionEnvironment val tr = env.fromParallelCollection(data) the data i do not know initialize,some one can tell me.. --------------------------------
- fromParallelCollection rimin515
- Re: fromParallelCollection Maximilian Michels