Flink CDC 中java: PostgresSourceBuilder()在 com.ververica.cdc.connectors.postgres.source.PostgresSourceBuilder 中是 private 访问控制？
flink1.17
Flink CDC 中java: PostgresSource中是 private 访问控制？[阿里云实时计算 Flink版]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！
=====这是一个广告位，招租中，联系qq 78315851====
在 Flink CDC 中，
PostgresSource类确实存在一些私有（private）访问控制的成员变量和方法。这是为了封装和保护类的内部实现细节，以确保类的正确性和稳定性。以下是
PostgresSource类中的一些私有成员变量和方法：–
private final PostgresSourceOptions options;：用于存储PostgresSource的配置选项，包括数据库连接信息、表信息、事件时间等。 –private volatile boolean running;：用于标识PostgresSource是否正在运行。 –private final AtomicReference error; ：用于存储PostgresSource运行过程中可能出现的异常信息。 –private final PostgresConnectionProvider connectionProvider;：提供 PostgreSQL 数据库连接的实例。 –private final PostgresSequenceNumGenerator sequenceNumGenerator;：用于生成变更数据的序列号。 –private final PostgresSnapshotSplitReader splitReader;：用于读取 PostgreSQL 数据库中的快照数据。 –private final PostgresContinuousSplitReader continuousSplitReader;：用于读取 PostgreSQL 数据库中的增量变更数据。此外，还有一些私有方法用于验证选项、启动连续读取器等。
根据您提供的截图，可能出现该类不可见的原因可能是导入的包或依赖项不正确，或者确实需要某些权限来访问该类。请确保在代码中正确导入了
PostgresSource类所在的包，并检查您是否具有访问该类的权限。在 Flink CDC 中，PostgresSource 是一个 Java 类，用于实现从 PostgreSQL 数据库中读取变更数据的功能。在 PostgresSource 类中，确实存在一些 private 访问控制的成员变量和方法，这是为了封装和保护类的内部实现细节，以确保类的正确性和稳定性。
具体来说，在 PostgresSource 类中，存在以下 private 成员变量和方法：
private final PostgresSourceOptions options;
该成员变量用于存储 PostgresSource 的配置选项，包括数据库连接信息、表信息、事件时间等。
private volatile boolean running;
该成员变量用于标识 PostgresSource 是否正在运行。
private final AtomicReference error;
该成员变量用于存储 PostgresSource 运行过程中可能出现的异常信息。
private final PostgresConnectionProvider connectionProvider;
该成员变量用于提供 PostgreSQL 数据库连接。
private final PostgresSequenceNumGenerator sequenceNumGenerator;
该成员变量用于生成变更数据的序列号。
private final PostgresSnapshotSplitReader splitReader;
该成员变量用于读取 PostgreSQL 数据库中的快照数据。
private final PostgresContinuousSplitReader continuousSplitReader;
该成员变量用于读取 PostgreSQL 数据库中的增量变更数据。
private void validateOptions(PostgresSourceOptions options);
该方法用于验证 PostgresSource 的配置选项是否正确。
private void startContinuousReader() throws Exception;
该方法用于启动连续读取 PostgreSQL 数据库中的增量变更数据。
private void stopContinuo
你是不是导错了包，看下pom和 import，代码最上面的import，看起来是有问题的，此回答整理自钉群“Flink CDC 社区”