HI Kurt,
Thanks for you reply! I’ve already solved the problem!
Desheng Zhang
E-mail: gzzhangdesh...@corp.netease.com;
> On Jul 13, 2017, at 17:10, Kurt Young wrote:
>
> Hi,
>
> Regarding 1. State is some kind of value bound with your current key of
> KeyedStream. ListState is list like
Hi,
Regarding 1. State is some kind of value bound with your current key of
KeyedStream. ListState is list like state, it can be used as a List, you
can add value to it, and get a iterator from it. If you have multiple
ArrayList to maintain, you can declare multiple states, each with different
nam
Hi Kurt,
Thanks! Your link helps me a lot.
I still have some problems after I glance on the document. As you can see from
my first email, I tried to implement a mapfunction class in flink. I actually
have 3 arraylists to be maintain at this map operator. I think the Using
managed keyed state
Hi,
I think you can use State to achieve your goal:
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/stream/state.html
Best,
Kurt
On Thu, Jul 13, 2017 at 1:14 PM, ZalaCheung wrote:
> Hi all,
>
> I am stuck with a problem. I have a stream, I want keyby it and then do a
> map func
Hi all,
I am stuck with a problem. I have a stream, I want keyby it and then do a map
function on it. But for each map operator, I want to maintain a variable for
it. Is that possible? I tried a naive version on local IntelliJ IDE and it
works. But I got nullpointerException while trying to ru
