Package org.apache.flink.api.connector.source

Class ReaderInfo

java.lang.Object

org.apache.flink.api.connector.source.ReaderInfo

All Implemented Interfaces:

Serializable

@Public
public final class ReaderInfo
extends Object
implements Serializable

A container class hosting the information of a SourceReader.

The reportedSplitsOnRegistration can only be provided when the source implements SupportsSplitReassignmentOnRecovery.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ReaderInfo(int subtaskId, String location)

Method Summary

Modifier and Type	Method	Description
static <SplitT extends SourceSplit> ReaderInfo	createReaderInfo(int subtaskId, String location, List<SplitT> splits)
boolean	equals(Object o)
String	getLocation()
<SplitT extends SourceSplit> List<SplitT>	getReportedSplitsOnRegistration()
int	getSubtaskId()
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReaderInfo

public ReaderInfo(int subtaskId,
                  String location)

Method Detail

createReaderInfo

public static <SplitT extends SourceSplit> ReaderInfo createReaderInfo(int subtaskId,
                                                                       String location,
                                                                       List<SplitT> splits)

getReportedSplitsOnRegistration

public <SplitT extends SourceSplit> List<SplitT> getReportedSplitsOnRegistration()

getSubtaskId

public int getSubtaskId()

Returns:

the ID of the subtask that runs the source reader.

getLocation

public String getLocation()

Returns:

the location of the subtask that runs this source reader.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object