Package com.linkedin.davinci.storage.chunking

Class BatchGetChunkingAdapter

java.lang.Object

com.linkedin.davinci.storage.chunking.BatchGetChunkingAdapter

All Implemented Interfaces:

ChunkingAdapter<ByteBuffer,MultiGetResponseRecordV1>

public class BatchGetChunkingAdapter
extends Object
implements ChunkingAdapter<ByteBuffer,MultiGetResponseRecordV1>

Batch get chunking adapter

Method Summary

Modifier and Type	Method	Description
void	addChunkIntoContainer(ByteBuffer byteBuffer, int chunkIndex, byte[] valueChunk)	Used to incrementally add a into the container.
ByteBuffer	constructChunksContainer(ChunkedValueManifest chunkedValueManifest)	Used to construct the right kind of 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, ByteBuffer byteBuffer)	This function can be implemented by the adapters which need fewer parameters.
static MultiGetResponseRecordV1	get(StorageEngine store, int partition, ByteBuffer key, boolean isChunked, ReadResponseStats 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 Details

addChunkIntoContainer

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

Description copied from interface: ChunkingAdapter

Used to incrementally add a into the container.

Specified by:

addChunkIntoContainer in interface ChunkingAdapter<ByteBuffer,MultiGetResponseRecordV1>

constructChunksContainer

public ByteBuffer constructChunksContainer(ChunkedValueManifest chunkedValueManifest)

Description copied from interface: ChunkingAdapter

Used to construct the right kind of 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<ByteBuffer,MultiGetResponseRecordV1>

constructValue

public MultiGetResponseRecordV1 constructValue(int schemaId,
 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<ByteBuffer,MultiGetResponseRecordV1>

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<ByteBuffer,MultiGetResponseRecordV1>

get

public static MultiGetResponseRecordV1 get(StorageEngine store,
 int partition,
 ByteBuffer key,
 boolean isChunked,
 ReadResponseStats response)