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

这个语法 全托管flink 能执行吗 ?

SELECT * FROM MyTable$audit_log where rowkind='+I' 这个语法 全托管flink 能执行吗 ? 只要更新状态 是 +I 的 其他 -U +U -D 这三个都不要 。【巴别时代基于 Apache Paimon 的 Streaming Lakehouse 的探索与实践】https://minipro.baidu.com/ma/qrcode/parser?app_key=oFx3nbdDN6GWF3Vb0Wh7EDBMBxRTTcfe&launchid=af78a7f9-b464-431d-9c55-727ad3d3c0ff&path=%2Fpages%2Farticle%2Findex%3Fid%3D626753292%26isShared%3D1%26_swebFromHost%3Dbaiduboxapp 我是看到这篇文章里 有提到这个 不清楚我理解的对不对

展开
收起
三分钟热度的鱼 2023-11-01 09:25:21 121 0
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    全托管 Flink 可以执行 SELECT * FROM MyTable$audit_log WHERE rowkind='+I' 这样的 SQL 语句,因为它与普通 Flink-SQL 一样支持标准的 SQL 语法。
    但是,请注意,“rowkind”并不是 Flink 的内置字段,因此它可能会被解析为字符串或别名,并且依赖于表的结构和配置。因此,您可能需要自行定义该字段,才能使其在查询时正常工作。
    另外,请务必谨慎处理这种特殊的查询方式,因为它可能会增加性能开销,并可能导致内存溢出等问题。

    2023-11-01 13:26:30
    赞同 1 展开评论 打赏
  • 根据您提供的信息,SELECT * FROM MyTable$audit_log where rowkind='+I' 是一个 SQL 查询语句,用于从名为 MyTable$audit_log 的表中选取所有符合条件的行。其中,rowkind 是一个列名,而 '+I' 是一个特定的值,表示行的状态为 "insert"(插入)。

    然而,要确定这个语法是否可以在全托管 Flink 平台上执行,需要查看该平台的文档和相关支持信息。Flink 是一个开源流处理框架,用于构建实时数据流应用程序,而具体的语法和功能可能会因平台和配置而有所不同。

    根据您提供的链接,提到的文章是关于巴别时代基于 Apache Paimon 的 Streaming Lakehouse 的探索与实践。Apache Paimon 是一个分布式数据库,提供了流处理和湖仓一体化的功能。根据文章的描述,Paimon 支持使用 SQL 进行数据操作和管理,这表明在 Streaming Lakehouse 场景下,使用 SQL 查询语句是可行的。

    因此,如果您正在使用基于 Apache Paimon 的 Streaming Lakehouse,并且该平台支持 SQL 查询,那么您应该可以在全托管 Flink 上执行类似的查询语句来选取符合特定条件的行。

    2023-11-01 11:56:01
    赞同 展开评论 打赏
  • 是的,这种语法是正确的,可以在全托管 Flink 中执行。这个表达式是指定了行类型的过滤条件,只保留更新状态为 '+I' 的记录。这是Paimon项目中特有的语法之一。
    在这篇文章中,作者介绍了巴别时代的 Streaming Lakehouse 架构,并使用 Paimon 来实现实时数据处理和分析。在架构中,作者使用了全托管 Flink 实现了对数据库的操作,其中包括了行类型的筛选和过滤。
    image.png

    2023-11-01 09:52:16
    赞同 展开评论 打赏

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

相关产品

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

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