samza-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Yi Pan <nickpa...@gmail.com>
Subject Re: Java Object in RocksDb
Date Thu, 07 Jan 2016 21:51:06 GMT
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 <estezz@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
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message