public class UncheckpointedCollectResultBuffer<T> extends AbstractCollectResultBuffer<T>
CollectSinkFunction
. It ignores the checkpoint related fields in the response. See Java doc of
CollectSinkFunction
for explanation of this communication protocol.Constructor and Description |
---|
UncheckpointedCollectResultBuffer(TypeSerializer<T> serializer,
boolean failureTolerance) |
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 UncheckpointedCollectResultBuffer(TypeSerializer<T> serializer, boolean failureTolerance)
protected void sinkRestarted(long lastCheckpointedOffset)
sinkRestarted
in class AbstractCollectResultBuffer<T>
protected void maintainVisibility(long currentVisiblePos, long lastCheckpointedOffset)
maintainVisibility
in class AbstractCollectResultBuffer<T>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.