Class MaxComputeMetadataApplier
- java.lang.Object
-
- org.apache.flink.cdc.connectors.maxcompute.MaxComputeMetadataApplier
-
- All Implemented Interfaces:
Serializable,AutoCloseable,MetadataApplier
public class MaxComputeMetadataApplier extends Object implements MetadataApplier
AMetadataApplierfor "MaxCompute" connector.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description MaxComputeMetadataApplier(MaxComputeOptions maxComputeOptions)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidapplySchemaChange(SchemaChangeEvent schemaChangeEvent)Apply the givenSchemaChangeEventto external systems.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.flink.cdc.common.sink.MetadataApplier
acceptsSchemaEvolutionType, close, getExistingTableSchemaExpansionSupport, getSupportedSchemaEvolutionTypes, setAcceptedSchemaEvolutionTypes
-
-
-
-
Constructor Detail
-
MaxComputeMetadataApplier
public MaxComputeMetadataApplier(MaxComputeOptions maxComputeOptions)
-
-
Method Detail
-
applySchemaChange
public void applySchemaChange(SchemaChangeEvent schemaChangeEvent)
Description copied from interface:MetadataApplierApply the givenSchemaChangeEventto external systems.- Specified by:
applySchemaChangein interfaceMetadataApplier
-
-