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

Class CollectCoordinationRequest

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.flink.runtime.operators.coordination.CoordinationRequest

public class CollectCoordinationRequest
extends Object
implements org.apache.flink.runtime.operators.coordination.CoordinationRequest

A CoordinationRequest from the client indicating that it wants a new batch of query results.

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
CollectCoordinationRequest(String version, long offset)
CollectCoordinationRequest(org.apache.flink.core.memory.DataInputView inView)

Method Summary

Modifier and Type	Method	Description
long	getOffset()
String	getVersion()
void	serialize(org.apache.flink.core.memory.DataOutputView outView)

Methods inherited from class java.lang.Object

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

Constructor Detail

CollectCoordinationRequest

public CollectCoordinationRequest(String version,
                                  long offset)

CollectCoordinationRequest

public CollectCoordinationRequest(org.apache.flink.core.memory.DataInputView inView)
                           throws IOException

Throws:

IOException

Method Detail

getVersion

public String getVersion()

getOffset

public long getOffset()

serialize

public void serialize(org.apache.flink.core.memory.DataOutputView outView)
               throws IOException

Throws:

IOException