public class NettyPayload extends Object
NettyPayload
represents the payload that will be transferred to netty connection. It
could indicate a combination of buffer, buffer index, and its subpartition id, and it could also
indicate an error or a segment id.Modifier and Type | Method and Description |
---|---|
Optional<Buffer> |
getBuffer() |
int |
getBufferIndex() |
Optional<Throwable> |
getError() |
int |
getSegmentId() |
int |
getSubpartitionId() |
static NettyPayload |
newBuffer(Buffer buffer,
int bufferIndex,
int subpartitionId) |
static NettyPayload |
newError(Throwable error) |
static NettyPayload |
newSegment(int segmentId) |
public static NettyPayload newBuffer(Buffer buffer, int bufferIndex, int subpartitionId)
public static NettyPayload newError(Throwable error)
public static NettyPayload newSegment(int segmentId)
public int getBufferIndex()
public int getSubpartitionId()
public int getSegmentId()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.