Re: 回复：Re: 回复：Re: fromParallelCollection

2016-09-07 Thread Timo Walther
g 主题：Re: 回复：Re: fromParallelCollection 日期：2016年09月06日 17点03分 Hi, you have to implement a class that extends "org.apache.flink.util.SplittableIterator". The runtime will ask this class for multiple "java.util.Iterator"s over your split data. How you split your data and how

回复：Re: 回复：Re: fromParallelCollection

2016-09-06 Thread rimin515
@flink.apache.org 主题：Re: 回复：Re: fromParallelCollection 日期：2016年09月06日 17点03分 Hi, you have to implement a class that extends "org.apache.flink.util.SplittableIterator". The runtime will ask this class for multiple "java.util.Iterator"s over your s

Re: 回复：Re: fromParallelCollection

2016-09-06 Thread Timo Walther
Hi, you have to implement a class that extends "org.apache.flink.util.SplittableIterator". The runtime will ask this class for multiple "java.util.Iterator"s over your split data. How you split your data and how an iterator looks like depends on your data and implementation. If you need mor

回复：Re: fromParallelCollection

2016-09-06 Thread rimin515
fromCollection is not parallelization,the data is huge,so i want to use env.fromParallelCollection(data),but the data i do not know how to initialize, - 原始邮件 - 发件人：Maximilian Michels 收件人："user@flink.apache.org" , rimin...@sina.cn 主题：Re: fromParallelCollection 日期：2016年09月05日 16点58分 Plea