Package org.apache.flink.cdc.connectors.values
-
Class Summary Class Description ValuesDatabase An auxiliary class for simulating a database, use forValuesDataSourceandValuesDataSink.ValuesDatabase.ErrorOnChangeMetadataApplier apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.ValuesDatabase.ValuesMetadataAccessor provide namespace/schema/table lists forValuesDataSource.ValuesDatabase.ValuesMetadataApplier apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.