Uses of Class
org.apache.flink.cdc.runtime.operators.sink.SchemaEvolutionClient
-
Packages that use SchemaEvolutionClient Package Description org.apache.flink.cdc.connectors.hudi.sink.function org.apache.flink.cdc.connectors.paimon.sink.v2.bucket -
-
Uses of SchemaEvolutionClient in org.apache.flink.cdc.connectors.hudi.sink.function
Methods in org.apache.flink.cdc.connectors.hudi.sink.function with parameters of type SchemaEvolutionClient Modifier and Type Method Description voidMultiTableEventStreamWriteFunction. setSchemaEvolutionClient(SchemaEvolutionClient schemaEvolutionClient)Sets the SchemaEvolutionClient from the operator level since functions don't have direct access to TaskOperatorEventGateway. -
Uses of SchemaEvolutionClient in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket
Methods in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket with parameters of type SchemaEvolutionClient Modifier and Type Method Description voidBucketAssignOperator. setSchemaEvolutionClient(SchemaEvolutionClient schemaEvolutionClient)
-