Package org.apache.flink.cdc.connectors.postgres.source.utils
-
Class Summary Class Description ChunkUtils Utilities to split chunks of table.CustomPostgresSchema A CustomPostgresSchema similar to PostgresSchema with customization.PostgresQueryUtils Query-related Utilities for Postgres CDC source.PostgresSourceRecordUtils A utility class for processingSourceRecords from a Postgres source.PostgresTypeUtils A utility class for converting Postgres types to Flink types.TableDiscoveryUtils A utility class for table discovery.