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

Class CollectCoordinationResponse

java.lang.Object

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

All Implemented Interfaces:

Serializable, CoordinationResponse

public class CollectCoordinationResponse
extends Object
implements CoordinationResponse

A CoordinationResponse from the coordinator containing the required batch or new results and other necessary information in serialized form.

For an explanation of this communication protocol, see Java docs in CollectSinkFunction.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
CollectCoordinationResponse(String version, long lastCheckpointedOffset, List<byte[]> serializedResults)
CollectCoordinationResponse(DataInputView inView)

Method Summary

Modifier and Type	Method	Description
long	getLastCheckpointedOffset()
<T> List<T>	getResults(TypeSerializer<T> elementSerializer)
String	getVersion()
void	serialize(DataOutputView outView)

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectCoordinationResponse

public CollectCoordinationResponse(String version,
                                   long lastCheckpointedOffset,
                                   List<byte[]> serializedResults)

CollectCoordinationResponse

public CollectCoordinationResponse(DataInputView inView)
                            throws IOException

Throws:

IOException

Method Detail

getVersion

public String getVersion()

getLastCheckpointedOffset

public long getLastCheckpointedOffset()

getResults

public <T> List<T> getResults(TypeSerializer<T> elementSerializer)
                       throws IOException

Throws:

IOException

serialize

public void serialize(DataOutputView outView)
               throws IOException

Throws:

IOException