Package org.apache.flink.cdc.connectors.maxcompute.utils
-
Class Summary Class Description MaxComputeUtils common utils use for maxcompute connector.RetryUtils Retry utilities to execute a callable with specific retry times.SchemaEvolutionUtils Schema evolution utils for maxcompute.SessionCommitCoordinateHelper The SessionCommitCoordinator class is responsible for coordinating and controlling the order of session submissions by multiple concurrent executors in a distributed processing environment.TypeConvertUtils Data type mapping table This table shows the mapping relationship from Flink types to MaxCompute types and the corresponding Java type representation.