Re: [DISCUSS] Support customize state in customized KeyedStateBackend

2019-09-08 Thread shimin yang
s/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java#L114 >> >> >> Best >> Yun Tang >> >> >> >> From: Yu Li >> Sent: Monday, September 9, 2019 2:24 >

Re: [DISCUSS] Support customize state in customized KeyedStateBackend

2019-09-08 Thread shimin yang
__________ > From: Yu Li > Sent: Monday, September 9, 2019 2:24 > To: dev > Subject: Re: [DISCUSS] Support customize state in customized > KeyedStateBackend > > Hi Shimin, > > Thanks for bring this discussion up. > > First of all, I'd like to

Re: [DISCUSS] Support customize state in customized KeyedStateBackend

2019-09-08 Thread Yun Tang
Tang From: Yu Li Sent: Monday, September 9, 2019 2:24 To: dev Subject: Re: [DISCUSS] Support customize state in customized KeyedStateBackend Hi Shimin, Thanks for bring this discussion up. First of all, I'd like to confirm/clarify that this discussion is ma

Re: [DISCUSS] Support customize state in customized KeyedStateBackend

2019-09-08 Thread Yu Li
Hi Shimin, Thanks for bring this discussion up. First of all, I'd like to confirm/clarify that this discussion is mainly about managed state with customized state descriptor rather than raw state, right? Asking because raw state was the very first thing came to my mind when seeing the title. And

[DISCUSS] Support customize state in customized KeyedStateBackend

2019-09-05 Thread shimin yang
Hi every, I would like to start a discussion on supporting customize state in customized KeyedStateBackend. In Flink, users can customize KeyedStateBackend to support different type of data store. Although we can implement customized StateDescriptors for different kind of data structrues, we do n