Uses of Class
org.apache.flink.cdc.connectors.maxcompute.common.SessionIdentifier
-
-
Uses of SessionIdentifier in org.apache.flink.cdc.connectors.maxcompute.common
Methods in org.apache.flink.cdc.connectors.maxcompute.common that return SessionIdentifier Modifier and Type Method Description static SessionIdentifierSessionIdentifier. of(String project, String schema, String table, String partitionName)static SessionIdentifierSessionIdentifier. of(String project, String schema, String table, String partitionName, String sessionId) -
Uses of SessionIdentifier in org.apache.flink.cdc.connectors.maxcompute.coordinator.message
Methods in org.apache.flink.cdc.connectors.maxcompute.coordinator.message that return SessionIdentifier Modifier and Type Method Description SessionIdentifierCreateSessionRequest. getIdentifier()Methods in org.apache.flink.cdc.connectors.maxcompute.coordinator.message with parameters of type SessionIdentifier Modifier and Type Method Description voidCreateSessionRequest. setIdentifier(SessionIdentifier identifier)Constructors in org.apache.flink.cdc.connectors.maxcompute.coordinator.message with parameters of type SessionIdentifier Constructor Description CreateSessionRequest(SessionIdentifier identifier) -
Uses of SessionIdentifier in org.apache.flink.cdc.connectors.maxcompute.utils
Methods in org.apache.flink.cdc.connectors.maxcompute.utils with parameters of type SessionIdentifier Modifier and Type Method Description static booleanMaxComputeUtils. isTransactionalTable(MaxComputeOptions options, SessionIdentifier sessionIdentifier) -
Uses of SessionIdentifier in org.apache.flink.cdc.connectors.maxcompute.writer
Methods in org.apache.flink.cdc.connectors.maxcompute.writer that return SessionIdentifier Modifier and Type Method Description SessionIdentifierBatchAppendWriter. getSessionIdentifier()SessionIdentifierBatchUpsertWriter. getSessionIdentifier()SessionIdentifierMaxComputeWriter. getSessionIdentifier()Methods in org.apache.flink.cdc.connectors.maxcompute.writer with parameters of type SessionIdentifier Modifier and Type Method Description static MaxComputeWriterMaxComputeWriter. batchWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)Constructors in org.apache.flink.cdc.connectors.maxcompute.writer with parameters of type SessionIdentifier Constructor Description BatchAppendWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)BatchUpsertWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)
-