Package org.apache.flink.cdc.runtime.operators.schema.distributed

Class Summary

Class	Description
SchemaCoordinator	Coordinator node for SchemaOperator.
SchemaCoordinatorProvider	Provider for SchemaCoordinator.
SchemaOperator	This operator merges upstream inferred schema into a centralized Schema Registry.
SchemaOperatorFactory	Factory to create SchemaOperator.