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 isDataAvailable,
int buffersInBacklog,
boolean isEventAvailable) |
Modifier and Type | Method and Description |
---|---|
Buffer |
buffer() |
int |
buffersInBacklog() |
static ResultSubpartition.BufferAndBacklog |
fromBufferAndLookahead(Buffer current,
Buffer lookahead,
int backlog) |
boolean |
isDataAvailable() |
boolean |
isEventAvailable() |
public BufferAndBacklog(Buffer buffer, boolean isDataAvailable, int buffersInBacklog, boolean isEventAvailable)
public Buffer buffer()
public boolean isDataAvailable()
public int buffersInBacklog()
public boolean isEventAvailable()
public static ResultSubpartition.BufferAndBacklog fromBufferAndLookahead(Buffer current, Buffer lookahead, int backlog)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.