p.get(tuple);
}
map.put(tuple, value+1);
}
for(Map.Entry entry : map.entrySet()) {
out.collect(new Tuple2<>(entry.getKey(),
entry.getValue()));
}
}
});
counts.print();
env.execute("S
hello,
I want to make a function for counting items (per type) in windows of
size N; For example for N=5 and the stream:
1 2 4 3 4 3 4 5 4 6 7 3 3 6 1 1 3 2 4 6
I would like to generate the tuples:
w(1 2 4 3 4) -> (1,1)(2,1)(4,2)(3,1)
w(3 4 5 4 6) -> (1,1)(2,1)(4,4)(3,2)(5,1)(6,1)
w(7 3 3 6 1)
errides this setting).
Can you identify at which position in the data flow the results start to
diverge?
Best, Fabian
2016-02-29 17:57 GMT+01:00 Marcela Charfuelan
mailto:charfuelanol...@tu-berlin.de>>:
Thanks Fabian,
I am using in both default options, since I am not testing in a
issue.
Regards,
MArcela.
On 29.02.2016 16:44, Fabian Hueske wrote:
Hi Marcela,
do you run the algorithm in both setups with the same parallelism?
Best, Fabian
2016-02-26 16:52 GMT+01:00 Marcela Charfuelan
mailto:charfuelanol...@tu-berlin.de>>:
Hello,
I implemented an algorith
Hello,
I implemented an algorithm that includes iterations (EM algorithm) and I
am getting different results when running in eclipse (Luna Release
(4.4.0)) and when running in the command line using Flink run; the
program does not crash is just that after the first iteration the
results are d
