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

flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ?

flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ?

展开
收起
真的很搞笑 2023-09-28 09:56:26 87 0
1 条回答
写回答
取消 提交回答
  • Flink CDC 可以支持 SQL Server 2008 或以上版本的增量获取。可以参考以下示例:

    CREATE TABLE MyTable (
    Id INT,
    Name VARCHAR(255),
    Age INT
    ) WITH (
    'connector' = 'sqlserver',
    'url' = 'jdbc:sqlserver://localhost:1433;database=MyDatabase',
    'username' = 'sa',
    'password' = 'password',
    'table-name' = 'MyTable',
    'key-column' = 'Id',
    'timestamp-column' = 'UpdatedOn'
    )
    启动此 Flink CDC 作业后,它将从 MyTable 表中读取数据,并将增量更改写入一个新的 Kafka 主题。

    你可以使用 Kafka 客户端读取这个 Kafka 主题,并将数据写入你自己的应用程序。

    2023-10-12 11:52:52
    赞同 展开评论 打赏

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

相关电子书

更多
SQL Server在电子商务中的应用与实践 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载