Package com.linkedin.venice.listener.response

Class MultiKeyResponseWrapper<K>

java.lang.Object

com.linkedin.venice.listener.response.AbstractReadResponse

com.linkedin.venice.listener.response.MultiKeyResponseWrapper<K>

All Implemented Interfaces:

ReadResponse

Direct Known Subclasses:

ComputeResponseWrapper, MultiGetResponseWrapper

public abstract class MultiKeyResponseWrapper<K>
extends AbstractReadResponse

Method Summary

Modifier and Type	Method	Description
void	addRecord(K record)
io.netty.buffer.ByteBuf	getResponseBody()	N.B.: This function is backed by a Lazy property.
abstract int	getResponseSchemaIdHeader()
ReadResponseStats	getStats()
ReadResponseStatsRecorder	getStatsRecorder()
String	toString()

Methods inherited from class com.linkedin.venice.listener.response.AbstractReadResponse

getCompressionStrategy, getRCU, isFound, isStreamingResponse, setCompressionStrategy, setRCU, setStreamingResponse

Methods inherited from class java.lang.Object

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

Method Details

addRecord

public void addRecord(K record)

Parameters:

record - to be added into the container.

Throws:

IllegalStateException - if called after getResponseBody()

getResponseSchemaIdHeader

public abstract int getResponseSchemaIdHeader()

Specified by:

getResponseSchemaIdHeader in interface ReadResponse

Specified by:

getResponseSchemaIdHeader in class AbstractReadResponse

getStats

public ReadResponseStats getStats()

getStatsRecorder

public ReadResponseStatsRecorder getStatsRecorder()

Specified by:

getStatsRecorder in class AbstractReadResponse

getResponseBody

public io.netty.buffer.ByteBuf getResponseBody()

N.B.: This function is backed by a Lazy property. The first time it is called, the response is recorded and will therefore not be regenerated even if the more records are added. To make this behavior unambiguous, it is no longer possible to add records after calling this function, as the records property then becomes an empty list.

Specified by:

getResponseBody in interface ReadResponse

Specified by:

getResponseBody in class AbstractReadResponse

Returns:

the serialized response as a ByteBuf

toString

public String toString()

Overrides:

toString in class Object