MultiKeyResponseWrapper (venice API)

java.lang.Object
- com.linkedin.davinci.listener.response.ReadResponse
- - com.linkedin.venice.listener.response.MultiKeyResponseWrapper<K>

Direct Known Subclasses:: ComputeResponseWrapper, MultiGetResponseWrapper

public abstract class MultiKeyResponseWrapper<K>
extends ReadResponse

Field Summary

Fields
Modifier and Type Field Description

protected java.util.List<K> records

Constructor Summary

Constructors
Constructor Description

MultiKeyResponseWrapper(int maxKeyCount)

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addRecord(K record)`
`int`	`getRecordCount()`
`io.netty.buffer.ByteBuf`	`getResponseBody()`
`abstract int`	`getResponseSchemaIdHeader()`
`protected abstract RecordSerializer<K>`	`getResponseSerializer()`
`void`	`incrementMultiChunkLargeValueCount()`	This function needs to be synchronized because during batch gets, there could be several threads incrementing this all at once.

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, isFound, isStreamingResponse, setCompressionStrategy, setDatabaseLookupLatency, setKeySizeList, setRCU, setReadComputeDeserializationLatency, setReadComputeLatency, setReadComputeSerializationLatency, setStorageExecutionQueueLen, setStorageExecutionSubmissionWaitTime, setStreamingResponse, setValueSizeList

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - records
```
protected final java.util.List<K> records
```
- Constructor Detail
  - MultiKeyResponseWrapper
```
public MultiKeyResponseWrapper(int maxKeyCount)
```
- Method Detail
  - addRecord
```
public void addRecord(K record)
```
  - getResponseSerializer
```
protected abstract RecordSerializer<K> getResponseSerializer()
```
  - getResponseSchemaIdHeader
```
public abstract int getResponseSchemaIdHeader()
```
    Specified by:
    
    getResponseSchemaIdHeader in class ReadResponse
  - getRecordCount
```
public int getRecordCount()
```
    Specified by:
    
    getRecordCount in class ReadResponse
  - getResponseBody
```
public io.netty.buffer.ByteBuf getResponseBody()
```
    Specified by:
    
    getResponseBody in class ReadResponse
  - incrementMultiChunkLargeValueCount
```
public void incrementMultiChunkLargeValueCount()
```
    This function needs to be synchronized because during batch gets, there could be several threads incrementing this all at once.
    
    Overrides:
    
    incrementMultiChunkLargeValueCount in class ReadResponse