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, java.util.function.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, java.util.function.IntFunction<MultiGetResponseWrapper> responseProvider)
java.lang.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 Detail

multiGet

public static ParallelMultiKeyResponseWrapper<MultiGetResponseWrapper> multiGet(int chunkCount,
                                                                                int chunkSize,
                                                                                java.util.function.IntFunction<MultiGetResponseWrapper> responseProvider)

compute

public static ParallelMultiKeyResponseWrapper<ComputeResponseWrapper> compute(int chunkCount,
                                                                              int chunkSize,
                                                                              java.util.function.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 java.lang.String toString()

Overrides:

toString in class java.lang.Object