pipelineDB学习笔记-2. Stream (流)

一、流的定义:

  所谓的“流”(stream)在pipelineDB中是指那些被允许的数据库客服端推送到 Continuous View(连续视图) 的时序化数据的一种“抽象”。流中的每一个raw(数据列)或者event(事件),看起来是和普通表中的数据一样的,并且写入数据到stream中和写入数据到table中的接口是一模一样的。stream与table只是在语义上不同而已。现实世界江河中的水流中的水一旦被使用,就会从水流中永远消失,而水流的这种特性是与stream一抹一眼的。当stream中的数据被Continuous View 消费掉之后,stream中就不再存在被消费掉的数据,如同水流一般,并且stream被设计出来只是为了给Continuous View服务的,所以用户无法通过普通的 select 语句查看stream的数据。

 

二、 创建语句:

  

     stream_name : stream的名字

   column_name: 列名

   data_type : 列的数据类型,pipelinedb支持2大类:内置函数,postgresql的数据类型 ,这两大类的详细请查看有关文档,此处不做赘述了。

   内置函数的详细信息:http://docs.pipelinedb.com/builtin.html#builtin 

     postgreSQL的数据类型: https://www.postgresql.org/docs/current/datatype.html  

   COLLATE collation :  这个目前还未理解到,有了解的朋友请说一声。

三、 通过 ALTER STREAM 给stream添加字段.

   

          注意事项:stream中的列不能被删除

四、  删除stream

  语句: DROP FOREIGN  TABLE

  

五、   写入数据到stream中

  1. 语法: 

 

   query :  是指select语句

   2、普通插入数据到stream

  

 3、 性能更好的批量插入

  

 

 4、 任意的表达式插入

     5、 预备插入

      pipelinedb为了减小网络压力而提供了一种 “ Prepared Insert” 既预备插入 . 可在需要时再实际的写入数据到stream中。

 

 

    6、 COPY

      可以通过COPY命令从文件读取数据然后放入stream,

      也可以从标准输入中读取数据后写入到stream

       

 

 

 

未完······ 

转载于:https://www.cnblogs.com/zhaohuaxishi/p/10102640.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/484579.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

银行家算法之Python实现[操作系统实验]

银行家算法 银行家算法是著名的死锁避免算法,其思想是:把操作系统视为银行家,操作系统管理的资源相当于银行家管理的资金,进程向操作系统请求分配资源相当于用户向银行家贷款。操作系统按照银行家制定的规则为进程分配资源。进程…

城市智能化发展中,AI公司应该做什么?

来源:虎嗅APP题图来源:视觉中国在上海长宁区的部分区域,你会发现共享单车总是能够整整齐齐的排列,并且在每一个你需要的街道路边,都能找到空闲的单车,既不会车辆爆满,也不会无车可骑。这些城市细微之处的体…

getchar(),putchar()用法

1.getchar函数可以接收用户输入的多个字符,只用等用户按下回车键后,getchar()函数才会从键盘缓冲区依次读出字符; 2.getchar()和putchar()结合使用,可以将读取的字符输出到屏幕; 3.函数原型: int getchar…

[操作系统]页面置换算法实验及C++实现(OPT、FIFO、LRU)

虚拟内存页面置换算法实验(OPT、FIFO、LRU) 进程运行时,若其访问的页面不再内存中而需将其调入,但内存已无空闲空间时,就需要从内存中调出一页程序或数据,送入磁盘的对换区。选择调出页面的算法就称为页面…

智谱AI多项成果惊艳亮相2021北京智源大会

来源:学术头条2021 年 6 月 1 日,由北京智源人工智能研究院(以下简称 “智源”)主办的 2021 北京智源大会在北京中关村国家自主创新示范区会议中心成功开幕。包括 Yoshua Bengio、David Patterson 等图灵奖获得者在内的两百余位国…

python-字典方法

1.字典的格式化字符串在转换说明符%后面加上键(圆括号括起来);phonebook{"A":45,"B":"56"} s"As phone number is %(A)s." print(s%phonebook) 运行结果: #字典方法: #clear():清楚字典中的所有的项…

js常用随手记

1. 判断是否是空对象 let myObject{} Object.keys(myObject).length // 0 2. void 0 代替 undefined undefined 不是保留字,在局部作用域下能被重写,因此在 val undefined 是有风险的 并且代替后有以下优点: void 0 占用字节更少void 0 更安…

2020-2021学年(2)操作系统考试重点[华侨大学]

2020-2021学年(2)操作系统考试重点 名词解释 操作系统:操作系统是程序的集合,负责控制和管理软硬件资源,并实现作业调度分时系统:(分时性)宏观上,多个用户同时工作,共享系统资源。…

