实现流时如何使用addJar()方法?
newJob()使用DAG:
JobConfig config = new JobConfig();
config.addJar("..");
jet.newJob(dag, config).execute().get();
流在内部更改为DAG:
IMap<String, Long> counts = lines
.stream()
.flatMap(..);
最佳答案
从0.4版本开始是可能的
IStreamMap<Integer, Integer> map = jet.getMap(randomString());
range(0, 10).parallel().forEach(i -> map.put(i, i));
JobConfig jobConfig = new JobConfig();
jobConfig.addClass(MyMapper.class);
List<Integer> list = map
.stream()
.configure(jobConfig)
.map(new MyMapper())
.collect(toList());