ed to store key-value mapping. Can
> you please clarify?
>
> Thanks,
> Alex
>
> -Original Message-
> From: Dawid Wysakowicz [mailto:wysakowicz.da...@gmail.com]
> Sent: Tuesday, April 10, 2018 8:54 AM
> To: NEKRASSOV, ALEXEI <an4...@att.com>
> Cc: user@fli
k.apache.org
Subject: Re: RocksDBMapState example?
Hi Alexei,
You should not use RocksDBMapState directly. Have you went through the doc page
regarding working with state[1]?
I think you want to use KeyedState, assuming the size of your keyspace.
Probably a way to go would be to key your stream a
Hi Alexei,
You should not use RocksDBMapState directly. Have you went through the doc page
regarding working with state[1]?
I think you want to use KeyedState, assuming the size of your keyspace.
Probably a way to go would be to key your stream and then even ValueState
(which will be scoped to
,
Alex
From: Ted Yu [mailto:yuzhih...@gmail.com]
Sent: Monday, April 09, 2018 11:48 AM
To: user <user@flink.apache.org>
Subject: Re: RocksDBMapState example?
Hi,
Have you looked at the ctor call in :
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/str
Hi,
Have you looked at the ctor call in :
flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java
around line 1261 ?
Cheers
