0

实现流时如何使用 addJar() 方法?

newJob() 使用 DAG:

JobConfig config = new JobConfig();
config.addJar("..");
jet.newJob(dag, config).execute().get();

流在内部更改为 DAG:

IMap<String, Long> counts = lines
                .stream()
                .flatMap(..);
4

1 回答 1

1

从 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());
于 2017-06-30T11:16:55.880 回答