Interface ChunkAwareCallback

    • Method Detail

      • setChunkingInfo

        void setChunkingInfo​(byte[] key,
                             java.nio.ByteBuffer[] valueChunks,
                             ChunkedValueManifest chunkedValueManifest,
                             java.nio.ByteBuffer[] rmdChunks,
                             ChunkedValueManifest chunkedRmdManifest,
                             ChunkedValueManifest oldValueManifest,
                             ChunkedValueManifest oldRmdManifest)
        For all PUT operations, the {@param key} is guaranteed to be passed via this function, whether chunking is enabled or not, and whether the value is chunked or not. The other two parameters are null if the value is not chunked.
        Parameters:
        key - A byte[] corresponding to the top-level key written to Kafka, potentially including a chunking suffix
        valueChunks - An array of ByteBuffer where the backing array has sufficient headroom to prepend Venice's header
        chunkedValueManifest - The ChunkedValueManifest of the new chunked value
        rmdChunks - An array of ByteBuffer where the backing array has sufficient headroom to prepend Venice's header
        chunkedRmdManifest - The ChunkedValueManifest of the new chunked RMD
        oldValueManifest - The ChunkedValueManifest of the previous chunked value
        oldRmdManifest - The ChunkedValueManifest of the previous chunked RMD