Class StorageResponseObject
- java.lang.Object
-
- com.linkedin.davinci.listener.response.ReadResponse
-
- com.linkedin.venice.listener.response.StorageResponseObject
-
public class StorageResponseObject extends ReadResponse
-
-
Constructor Summary
Constructors Constructor Description StorageResponseObject()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getRecordCount()
io.netty.buffer.ByteBuf
getResponseBody()
int
getResponseSchemaIdHeader()
ValueRecord
getValueRecord()
boolean
isFound()
void
setValueRecord(ValueRecord valueRecord)
-
Methods inherited from class com.linkedin.davinci.listener.response.ReadResponse
addDatabaseLookupLatency, addReadComputeDeserializationLatency, addReadComputeLatency, addReadComputeOutputSize, addReadComputeSerializationLatency, addValueSize, getCompressionStrategy, getCosineSimilarityCount, getCountOperatorCount, getDatabaseLookupLatency, getDotProductCount, getHadamardProductCount, getKeySizeList, getMultiChunkLargeValueCount, getRCU, getReadComputeDeserializationLatency, getReadComputeLatency, getReadComputeOutputSize, getReadComputeSerializationLatency, getStorageExecutionHandlerSubmissionWaitTime, getStorageExecutionQueueLen, getValueSize, getValueSizeList, incrementCosineSimilarityCount, incrementCountOperatorCount, incrementDotProductCount, incrementHadamardProductCount, incrementMultiChunkLargeValueCount, isStreamingResponse, setCompressionStrategy, setDatabaseLookupLatency, setKeySizeList, setRCU, setReadComputeDeserializationLatency, setReadComputeLatency, setReadComputeSerializationLatency, setStorageExecutionQueueLen, setStorageExecutionSubmissionWaitTime, setStreamingResponse, setValueSizeList
-
-
-
-
Method Detail
-
setValueRecord
public void setValueRecord(ValueRecord valueRecord)
-
getValueRecord
public ValueRecord getValueRecord()
-
isFound
public boolean isFound()
- Overrides:
isFound
in classReadResponse
-
getRecordCount
public int getRecordCount()
- Specified by:
getRecordCount
in classReadResponse
-
getResponseBody
public io.netty.buffer.ByteBuf getResponseBody()
- Specified by:
getResponseBody
in classReadResponse
-
getResponseSchemaIdHeader
public int getResponseSchemaIdHeader()
- Specified by:
getResponseSchemaIdHeader
in classReadResponse
-
-