Hi kaka
You're correct, these comments are not correct for RocksDBMapState now, will
correct it with a hotfix.
Best
Yun Tang
________________________________
From: kaka chen <kaka11.c...@gmail.com>
Sent: Friday, July 5, 2019 15:05
To: dev@flink.apache.org
Subject: A question about RocksDBListState and RocksDBMapState.
Hi All,
I noticed RocksDBListState and RocksDBMapState have both the following
comments:
* <p>{@link RocksDBStateBackend} must ensure that we set the
* {@link org.rocksdb.StringAppendOperator} on the column family that
we use for our state since
* we use the {@code merge()} call.
However, from the source code, I found only RocksDBListState use
rocksdb::merge() function which used StringAppendTestOperator in rocksdb to
merge the list entries when compaction or getting key. I don't know why
RocksDBMapState is related with these comments, could someone to explain
it, thanks.
Thanks,
Kaka
