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.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReaderInfo(int subtaskId, String location)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
String	getLocation()
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

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.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object