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 aSourceReader.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ReaderInfo(int subtaskId, String location)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object obj)StringgetLocation()intgetSubtaskId()inthashCode()
-
-
-
Constructor Detail
-
ReaderInfo
public ReaderInfo(int subtaskId, String location)
-
-
Method Detail
-
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.
-
-