Actually, the program works correctly (according to the DataStream API)
Let me explain what happens:
1) You do not initialize the count variable, so it will be 0 (summing 0s
results in 0)
2) DataStreams are considered to be unbound (have an infinite size). KeyBy
does not group the records because
Can you try serializing your POJO ?
Thanks
Deepak
On Mon, May 23, 2016 at 8:42 PM, Flavio Pompermaier
wrote:
> Sorry Rami, you're right :)
> Unfortunattely I've never used Flink streaming so I cannot be helpful
> there..
> Myabe is it something related to the default triggering policy of the
>
Sorry Rami, you're right :)
Unfortunattely I've never used Flink streaming so I cannot be helpful
there..
Myabe is it something related to the default triggering policy of the
streaming environment?
On Mon, May 23, 2016 at 5:06 PM, Al-Isawi Rami
wrote:
> Thanks, setters and getters for public fi
Thanks, setters and getters for public fields have no purpose. Also per the
conditions you have mentioned:
"All fields either have to be public or there must be getters and setters for
all non-public fields.”
Since my fields are declared public there are no impact on adding getters and
setters.
You don't have getters and setters for count and productId.
Your class should be
public class PojoExample {
public int count;
public String productId;
public PojoExample() {}
public int getCount() {
return count;
}
public void setCount(int count) {
this.count = count;
}
public String getProdu
Thanks Flavio, but as you can see in my code I have already declared my pojo to
achieve those conditions:
public class PojoExample {
public int count;
public String productId;
public PojoExample() {
}
}
So it cannot be that.
-Rami
On 23 May 2016, at 16:30, Flavi
*Conditions* for a class to be treated as a POJO by Flink:
- The class must be public
- It must have a public constructor without arguments
- All fields either have to be public or there must be getters and
setters for all non-public fields. If the field name is foo the getter
and s
Hi,
I was trying to test some specific issue, but now I cannot seem to get the very
basic case working. It is most likely that I am blind to something, would
anyone have quick look at it?
https://gist.github.com/rami-alisawi/d6ff33ae2d4d6e7bb1f8b329e3e5fa77
It is just a collection of pojos wher
