开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC 中java: PostgresSource中是 private 访问控制?

Flink CDC 中java: PostgresSourceBuilder()在 com.ververica.cdc.connectors.postgres.source.PostgresSourceBuilder 中是 private 访问控制?image.png flink1.17image.png

展开
收起
真的很搞笑 2023-07-02 16:57:02 107 0
3 条回答
写回答
取消 提交回答
  • 在 Flink CDC 中,PostgresSource 类确实存在一些私有(private)访问控制的成员变量和方法。这是为了封装和保护类的内部实现细节,以确保类的正确性和稳定性。

    以下是 PostgresSource 类中的一些私有成员变量和方法:

    private final PostgresSourceOptions options;:用于存储 PostgresSource 的配置选项,包括数据库连接信息、表信息、事件时间等。 - private volatile boolean running;:用于标识 PostgresSource 是否正在运行。 - private final AtomicReference<Throwable> error;:用于存储 PostgresSource 运行过程中可能出现的异常信息。 - private final PostgresConnectionProvider connectionProvider;:提供 PostgreSQL 数据库连接的实例。 - private final PostgresSequenceNumGenerator sequenceNumGenerator;:用于生成变更数据的序列号。 - private final PostgresSnapshotSplitReader splitReader;:用于读取 PostgreSQL 数据库中的快照数据。 - private final PostgresContinuousSplitReader continuousSplitReader;:用于读取 PostgreSQL 数据库中的增量变更数据。

    此外,还有一些私有方法用于验证选项、启动连续读取器等。

    根据您提供的截图,可能出现该类不可见的原因可能是导入的包或依赖项不正确,或者确实需要某些权限来访问该类。请确保在代码中正确导入了 PostgresSource 类所在的包,并检查您是否具有访问该类的权限。

    2023-07-30 12:54:48
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    在 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

    2023-07-30 10:15:41
    赞同 展开评论 打赏
  • 你是不是导错了包,看下pom和 import,代码最上面的import,看起来是有问题的,此回答整理自钉群“Flink CDC 社区”

    2023-07-02 17:12:33
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载