Ajouter du code avec AddJar() lors de l'utilisation de l'API des flux?

Question

Comment puis-je utiliser la méthode addJar() lorsque j'implémente un flux?

Le newJob() utilise un DAG:

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

cours d'eau sont changées en DAG interne:

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

Answer 1

Ceci est possible de la version 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());