当前位置： 首页 > news >正文

（十二）Flink Table API

news 来源：原创 2024/9/14 17:48:05

目录

Table API 案例

Table API 连接操作

Table API 是批处理和流处理的统一的关系型 API。Table API 的查询不需要修改代码就可以采用批输入或流输入来运行。Table API 是 SQL 语言的超集，并且是针对 Apache Flink 专门设计的。Table API 集成了 Scala，Java 和 Python 语言的 API。Table API 的查询是使用 Java，Scala 或 Python 语言嵌入的风格定义的，有诸如自动补全和语法校验的 IDE 支持，而不是像普通 SQL 一样使用字符串类型的值来指定查询。

Table API 案例

1. 示例：订单分组计数

下面的例子中假定有一张叫 Orders 的表，表中有属性 (orderId, dept, amount, orderTime) 。orderTime 字段是流任务中的逻辑时间属性或是批任务中的普通时间戳字段。

按照部门分组，统计每个部门的单量（数据来源于 CSV 文件）。

具体代码实现如下：

import org.apache.flink.table.api.*;import java.net.URLDecoder;import static org.apache.flink.table.api

相关文章：

  • 给自闭症孩子家长的建议：携手同行，共筑爱的桥梁
  • Docker常见命令和参数
  • Cmake相关概念
  • HikariCP源码分析之源码环境搭建
  • 优化MySQL性能的方法
  • C#知识|语法拾遗：分支结构、循环
  • spark-sql 写入paimon主键表报错 Cannot write nullable values to non-null column
  • MegaCLI和H750阵列卡不匹配导致的服务夯死
  • 第二证券：两融账户开通需要的条件？证券两融开户？
  • Android中几种线程交互方式
  • uniapp开发安卓app--安卓低版本（4.4）不显示echarts图表问题解决思路
  • DataX
  • ES6 -- 总结 03
  • Linux网络编程——C/C++Web服务器（二）：IO多路复用select/poll/epoll实现服务器监听多客户端事件
  • Java 使用 POI 导出Excel，实现单元格内容为下拉选项
  • Android优雅地处理按钮重复点击
  • - C#编程大幅提高OUTLOOK的邮件搜索能力!
  • js算法-归并排序（merge_sort）
  • Kibana配置logstash，报表一体化
  • log4j2输出到kafka
  • MaxCompute访问TableStore(OTS) 数据
  • passportjs 源码分析
  • Python_网络编程
  • UEditor初始化失败（实例已存在，但视图未渲染出来，单页化）
  • 不上全站https的网站你们就等着被恶心死吧
  • 机器学习 vs. 深度学习
  • 聊聊springcloud的EurekaClientAutoConfiguration
  • 每个JavaScript开发人员应阅读的书【1】 - JavaScript: The Good Parts
  • 前端临床手札——文件上传
  • 如何实现 font-size 的响应式
  • 手写一个CommonJS打包工具（一）
  • 怎么将电脑中的声音录制成WAV格式
  • JavaScript 新语法详解：Class 的私有属性与私有方法 ...
  • 说说我为什么看好Spring Cloud Alibaba
  • ​14：00面试，14：06就出来了，问的问题有点变态。。。
  • ​一些不规范的GTID使用场景
  • #使用清华镜像源 安装/更新 指定版本tensorflow
  • (1) caustics\
  • （1）Hilt的基本概念和使用
  • （DFS + 剪枝）【洛谷P1731】 [NOI1999] 生日蛋糕
  • （PHP）设置修改 Apache 文件根目录 (Document Root)（转帖）
  • （翻译）Entity Framework技巧系列之七 - Tip 26 – 28
  • （附源码）springboot“微印象”在线打印预约系统 毕业设计 061642
  • (区间dp) (经典例题) 石子合并
  • （十八）Flink CEP 详解
  • （转）nsfocus-绿盟科技笔试题目
  • （转）PlayerPrefs在Windows下存到哪里去了？
  • （转）大型网站的系统架构
  • **CI中自动类加载的用法总结
  • .NET 使用配置文件
  • .NET项目中存在多个web.config文件时的加载顺序
  • .Net中的集合
  • .pyc文件还原.py文件_Python什么情况下会生成pyc文件？
  • @CacheInvalidate(name = “xxx“, key = “#results.![a+b]“,multi = true)是什么意思
  • @component注解的分类