org.apache.paimon.flink.action.cdc.postgres

Class PostgresActionUtils

java.lang.Object

org.apache.paimon.flink.action.cdc.postgres.PostgresActionUtils

public class PostgresActionUtils
extends Object

Utils for Postgres Action.

Constructor Summary

Constructors

Constructor and Description
PostgresActionUtils()

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.cdc.connectors.base.source.jdbc.JdbcIncrementalSource<CdcSourceRecord>	buildPostgresSource(org.apache.flink.configuration.Configuration postgresConfig, String[] schemaList, String[] tableList)
static JdbcSchemasInfo	getPostgresTableInfos(org.apache.flink.configuration.Configuration postgresConfig, java.util.function.Predicate<String> monitorTablePredication, List<Identifier> excludedTables, TypeMapping typeMapping)
static void	registerJdbcDriver()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PostgresActionUtils

public PostgresActionUtils()

Method Detail

getPostgresTableInfos

public static JdbcSchemasInfo getPostgresTableInfos(org.apache.flink.configuration.Configuration postgresConfig,
                                                    java.util.function.Predicate<String> monitorTablePredication,
                                                    List<Identifier> excludedTables,
                                                    TypeMapping typeMapping)
                                             throws Exception

Throws:

Exception

buildPostgresSource

public static org.apache.flink.cdc.connectors.base.source.jdbc.JdbcIncrementalSource<CdcSourceRecord> buildPostgresSource(org.apache.flink.configuration.Configuration postgresConfig,
                                                                                                                          String[] schemaList,
                                                                                                                          String[] tableList)

registerJdbcDriver

public static void registerJdbcDriver()