Uses of Class
org.apache.flink.cdc.connectors.vitess.config.SchemaAdjustmentMode
-
Packages that use SchemaAdjustmentMode Package Description org.apache.flink.cdc.connectors.vitess org.apache.flink.cdc.connectors.vitess.config org.apache.flink.cdc.connectors.vitess.table -
-
Uses of SchemaAdjustmentMode in org.apache.flink.cdc.connectors.vitess
Methods in org.apache.flink.cdc.connectors.vitess with parameters of type SchemaAdjustmentMode Modifier and Type Method Description VitessSource.Builder<T>VitessSource.Builder. schemaNameAdjustmentMode(SchemaAdjustmentMode schemaNameAdjustmentMode)Specifies how schema names should be adjusted for compatibility with the message converter used by the connector. -
Uses of SchemaAdjustmentMode in org.apache.flink.cdc.connectors.vitess.config
Methods in org.apache.flink.cdc.connectors.vitess.config that return SchemaAdjustmentMode Modifier and Type Method Description static SchemaAdjustmentModeSchemaAdjustmentMode. avro()static SchemaAdjustmentModeSchemaAdjustmentMode. none()static SchemaAdjustmentModeSchemaAdjustmentMode. valueOf(String name)Returns the enum constant of this type with the specified name.static SchemaAdjustmentMode[]SchemaAdjustmentMode. values()Returns an array containing the constants of this enum type, in the order they are declared. -
Uses of SchemaAdjustmentMode in org.apache.flink.cdc.connectors.vitess.table
Constructors in org.apache.flink.cdc.connectors.vitess.table with parameters of type SchemaAdjustmentMode Constructor Description VitessTableSource(org.apache.flink.table.catalog.ResolvedSchema physicalSchema, int port, String hostname, String keyspace, String tableName, String username, String password, String shard, String gtid, Boolean stopOnReshard, Boolean tombstonesOnDelete, SchemaAdjustmentMode schemaNameAdjustmentMode, TabletType tabletType, String pluginName, String name, Properties dbzProperties)
-