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

Class MaxComputeUtils

java.lang.Object

org.apache.flink.cdc.connectors.maxcompute.utils.MaxComputeUtils

public class MaxComputeUtils
extends Object

common utils use for maxcompute connector.

Constructor Summary

Constructors

Constructor	Description
MaxComputeUtils()

Method Summary

Modifier and Type	Method	Description
static com.aliyun.odps.tunnel.io.CompressOption	compressOptionOf(String compressAlgo)
static void	createPartitionIfAbsent(MaxComputeOptions options, String schema, String table, String partitionName)
static com.aliyun.odps.Odps	getOdps(MaxComputeOptions maxComputeOptions)
static String	getSchema(MaxComputeOptions options, TableId tableId)
static com.aliyun.odps.Table	getTable(MaxComputeOptions maxComputeOptions, TableId tableId)
static com.aliyun.odps.TableSchema	getTableSchema(MaxComputeOptions options, TableId tableId)
static com.aliyun.odps.tunnel.TableTunnel	getTunnel(MaxComputeOptions maxComputeOptions, MaxComputeWriteOptions writeOptions)
static boolean	isTableExist(MaxComputeOptions maxComputeOptions, TableId tableId)
static boolean	isTransactionalTable(MaxComputeOptions options, SessionIdentifier sessionIdentifier)
static boolean	schemaEquals(com.aliyun.odps.TableSchema currentSchema, com.aliyun.odps.TableSchema expectSchema)
static boolean	supportSchema(MaxComputeOptions maxComputeOptions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MaxComputeUtils

public MaxComputeUtils()

Method Detail

getOdps

public static com.aliyun.odps.Odps getOdps(MaxComputeOptions maxComputeOptions)

getTunnel

public static com.aliyun.odps.tunnel.TableTunnel getTunnel(MaxComputeOptions maxComputeOptions,
                                                           MaxComputeWriteOptions writeOptions)

getTable

public static com.aliyun.odps.Table getTable(MaxComputeOptions maxComputeOptions,
                                             TableId tableId)

getTableSchema

public static com.aliyun.odps.TableSchema getTableSchema(MaxComputeOptions options,
                                                         TableId tableId)

supportSchema

public static boolean supportSchema(MaxComputeOptions maxComputeOptions)

compressOptionOf

public static com.aliyun.odps.tunnel.io.CompressOption compressOptionOf(String compressAlgo)

isTableExist

public static boolean isTableExist(MaxComputeOptions maxComputeOptions,
                                   TableId tableId)

schemaEquals

public static boolean schemaEquals(com.aliyun.odps.TableSchema currentSchema,
                                   com.aliyun.odps.TableSchema expectSchema)

createPartitionIfAbsent

public static void createPartitionIfAbsent(MaxComputeOptions options,
                                           String schema,
                                           String table,
                                           String partitionName)
                                    throws com.aliyun.odps.OdpsException

Throws:

com.aliyun.odps.OdpsException

getSchema

public static String getSchema(MaxComputeOptions options,
                               TableId tableId)

isTransactionalTable

public static boolean isTransactionalTable(MaxComputeOptions options,
                                           SessionIdentifier sessionIdentifier)