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
>
|