public class CheckpointedCollectResultBuffer<T> extends AbstractCollectResultBuffer<T>
CollectSinkFunction
. It will consider the checkpoint related fields in the response. See Java
doc of CollectSinkFunction
for explanation of this communication protocol.Constructor and Description |
---|
CheckpointedCollectResultBuffer(TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
protected void |
maintainVisibility(long currentVisiblePos,
long lastCheckpointedOffset) |
protected void |
sinkRestarted(long lastCheckpointedOffset) |
complete, dealWithResponse, getOffset, getVersion, makeResultsVisible, next, reset, revert
public CheckpointedCollectResultBuffer(TypeSerializer<T> serializer)
protected void sinkRestarted(long lastCheckpointedOffset)
sinkRestarted
in class AbstractCollectResultBuffer<T>
protected void maintainVisibility(long currentVisiblePos, long lastCheckpointedOffset)
maintainVisibility
in class AbstractCollectResultBuffer<T>
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.