org.apache.flink.streaming.api.operators.collect

Class UncheckpointedCollectResultBuffer<T>

java.lang.Object

org.apache.flink.streaming.api.operators.collect.AbstractCollectResultBuffer<T>

org.apache.flink.streaming.api.operators.collect.UncheckpointedCollectResultBuffer<T>

public class UncheckpointedCollectResultBuffer<T>
extends AbstractCollectResultBuffer<T>

A buffer which encapsulates the logic of dealing with the response from the CollectSinkFunction. It ignores the checkpoint related fields in the response. See Java doc of CollectSinkFunction for explanation of this communication protocol.

Constructor Summary

Constructors

Constructor and Description
UncheckpointedCollectResultBuffer(TypeSerializer<T> serializer, boolean failureTolerance)

Method Summary

Modifier and Type	Method and Description
protected void	maintainVisibility(long currentVisiblePos, long lastCheckpointedOffset)
protected void	sinkRestarted(long lastCheckpointedOffset)

Methods inherited from class org.apache.flink.streaming.api.operators.collect.AbstractCollectResultBuffer

complete, dealWithResponse, getOffset, getVersion, makeResultsVisible, next, reset, revert

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UncheckpointedCollectResultBuffer

public UncheckpointedCollectResultBuffer(TypeSerializer<T> serializer,
                                         boolean failureTolerance)

Method Detail

sinkRestarted

protected void sinkRestarted(long lastCheckpointedOffset)

Specified by:

sinkRestarted in class AbstractCollectResultBuffer<T>

maintainVisibility

protected void maintainVisibility(long currentVisiblePos,
                                  long lastCheckpointedOffset)

Specified by:

maintainVisibility in class AbstractCollectResultBuffer<T>