MapState in flink

Hi,

Can anyone please help me on how can I create a MapState of ListState in flink, does flink support the same and if supports, how to declare the descriptor for same state data structure?

If it is not supported, how may I create similar datastructure for state in flink?

Thanks,

Jaswin

I need some representation like this:

---

From: Jaswin Shah <[hidden email]>
Sent: 14 June 2020 01:01
To: [hidden email] <[hidden email]>
Subject: MapState in flink

 

Hi,

Can anyone please help me on how can I create a MapState of ListState in flink, does flink support the same and if supports, how to declare the descriptor for same state data structure?

If it is not supported, how may I create similar datastructure for state in flink?

Thanks,

Jaswin

[Oytun Tez]

Correct me @everyone if I'm wrong, but you cannot keep State inside State in that way. So change your signature to: MapState<String, List<...>>

The underlying mechanism wouldn't make sense in this state-inside-state shape.

On Sat, Jun 13, 2020 at 3:32 PM Jaswin Shah <[hidden email]> wrote:

I need some representation like this:

---

From: Jaswin Shah <[hidden email]>
Sent: 14 June 2020 01:01
To: [hidden email] <[hidden email]>
Subject: MapState in flink

 

Hi,

Can anyone please help me on how can I create a MapState of ListState in flink, does flink support the same and if supports, how to declare the descriptor for same state data structure?

If it is not supported, how may I create similar datastructure for state in flink?

Thanks,

Jaswin

[Congxian Qiu]

Hi

Could you please share why you need `MapState<String, ListState>` instead of `MapState<String, List<...>>` 

Oytun Tez <[hidden email]> 于2020年6月14日周日 上午3:39写道：

Correct me @everyone if I'm wrong, but you cannot keep State inside State in that way. So change your signature to: MapState<String, List<...>>

The underlying mechanism wouldn't make sense in this state-inside-state shape.

 --

Oytun Tez M O T A W O R D | CTO & Co-Founder [hidden email]

On Sat, Jun 13, 2020 at 3:32 PM Jaswin Shah <[hidden email]> wrote:

I need some representation like this:

---

From: Jaswin Shah <[hidden email]>
Sent: 14 June 2020 01:01
To: [hidden email] <[hidden email]>
Subject: MapState in flink

 

Hi,

Can anyone please help me on how can I create a MapState of ListState in flink, does flink support the same and if supports, how to declare the descriptor for same state data structure?

If it is not supported, how may I create similar datastructure for state in flink?

Thanks,

Jaswin