Package com.linkedin.davinci.storage.chunking

Class BatchGetChunkingAdapter

java.lang.Object

com.linkedin.davinci.storage.chunking.BatchGetChunkingAdapter

All Implemented Interfaces:

ChunkingAdapter<java.nio.ByteBuffer,MultiGetResponseRecordV1>

public class BatchGetChunkingAdapter
extends java.lang.Object
implements ChunkingAdapter<java.nio.ByteBuffer,MultiGetResponseRecordV1>

Batch get chunking adapter

Method Summary

Modifier and Type	Method	Description
void	addChunkIntoContainer(java.nio.ByteBuffer byteBuffer, int chunkIndex, byte[] valueChunk)	Used to incrementally add a {@param valueChunk} into the {@param CHUNKS_CONTAINER} container.
java.nio.ByteBuffer	constructChunksContainer(ChunkedValueManifest chunkedValueManifest)	Used to construct the right kind of {@param CHUNKS_CONTAINER} container (according to the query code) to hold a large value which needs to be incrementally re-assembled from many smaller chunks.
MultiGetResponseRecordV1	constructValue(int schemaId, byte[] fullBytes)	This function can be implemented by the adapters which need fewer parameters.
MultiGetResponseRecordV1	constructValue(int schemaId, java.nio.ByteBuffer byteBuffer)	This function can be implemented by the adapters which need fewer parameters.
static MultiGetResponseRecordV1	get(AbstractStorageEngine store, int partition, java.nio.ByteBuffer key, boolean isChunked, ReadResponse response)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.linkedin.davinci.storage.chunking.ChunkingAdapter

constructValue, constructValue, constructValue

Method Detail

addChunkIntoContainer

public void addChunkIntoContainer(java.nio.ByteBuffer byteBuffer,
                                  int chunkIndex,
                                  byte[] valueChunk)

Description copied from interface: ChunkingAdapter

Used to incrementally add a {@param valueChunk} into the {@param CHUNKS_CONTAINER} container.

Specified by:

addChunkIntoContainer in interface ChunkingAdapter<java.nio.ByteBuffer,MultiGetResponseRecordV1>

constructChunksContainer

public java.nio.ByteBuffer constructChunksContainer(ChunkedValueManifest chunkedValueManifest)

Description copied from interface: ChunkingAdapter

Used to construct the right kind of {@param CHUNKS_CONTAINER} container (according to the query code) to hold a large value which needs to be incrementally re-assembled from many smaller chunks.

Specified by:

constructChunksContainer in interface ChunkingAdapter<java.nio.ByteBuffer,MultiGetResponseRecordV1>

constructValue

public MultiGetResponseRecordV1 constructValue(int schemaId,
                                               java.nio.ByteBuffer byteBuffer)

Description copied from interface: ChunkingAdapter

This function can be implemented by the adapters which need fewer parameters.

Specified by:

constructValue in interface ChunkingAdapter<java.nio.ByteBuffer,MultiGetResponseRecordV1>

See Also:

#constructValue(int, Object, Object, BinaryDecoder, ReadResponse, CompressionStrategy, boolean, ReadOnlySchemaRepository, String, VeniceCompressor)

constructValue

public MultiGetResponseRecordV1 constructValue(int schemaId,
                                               byte[] fullBytes)

Description copied from interface: ChunkingAdapter

This function can be implemented by the adapters which need fewer parameters.

Specified by:

constructValue in interface ChunkingAdapter<java.nio.ByteBuffer,MultiGetResponseRecordV1>

See Also:

#constructValue(int, int, byte[], int, Object, BinaryDecoder, ReadResponse, CompressionStrategy, boolean, ReadOnlySchemaRepository, String, VeniceCompressor)

get

public static MultiGetResponseRecordV1 get(AbstractStorageEngine store,
                                           int partition,
                                           java.nio.ByteBuffer key,
                                           boolean isChunked,
                                           ReadResponse response)