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 <est...@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 >
