Package org.apache.flink.runtime.source.event

Class ReaderRegistrationEvent

java.lang.Object

org.apache.flink.runtime.source.event.ReaderRegistrationEvent

All Implemented Interfaces:

Serializable, OperatorEvent

public class ReaderRegistrationEvent
extends Object
implements OperatorEvent

The SourceOperator should always send the ReaderRegistrationEvent with the `reportedSplitsOnRegistration` list. But it will not add the splits to readers if SupportsSplitReassignmentOnRecovery is implemented.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ReaderRegistrationEvent(int subtaskId, String location)

Method Summary

Modifier and Type	Method	Description
static <SplitT extends org.apache.flink.api.connector.source.SourceSplit> ReaderRegistrationEvent	createReaderRegistrationEvent(int subtaskId, String location, List<SplitT> splits, org.apache.flink.core.io.SimpleVersionedSerializer<SplitT> splitSerializer)
String	location()
<SplitT extends org.apache.flink.api.connector.source.SourceSplit> List<SplitT>	splits(org.apache.flink.core.io.SimpleVersionedSerializer<SplitT> splitSerializer)
int	subtaskId()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.runtime.operators.coordination.OperatorEvent

isLossTolerant

Constructor Detail

ReaderRegistrationEvent

public ReaderRegistrationEvent(int subtaskId,
                               String location)

Method Detail

createReaderRegistrationEvent

public static <SplitT extends org.apache.flink.api.connector.source.SourceSplit> ReaderRegistrationEvent createReaderRegistrationEvent(int subtaskId,
                                                                                                                                       String location,
                                                                                                                                       List<SplitT> splits,
                                                                                                                                       org.apache.flink.core.io.SimpleVersionedSerializer<SplitT> splitSerializer)
                                                                                                                                throws IOException

Throws:

IOException

splits

public <SplitT extends org.apache.flink.api.connector.source.SourceSplit> List<SplitT> splits(org.apache.flink.core.io.SimpleVersionedSerializer<SplitT> splitSerializer)
                                                                                       throws IOException

Throws:

IOException

subtaskId

public int subtaskId()

location

public String location()

toString

public String toString()

Overrides:

toString in class Object