Package com.linkedin.davinci.storage.chunking

Class SingleGetChunkingAdapter

java.lang.Object

com.linkedin.davinci.storage.chunking.SingleGetChunkingAdapter

All Implemented Interfaces:

ChunkingAdapter<io.netty.buffer.CompositeByteBuf,ValueRecord>

public class SingleGetChunkingAdapter
extends java.lang.Object
implements ChunkingAdapter<io.netty.buffer.CompositeByteBuf,ValueRecord>

Single get chunking adapter

Method Summary

Modifier and Type	Method	Description
void	addChunkIntoContainer(io.netty.buffer.CompositeByteBuf byteBufs, int chunkIndex, byte[] valueChunk)	Used to incrementally add a {@param valueChunk} into the {@param CHUNKS_CONTAINER} container.
io.netty.buffer.CompositeByteBuf	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.
ValueRecord	constructValue(int schemaId, byte[] fullBytes)	This function can be implemented by the adapters which need fewer parameters.
ValueRecord	constructValue(int schemaId, io.netty.buffer.CompositeByteBuf byteBufs)	This function can be implemented by the adapters which need fewer parameters.
static ValueRecord	get(AbstractStorageEngine store, int partition, byte[] key, boolean isChunked, ReadResponse response)
static ValueRecord	getReplicationMetadata(AbstractStorageEngine store, int partition, byte[] key, boolean isChunked, ReadResponse response, ChunkedValueManifestContainer manifestContainer)

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(io.netty.buffer.CompositeByteBuf byteBufs,
                                  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<io.netty.buffer.CompositeByteBuf,ValueRecord>

constructChunksContainer

public io.netty.buffer.CompositeByteBuf 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<io.netty.buffer.CompositeByteBuf,ValueRecord>

constructValue

public ValueRecord constructValue(int schemaId,
                                  io.netty.buffer.CompositeByteBuf byteBufs)

Description copied from interface: ChunkingAdapter

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

Specified by:

constructValue in interface ChunkingAdapter<io.netty.buffer.CompositeByteBuf,ValueRecord>

See Also:

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

constructValue

public ValueRecord 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<io.netty.buffer.CompositeByteBuf,ValueRecord>

See Also:

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

get

public static ValueRecord get(AbstractStorageEngine store,
                              int partition,
                              byte[] key,
                              boolean isChunked,
                              ReadResponse response)

getReplicationMetadata

public static ValueRecord getReplicationMetadata(AbstractStorageEngine store,
                                                 int partition,
                                                 byte[] key,
                                                 boolean isChunked,
                                                 ReadResponse response,
                                                 ChunkedValueManifestContainer manifestContainer)