Package org.apache.flink.cdc.connectors.maxcompute.common

Class SessionIdentifier

java.lang.Object

org.apache.flink.cdc.connectors.maxcompute.common.SessionIdentifier

All Implemented Interfaces:

Serializable

public class SessionIdentifier
extends Object
implements Serializable

A Session is uniquely identified through TableId and partitionName. When the Session is successfully created, this class can also carry the sessionId. Note that sessionId does not participate in the comparison of hashcode and equals.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
SessionIdentifier(String project, String schema, String table, String partitionName)
SessionIdentifier(String project, String schema, String table, String partitionName, String sessionId)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getPartitionName()
String	getProject()
String	getSchema()
String	getSessionId()
String	getTable()
int	hashCode()
static SessionIdentifier	of(String project, String schema, String table, String partitionName)
static SessionIdentifier	of(String project, String schema, String table, String partitionName, String sessionId)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionIdentifier

public SessionIdentifier(String project,
                         String schema,
                         String table,
                         String partitionName)

SessionIdentifier

public SessionIdentifier(String project,
                         String schema,
                         String table,
                         String partitionName,
                         String sessionId)

Method Detail

of

public static SessionIdentifier of(String project,
                                   String schema,
                                   String table,
                                   String partitionName)

of

public static SessionIdentifier of(String project,
                                   String schema,
                                   String table,
                                   String partitionName,
                                   String sessionId)

getProject

public String getProject()

getSchema

public String getSchema()

getTable

public String getTable()

getPartitionName

public String getPartitionName()

getSessionId

public String getSessionId()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object