Package com.linkedin.davinci.utils

Class ChunkAssembler

java.lang.Object

com.linkedin.davinci.utils.ChunkAssembler

public class ChunkAssembler
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
protected InMemoryStorageEngine	inMemoryStorageEngine
protected java.lang.String	storeName

Constructor Summary

Constructors

Constructor	Description
ChunkAssembler(java.lang.String storeName)

Method Summary

Modifier and Type	Method	Description
<T> T	bufferAndAssembleRecord(PubSubTopicPartition pubSubTopicPartition, int schemaId, byte[] keyBytes, java.nio.ByteBuffer valueBytes, long recordOffset, Lazy<RecordDeserializer<T>> recordDeserializer, int readerSchemaId, VeniceCompressor compressor)
void	clearInMemoryDB()
protected <T> T	decompressAndDeserialize(RecordDeserializer<T> deserializer, VeniceCompressor compressor, java.nio.ByteBuffer value)

Methods inherited from class java.lang.Object

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

Field Detail

storeName

protected final java.lang.String storeName

inMemoryStorageEngine

protected final InMemoryStorageEngine inMemoryStorageEngine

Constructor Detail

ChunkAssembler

public ChunkAssembler(java.lang.String storeName)

Method Detail

bufferAndAssembleRecord

public <T> T bufferAndAssembleRecord(PubSubTopicPartition pubSubTopicPartition,
                                     int schemaId,
                                     byte[] keyBytes,
                                     java.nio.ByteBuffer valueBytes,
                                     long recordOffset,
                                     Lazy<RecordDeserializer<T>> recordDeserializer,
                                     int readerSchemaId,
                                     VeniceCompressor compressor)

decompressAndDeserialize

protected <T> T decompressAndDeserialize(RecordDeserializer<T> deserializer,
                                         VeniceCompressor compressor,
                                         java.nio.ByteBuffer value)
                                  throws java.io.IOException

Throws:

java.io.IOException

clearInMemoryDB

public void clearInMemoryDB()