Hi TD
Could you explain me this code part?
.reduceByKeyAndWindow(
109 new Function2() {
110 public Integer call(Integer i1, Integer i2) { return i1 +
i2; }
111 },
112 new Function2() {
113 public Integer call(Integer i1, Integer i2) { return i1 -
i2;
Hi Tathagata,
You are right, this code compile, but I am some problems with high
memory consummation, I sent today some email about this, but no response
until now.
Thanks
Em 4/4/14, 22:56, Tathagata Das escreveu:
I havent really compiled the code, but it looks good to me. Why? Is
there any
I havent really compiled the code, but it looks good to me. Why? Is there
any problem you are facing?
TD
On Fri, Apr 4, 2014 at 8:03 AM, Eduardo Costa Alfaia wrote:
>
> Hi guys,
>
> I would like knowing if the part of code is right to use in Window.
>
> JavaPairDStream wordCounts = words.map(
Hi guys,
I would like knowing if the part of code is right to use in Window.
JavaPairDStream wordCounts = words.map(
103 new PairFunction() {
104 @Override
105 public Tuple2 call(String s) {
106 return new Tuple2(s, 1);
107 }
108 }).reduceByKeyAndWi
