Class ServerIdRange
- java.lang.Object
-
- org.apache.flink.cdc.connectors.mysql.source.config.ServerIdRange
-
- All Implemented Interfaces:
Serializable
public class ServerIdRange extends Object implements Serializable
This class defines a range of server id. The boundaries of the range are inclusive.- See Also:
MySqlSourceOptions.SERVER_ID, Serialized Form
-
-
Constructor Summary
Constructors Constructor Description ServerIdRange(int startServerId, int endServerId)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ServerIdRangefrom(String range)Returns aServerIdRangefrom a server id range string which likes '5400-5408' or a single server id likes '5400'.intgetEndServerId()intgetNumberOfServerIds()intgetServerId(int subTaskId)intgetStartServerId()StringtoString()
-
-
-
Method Detail
-
getStartServerId
public int getStartServerId()
-
getEndServerId
public int getEndServerId()
-
getServerId
public int getServerId(int subTaskId)
-
getNumberOfServerIds
public int getNumberOfServerIds()
-
from
@Nullable public static ServerIdRange from(@Nullable String range)
Returns aServerIdRangefrom a server id range string which likes '5400-5408' or a single server id likes '5400'.
-
-