Package com.linkedin.venice.listener.response

Class ParallelMultiKeyResponseWrapper<T extends MultiKeyResponseWrapper>

java.lang.Object

com.linkedin.venice.listener.response.AbstractReadResponse

com.linkedin.venice.listener.response.ParallelMultiKeyResponseWrapper<T>

All Implemented Interfaces:

ReadResponse

public class ParallelMultiKeyResponseWrapper<T extends MultiKeyResponseWrapper>
extends AbstractReadResponse

Method Summary

Modifier and Type	Method	Description
static ParallelMultiKeyResponseWrapper<ComputeResponseWrapper>	compute(int chunkCount, int chunkSize, IntFunction<ComputeResponseWrapper> responseProvider)
T	getChunk(int chunkIndex)
io.netty.buffer.ByteBuf	getResponseBody()
int	getResponseSchemaIdHeader()
ReadResponseStats	getStats()	N.B.: Only the individual chunks should be passed into code paths that require this API.
ReadResponseStatsRecorder	getStatsRecorder()
static ParallelMultiKeyResponseWrapper<MultiGetResponseWrapper>	multiGet(int chunkCount, int chunkSize, IntFunction<MultiGetResponseWrapper> responseProvider)
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

multiGet

public static ParallelMultiKeyResponseWrapper<MultiGetResponseWrapper> multiGet(int chunkCount,
 int chunkSize,
 IntFunction<MultiGetResponseWrapper> responseProvider)

compute

public static ParallelMultiKeyResponseWrapper<ComputeResponseWrapper> compute(int chunkCount,
 int chunkSize,
 IntFunction<ComputeResponseWrapper> responseProvider)

getChunk

public T getChunk(int chunkIndex)

getStats

public ReadResponseStats getStats()

N.B.: Only the individual chunks should be passed into code paths that require this API. If some refactoring causes that assumption to change, then we have a regression.

getStatsRecorder

public ReadResponseStatsRecorder getStatsRecorder()

Specified by:

getStatsRecorder in class AbstractReadResponse

getResponseBody

public io.netty.buffer.ByteBuf getResponseBody()

Specified by:

getResponseBody in interface ReadResponse

Specified by:

getResponseBody in class AbstractReadResponse

getResponseSchemaIdHeader

public int getResponseSchemaIdHeader()

Specified by:

getResponseSchemaIdHeader in interface ReadResponse

Specified by:

getResponseSchemaIdHeader in class AbstractReadResponse

toString

public String toString()

Overrides:

toString in class Object