当前位置: 首页 > article >正文

13、Flink SQL 的 时间属性 介绍

时间属性
a)概述

Flink 可以基于几种不同的 时间 概念来处理数据。

  • 处理时间 指的是执行具体操作时的机器时间(例如 Java的 System.currentTimeMillis()) )
  • 事件时间 指的是数据本身携带的时间,这个时间是在事件产生时的时间。
  • 摄入时间 指的是数据进入 Flink 的时间;在系统内部,会把它当做事件时间来处理。
b)时间属性介绍

像窗口(在 Table API 和 SQL)这种基于时间的操作,需要有时间信息;Table API 中的表就需要提供逻辑时间属性来表示时间,以及支持时间相关的操作。

每种类型的表都可以有时间属性,可以在用CREATE TABLE DDL创建表的时候指定、也可以在 DataStream 中指定、也可以在定义 TableSource 时指定;一旦时间属性定义好,它就可以像普通列一样使用,也可以在时间相关的操作中使用。

只要时间属性没有被修改,而是简单地从一个表传递到另一个表,它就仍


http://www.kler.cn/a/297023.html

相关文章:

  • 【Qt】Qt与Html网页进行数据交互
  • MySQL基本知识2
  • 鸿蒙开发Tabs栏Scroll的使用 【第四篇】
  • Linux 之 mysql-5.7.44 下载/安装(离线)
  • AI 浪潮中的一体化数据库|外滩大会之OceanBase实录
  • 【OpenWrt(3)】内网搭建iperf3测速服务器
  • 如何搭建ETL?
  • 【数据结构】排序算法篇二
  • 【吊打面试官系列-Redis面试题】怎么理解 Redis 事务?
  • 云计算之大数据(上)
  • 八股(7)——Redis
  • 高清无损!探索PDF转JPG的最佳实践工具
  • TikTok Live营销秘籍:创意与趣味性驱动的品牌增长策略
  • Dubbo依赖包
  • Python编码系列—Python团队开发工作流:高效协作的艺术
  • 浅谈:CDN下真实IP的暴露
  • 如何从Oracle Apex页面直接跳转到Oracle EBS form详情页
  • 网管家电脑监控软件如何安装?怎么部署?(保姆级教程奉上!)
  • 漫谈设计模式 [9]:外观模式
  • 软件工程技术专业软件开发综合实训室解决方案