public static final class ResultSubpartition.BufferAndBacklog extends Object
Buffer
and the backlog length indicating
how many non-event buffers are available in the subpartition.Constructor and Description |
---|
BufferAndBacklog(Buffer buffer,
boolean isMoreAvailable,
int buffersInBacklog,
boolean nextBufferIsEvent) |
Modifier and Type | Method and Description |
---|---|
Buffer |
buffer() |
int |
buffersInBacklog() |
static ResultSubpartition.BufferAndBacklog |
fromBufferAndLookahead(Buffer current,
Buffer lookahead,
int backlog) |
boolean |
isMoreAvailable() |
boolean |
nextBufferIsEvent() |
public BufferAndBacklog(Buffer buffer, boolean isMoreAvailable, int buffersInBacklog, boolean nextBufferIsEvent)
public Buffer buffer()
public boolean isMoreAvailable()
public int buffersInBacklog()
public boolean nextBufferIsEvent()
public static ResultSubpartition.BufferAndBacklog fromBufferAndLookahead(Buffer current, Buffer lookahead, int backlog)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.