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

wordpress标题北京谷歌seo公司

wordpress标题,北京谷歌seo公司,制作网站的工作流程,做网站能赚钱吗Flink SQL是建立在Apache Flink之上的SQL处理引擎,它允许用户以SQL的方式处理流数据和批数据。以下是一些Flink SQL的基础操作: 一、环境准备 1.启动flink集群 ./start-cluster.sh启动sql-client ./sql-client.sh二、数据源定义 创建表(…

Flink SQL是建立在Apache Flink之上的SQL处理引擎,它允许用户以SQL的方式处理流数据和批数据。以下是一些Flink SQL的基础操作:

一、环境准备

1.启动flink集群

./start-cluster.sh
  1. 启动sql-client
./sql-client.sh

二、数据源定义

  1. 创建表(Source):
  • 使用CREATE TABLE语句定义输入数据源,包括其schema、存储格式(如CSV、JSON等)以及连接器的配置(如Kafka、FileSystem等)。
  • 示例:
CREATE TABLE students (  id STRING,  name STRING,  age INT,  sex STRING,  clazz STRING  
) WITH (  'connector' = 'kafka',  'topic' = 'students',  'properties.bootstrap.servers' = 'localhost:9092',  'format' = 'csv'  
);

三、数据处理

  1. 编写SQL查询:
  • 使用标准的SQL语句对数据进行查询、过滤、聚合等操作。
  • 示例:
SELECT id, name, age  
FROM students  
WHERE age > 18;

四、数据输出

  1. 创建表(Sink):
  • 使用CREATE TABLE语句定义输出数据源,用于将处理后的数据写入外部系统,如Kafka、数据库等。
  • 示例:
CREATE TABLE results (  id STRING,  name STRING,  age INT  
) WITH (  'connector' = 'kafka',  'topic' = 'results',  'properties.bootstrap.servers' = 'localhost:9092',  'format' = 'csv'  
);
  1. 插入数据:
  • 使用INSERT INTO语句将查询结果写入Sink表。
  • 示例:
INSERT INTO results  
SELECT id, name, age  
FROM students  
WHERE age > 18;

五、执行与监控

  1. 执行SQL语句:
  • 在Flink SQL客户端或程序中执行SQL语句。
  • 可以通过Flink的Dashboard或其他监控工具来查看作业的执行状态和性能指标。
  1. 结果展示:
  • Flink SQL客户端支持多种结果显示模式,如表格模式、变更日志模式和Tableau模式,可以根据需要设置。

六、其他操作

  1. 动态表:
  • Flink SQL中的表是动态表,支持对流数据的实时查询和处理。
  1. Join操作:
  • Flink SQL支持多种Join方式,包括Regular Joins、Interval Joins、Temporal Joins和Lookup Joins,用于处理表之间的关联查询。
  1. 窗口函数:
  • Flink SQL支持窗口函数,用于对时间序列数据进行分组和聚合操作。

注意事项

  • 在进行Flink SQL操作时,需要确保已经正确配置了Flink环境,并且已经添加了必要的依赖库。
  • Flink SQL的语法和功能可能会随着Flink版本的更新而发生变化,因此建议查阅最新的官方文档以获取准确的信息。

样例操作

1、 从csv中读取数据

CREATE TABLE well_casting_alarm (_id VARCHAR,comCode VARCHAR,wellCode VARCHAR,uuid VARCHAR,type INT,alarmType INT,alarmGrade INT,zp INT,startAlarmTime TIME,startAlarmValue DECIMAL,threshold INT,warnStatus INT,isDeal INT,createTime TIME,_class VARCHAR
) WITH ( 'connector' = 'filesystem','path' = '/wfg/data/sjzz.wellCastingAlarm0606.csv','format' = 'csv'
);

2、查看所有表

Flink SQL> show tables;
+----------------------+
|           table name |
+----------------------+
| employee_information |
|   well_casting_alarm |
+----------------------+
2 rows in set

3、删除表

DROP TABLE well_casting_alarm;

4、查询数据

select *from well_casting_alarm limit 1;

5、删除一条数据

DELETE FROM well_casting_alarm where '_id'='_id';
http://www.shuangfujiaoyu.com/news/23193.html

相关文章:

  • 专注江苏网站建设企业产品推广运营公司
  • wordpress备份整站windows优化大师下载
  • 杭州建设网站制作网络新闻发布平台
  • 杭州建站公司软件外包公司
  • oa系统办公一键优化软件
  • 网站建设 asp 武汉2345网址导航
  • 如何在网上接做网站的小项目百度关键词竞价价格
  • 国外设计网站app媒体公关公司
  • 政府网站源码破解网络优化需要哪些知识
  • 南京网站定制开发公司如何做seo优化
  • 老网站怎么做循环链接搜索引擎优化是什么意思啊
  • 网站做二级域名seo搜索引擎优化工资
  • 一个博彩网站建设下来要花多少钱网站友情链接
  • wordpress站点目录海外推广营销系统
  • 做义工的网站长春百度seo公司
  • 长宁区网站制作人民网舆情数据中心官网
  • 一个网站做3个关键词够优秀的营销案例
  • 99到家网站怎么做杭州关键词优化测试
  • 网站怎么建设dw百度左侧排名
  • 重庆网站开发哪家专业沈阳关键词优化费用
  • h5动态页面玉溪seo
  • 17做网站联系关键词完整版
  • 深圳罗湖网站制作公司哪家好seo变现培训
  • 广州网站开发平台免费发广告网站
  • 外卖网站那家做的好处游戏推广公司好做吗
  • 废品回收网站怎么做网站优化重庆百度快照优化
  • 光谷做网站推广哪家好营销方式有哪几种
  • 烟台seo网站诊断b2b免费发布网站大全
  • 巴中网站建设搜索引擎优化培训免费咨询
  • 网站客户端制作互联网营销的五个手段