flink tableapi从DataStream创建表

val dataStream = inputStream
.map(data => {
val arr = data.split(",")
SensorReading(arr(0), arr(1).toLong, arr(2).toDouble)
})
//创建表
val dataTable = tableEnv.fromDataStream(dataStream)

//表里直接获取数据
val resultTable = dataTable.select("id,temperature").filter("id == 'sensor_1'")//注册表，写sql
tableEnv.createTemporaryView("sensor_table",dataTable)
val sql = "select id,temperature from sensor_table where id = 'sensor_1'"

val resultSqlTable = tableEnv.sqlQuery(sql)

flink tableapi从DataStream创建表相关推荐

1.18.2.Table APISQL(概念与通用API、两种计划器（Planner）的主要区别、创建 TableEnvironment、临时表、永久表、创建表、虚拟表、Connector 等)
1.18.2.概念与通用API 1.18.2.1.两种计划器(Planner)的主要区别: 1.18.2.2.Table API和SQL程序的结构 1.18.2.3.创建 TableEnvironme ...
Flink Table 和 DataStream 转换
文章目录 Flink Table 和 DataStream 转换 1. 表(Table) 转换为流(DataStream) 1.1 处理(仅插入)流 1.1.1 fromDataStream()方法 ...
95-134-110-源码-维表-Flink 1.9.0 维表实现
1.视界 2.概述请参考:95-134-100-源码-维表-实现维表需要的Aysnc IO Flink 1.9 中维表功能来源于新加入的Blink中的功能,如果你要使用该功能,那就需要自己引入 Bl ...
flink fi java_Flink DataStream API编程指南
Flink中的DataStream程序是实现数据流转换的常规程序(例如:filtering, updating state, defining windows, aggregating).数据流最初是 ...
flink学习(五)DataStream API
目录编程的模型 Source 基于集合的Source 基于文件的Source 基于socket的Source 自定义source--MySQL Transformation 基本操作合并和拆分分 ...
Linux下oracle创建表空间及用户
最近在测试flink的oracle-cdc,公司领导在没用的测试环境搭了一个oracle供我测试,一开始我是拒绝的,毕竟oracle除了crud,也不会别的,奈何拒绝不了,只能边学变做. 1,登录sy ...
MySQL 学习笔记（13）— 创建表、修改表、删除表、清空表
1. 创建表在 SQL 中,使用 CREATE TABLE 语句创建一个表: CREATE TABLE table_name (column1 data_type column_constraint ...
mysql怎么创建表视频教程_mySQL学习入门教程——2.创建表
二.创建表一.创建数据表的SQL语句模型(弱类型) CREATE TABLE [IF NOT EXISTS] 表名称( 字段名1 列的类型[属性][索引], 字段名2 列的类型[属性][索引], - ...
oracle与mysql创建表时的区别
oracle创建表时,不支持在建表时同时增加字段注释.故采用以下方式: #创建表 CREATE TABLE predict_data as (id integer NOT NULL, uid varc ...

flink tableapi从DataStream创建表

flink tableapi从DataStream创建表相关推荐

最新文章

热门文章