获得诺贝尔奖的底层小职员 | 从来没有一个高手,是在一夜之间强大起来的

来源:Pinterest优选2019年初NHK的一个访谈纪录片,看哭了很多网友。“感动,这才是真正的大神啊!”纪录片的主人公,是2002年的诺贝尔化学奖得主——田中耕一。十九年前,他的获奖几乎是“都市传说”般的爆炸新…

python-循环语句基础知识

#循环语句 x1 while x<100:print(x)x1 name while not name:nameinput("input name:")namename.strip()#删除空格&#xff0c;制表&#xff0c;换行符print(name)w[A,"B",C,D] for i in w:print(i)#内建函数&#xff1a;range()包含下限&#xff0c;不包…

bzoj3160: 万径人踪灭

数组开小gg fft乱搞就可以了。 #include<cstdio> #include<iostream> #include<cstring> #include<cstdlib> #include<algorithm> #include<cmath> using namespace std; typedef long long LL; const LL mod1e97; const double piacos(-…

光辉岁月:人工智能的那些人和事(1)

来源&#xff1a;图灵人工智能源头茫昧虽难觅&#xff0c;活水奔流喜不休。——法国数学家亨利庞加莱&#xff08;Henri Poincare&#xff09;目前&#xff0c;人工智能&#xff08;Artificial Intelligence&#xff0c;AI&#xff09;正在迅速崛起。现已面世的AI应用&#xff…

MySQL主从架构及读写分离实战

​​​​​​ 目录 一、实验目的与环境 二、基础环境介绍 三、搭建主从集群 1、理论基础 2、同步的原理 3、搭建主从集群 3.1 配置master主服务器 3.2 配置slave从服务 3.3 主从集群测试 3.4 集群搭建扩展&#xff1a; 3.5、GTID同步集群 4、集群扩容 5、半同步复…

C++基本数据类型

1.C对基本的数据类型进行了封装&#xff0c;成为内置数据类型。 2.有符号整数在内存中存放为补码&#xff0c;无符号整数在内存中存放为原码&#xff1b; Visual C 基本数据类型类型占用字节数名称占用比特位数bool1布尔型8(signed) char1有符号字符型8unsigned char1无符号字…

编译原理课程实践——实现一个初等函数运算语言的解释器或编译器

编译原理课程实践——实现具有初等函数运算语言的解释器或编译器 作者&#xff1a;Sylvan Ding &#xff5c;转载请注明文章出处&#xff01; 摘要&#xff1a;本文主要内容是设计词法分析器、语法分析器&#xff08;LL(1)、SLR(1)&#xff09;和语义分析器&#xff08;基于SL…

数据结构开发(3):线性表的顺序存储结构

0.目录 1.线性表的本质和操作 2.线性表的顺序存储结构 3.顺序存储结构的抽象实现和具体实现 3.1 SeqList3.2 StaticList 和 DynamicList4.顺序存储线性表的分析 4.1 效率分析4.2 功能分析5.小结 1.线性表的本质和操作 线性表 ( List ) 的表现形式&#xff1a; 零个或多个数据元…

小目标检测的一些问题,思路和方案

来源&#xff1a;机器学习研究组订阅机器学习正越来越多地进入我们的日常生活。从个人服务的广告和电影推荐&#xff0c;到自动驾驶汽车和自动送餐服务。几乎所有的现代自动化机器都能“看”世界&#xff0c;但跟我们不一样。为了像我们人类一样看到和识别每个物体&#xff0c;…

python-条件语句

#条件、循环和其他语句 #print:可以打印多个表达式&#xff0c;表达式之间用逗号隔开 print(a,"b",False)#参数并不构成一个元组 模块导入:import x :导入模块xfrom x import func &#xff1a;导入模块x的函数funcfrom x import func1,func2,... 导入模块…

第21条:用函数对象表示策略

第21条&#xff1a;用函数对象表示策略 有些语言支持函数指针&#xff08;function pointer&#xff09;、代理&#xff08;delegate&#xff09;、lambda表达式&#xff08;lambda expression&#xff09;&#xff0c;或者支持类似的机制&#xff0c;允许程序把“调用特殊函数…

2021-2022学年编译原理考试重点[华侨大学]

2021-2022学年编译原理考试重点 注&#xff1a;计算部分请参考 编译原理实验报告 名词解释 编译器&#xff1a;编译阶段&#xff0c;用户输入源程序&#xff0c;经编译器翻译生成目标程序&#xff0c;目标程序在运行时接受输入数据&#xff0c;得到数据输出 解释器&#xff1a…