You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@samza.apache.org by Leo Woessner <es...@gmail.com> on 2016/01/07 21:11:29 UTC

Java Object in RocksDb

Can I insert a POJO in RocksDB?

I see this serde,
https://samza.apache.org/learn/documentation/0.10/container/serialization.html
serializable Serializable Object Type



-- 
Leo Woessner

Re: Java Object in RocksDb

Posted by Yi Pan <ni...@gmail.com>.

Hi, Leo,

Samza RocksDB store stores ByteArray for keys and values on-disk. You can
define your own key and msg serde via the configuration (
http://samza.apache.org/learn/documentation/0.10/jobs/configuration-table.html#stores-key-serde,
http://samza.apache.org/learn/documentation/0.10/jobs/configuration-table.html#stores-msg-serde),
and Samza will use the configured serde classes to serialize/de-serialize
the on-disk data in RocksDB, which are raw byte arrays. You can implement
POJO serde classes to serialize/de-serialize objects to and from the raw
byte array format.

Hope that is clear.

-Yi

On Thu, Jan 7, 2016 at 12:11 PM, Leo Woessner <es...@gmail.com> wrote:

> Can I insert a POJO in RocksDB?
>
> I see this serde,
>
> https://samza.apache.org/learn/documentation/0.10/container/serialization.html
> serializable Serializable Object Type
>
>
>
> --
> Leo Woessner
>