Uses of Class
org.apache.flink.cdc.connectors.maxcompute.options.MaxComputeOptions

Packages that use MaxComputeOptions

Package	Description
org.apache.flink.cdc.connectors.maxcompute
org.apache.flink.cdc.connectors.maxcompute.coordinator
org.apache.flink.cdc.connectors.maxcompute.options
org.apache.flink.cdc.connectors.maxcompute.sink
org.apache.flink.cdc.connectors.maxcompute.utils
org.apache.flink.cdc.connectors.maxcompute.writer

Uses of MaxComputeOptions in org.apache.flink.cdc.connectors.maxcompute

Constructors in org.apache.flink.cdc.connectors.maxcompute with parameters of type MaxComputeOptions

Constructor	Description
MaxComputeDataSink(MaxComputeOptions options, MaxComputeWriteOptions writeOptions)
MaxComputeMetadataApplier(MaxComputeOptions maxComputeOptions)

Uses of MaxComputeOptions in org.apache.flink.cdc.connectors.maxcompute.coordinator

Constructors in org.apache.flink.cdc.connectors.maxcompute.coordinator with parameters of type MaxComputeOptions

Constructor	Description
SessionManageCoordinatedOperatorFactory(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, String schemaOperatorUid)
SessionManageCoordinatorProvider(String operatorName, org.apache.flink.runtime.jobgraph.OperatorID operatorID, MaxComputeOptions options, MaxComputeWriteOptions writeOptions)
SessionManageOperator(MaxComputeOptions options, org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorUid)

Uses of MaxComputeOptions in org.apache.flink.cdc.connectors.maxcompute.options

Methods in org.apache.flink.cdc.connectors.maxcompute.options that return MaxComputeOptions

Modifier and Type	Method	Description
MaxComputeOptions	MaxComputeOptions.Builder.build()

Uses of MaxComputeOptions in org.apache.flink.cdc.connectors.maxcompute.sink

Constructors in org.apache.flink.cdc.connectors.maxcompute.sink with parameters of type MaxComputeOptions

Constructor	Description
MaxComputeEventSink(MaxComputeOptions options, MaxComputeWriteOptions writeOptions)
MaxComputeEventWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, org.apache.flink.api.connector.sink2.Sink.InitContext context)
MaxComputeEventWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, org.apache.flink.api.connector.sink2.WriterInitContext context)
MaxComputeHashFunctionProvider(MaxComputeOptions options)

Uses of MaxComputeOptions in org.apache.flink.cdc.connectors.maxcompute.utils

Methods in org.apache.flink.cdc.connectors.maxcompute.utils with parameters of type MaxComputeOptions

Modifier and Type	Method	Description
static void	SchemaEvolutionUtils.addColumns(MaxComputeOptions options, TableId tableId, List<AddColumnEvent.ColumnWithPosition> columns)	equals to run a sql like: 'alter table table_name add columns (col_name1 type1 comment [, col_name2 type2 ...]);'.
static void	SchemaEvolutionUtils.alterColumnType(MaxComputeOptions options, TableId tableId, Map<String,DataType> typeMapping, Map<String,String> comments)	equals to run a sql like: 'alter table table_name change column old_column_name new_column_name new_data_type;'.
static void	SchemaEvolutionUtils.alterTableComment(MaxComputeOptions options, TableId tableId, String comment)
static void	MaxComputeUtils.createPartitionIfAbsent(MaxComputeOptions options, String schema, String table, String partitionName)
static void	SchemaEvolutionUtils.createTable(MaxComputeOptions options, TableId tableId, Schema schema)	equals to run a sql like: create table table_name (col_name1 type1 comment [, col_name2 type2 ...]);.
static void	SchemaEvolutionUtils.dropColumn(MaxComputeOptions options, TableId tableId, List<String> droppedColumnNames)	equals to run a sql like: 'alter table table_name drop columns col_name1[, col_name2...];'.
static void	SchemaEvolutionUtils.dropTable(MaxComputeOptions options, TableId tableId)
static com.aliyun.odps.Odps	MaxComputeUtils.getOdps(MaxComputeOptions maxComputeOptions)
static String	MaxComputeUtils.getSchema(MaxComputeOptions options, TableId tableId)
static com.aliyun.odps.Table	MaxComputeUtils.getTable(MaxComputeOptions maxComputeOptions, TableId tableId)
static com.aliyun.odps.TableSchema	MaxComputeUtils.getTableSchema(MaxComputeOptions options, TableId tableId)
static com.aliyun.odps.tunnel.TableTunnel	MaxComputeUtils.getTunnel(MaxComputeOptions maxComputeOptions, MaxComputeWriteOptions writeOptions)
static boolean	MaxComputeUtils.isTableExist(MaxComputeOptions maxComputeOptions, TableId tableId)
static boolean	MaxComputeUtils.isTransactionalTable(MaxComputeOptions options, SessionIdentifier sessionIdentifier)
static void	SchemaEvolutionUtils.renameColumn(MaxComputeOptions options, TableId tableId, Map<String,String> nameMapping)	equals to run a sql like: 'alter table table_name change column old_col_name rename to new_col_name;'.
static boolean	MaxComputeUtils.supportSchema(MaxComputeOptions maxComputeOptions)
static void	SchemaEvolutionUtils.truncateTable(MaxComputeOptions options, TableId tableId)

Uses of MaxComputeOptions in org.apache.flink.cdc.connectors.maxcompute.writer

Methods in org.apache.flink.cdc.connectors.maxcompute.writer with parameters of type MaxComputeOptions

Modifier and Type	Method	Description
static MaxComputeWriter	MaxComputeWriter.batchWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)

Constructors in org.apache.flink.cdc.connectors.maxcompute.writer with parameters of type MaxComputeOptions

Constructor	Description
BatchAppendWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)
BatchUpsertWriter(MaxComputeOptions options, MaxComputeWriteOptions writeOptions, SessionIdentifier sessionIdentifier)