一、流的定義：

　　所謂的“流”（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

總結

以上是生活随笔為你收集整理的pipelineDB学习笔记-2. Stream （流）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。