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

finksql sink到ES 这里es的date类型 我们对应的sql是什么类型的呀?

finksql sink到ES 这里es的date类型 我们对应的sql是什么类型的呀?

展开
收起
真的很搞笑 2023-11-22 08:17:06 100 0
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink SQL中,你可以使用TIMESTAMP类型来对应ES中的date类型。例如,如果你要将一个包含日期和时间的列插入到ES中,你可以使用如下语法:

    INSERT INTO es_sink (id, date_column)
    SELECT id, TIMESTAMP '2023-01-01 12:00:00' as date_column
    FROM my_table;
    

    请注意,你需要根据实际需求来替换'2023-01-01 12:00:00'以及my_table
    另外,如果你想从一个文本字符串中解析日期,你可以使用TO_TIMESTAMP函数。例如:

    INSERT INTO es_sink (id, date_column)
    SELECT id, TO_TIMESTAMP('2023-01-01 12:00:00', 'YYYY-MM-DD HH:MI:SS') as date_column
    FROM my_table;
    

    其中,'YYYY-MM-DD HH:MI:SS'是一个模式字符串,用于指定日期和时间的格式。你需要将其更改为实际的日期格式。

    2023-11-29 14:09:32
    赞同 展开评论 打赏
  • 在Flink SQL中,将数据写入Elasticsearch时,如果Elasticsearch中的字段类型为date,那么对应的SQL类型应该是TIMESTAMP(3)

    2023-11-29 13:53:29
    赞同 展开评论 打赏
  • string和date都可以,映射表string,ES date(不加format),此时写入映射表的时候要手动加'T''Z'image.png
    映射表date,ES date就得在mapping设置format参数了,然后还可以映射表timestamp(0/3/6),ES keyword,三种方式 ES显示的格式是有差别的,此回答整理自钉群“Flink CDC 社区”

    2023-11-22 11:52:13
    赞同 展开评论 打赏

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

相关电子书

更多
SQL Server 2017 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载