问题标签 [pipelinedb]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
json - 将 json 中的值选择到其他 json 中（Postgres）
我有以下 JSON
而且我需要提取包含另一个json的“数据”中的值“velocidade”。
我正在使用以下语法，但它返回 null。
pipelinedb - 自定义 PipelineDB 扩展
目前我可以看到对 kafka 和 kinesis 的支持，是否可以向 pipelinedb 添加自定义协议扩展？如果是，我在哪里可以找到一些指导方针来编写它。
- 谢谢
pipelinedb - PipelineDB：连续视图输出流意外显示相同的（旧）和（新）值
我正在使用 PipelineDB 0.9.7u3
我玩了一些连续视图输出流，看看我是否可以通过一些更新获得新的连续视图。
这是我的测试用例。
让我们放一些数据。
正如预期的那样：
"t2";190;"待定"
"t1";124;"打开"
"t2";;"";190;"待定"
"t1";;"";124;"打开"
然后，一些更新。
正如预期的那样：
"t2";160;"等待"
"t1";100;"待定"
"t2";;"";190;"待定"
"t1";;"";124;"打开"
“t2”；190；“待定”；160；“等待”
“t1”；124；“打开”；100；“待定”
“t2”；190；“待定”；160；“等待”
“t1”；124；“打开”；100；“待定”
现在，一些新数据和一些更新。
select * from cv_test;按预期返回，但select * from cv_test_upin;没有。
...
“t2”；160；“等待”；90；“垃圾邮件”
"t3";;"";140;"打开"
“t1”；80；“关闭”；80；“关闭”
我预计最后一个“t1”是"t1";100;"pending";80;"closed"
错误或预期行为？
谢谢。
stream - 如何从 pipelinedb 中的连续视图流式输出？
我已经设置了 pipelinedb，效果很好！我想知道在视图中的值更新后是否可以从连续视图中流式传输数据？也就是说，让一些外部流程对视图的更改采取行动。
我希望将从视图生成的指标流式传输到仪表板中，并且我不想使用轮询数据库来实现这一点。
pipelinedb - PipelineDB，获取前 K 项的计数
如何计算流中前 K 值的频率？
假设我们有一个流
我们插入了十行
我怎样才能找回前 2 个项目及其频率？
我想它应该以某种方式同时使用 Top K 和 Count-min Sketch？
postgresql - 插入的默认日期在连续转换中不会改变
我创建了下表。
我的插入：
对于“dt_insersao”值的任何情况，应该默认为“现在”，始终为“2017-06-08 10:35:35”...
我不知道它是从哪里来的这个值..
这个插入被执行到我的持续转换中。
这些插入被执行到我对 pipelinedb 的持续转换中。当我在客户端 PGAdmin 中执行时，日期是正确的。
apache-kafka - 如何在 Pipelinedb 中更新 kafka 扩展
谁能告诉我如何更新 PipelineDB 中的 kafka 扩展，目前使用旧版本，我想升级到最新版本。
pipelinedb - 如何使用 pipelindb 向 kafka 生产者发送消息？
我正在学习 kafka 和 pipelinedb，我遇到了以下语句，如何使用 pipelindb 向 kafka 生产者发送消息？你有例子吗？
amazon-kinesis - Differences in PipelineDB and AWS Kinesis Analytics use of Reference data
I'm doing a comparison of AWS Kinesis Analytics to PipelineDB use of "reference" data in STREAM SQL.
http://docs.aws.amazon.com/kinesisanalytics/latest/dev/limits.html http://docs.pipelinedb.com/joins.html#joins
Question 1: JOIN on multiple reference tables
AWS Kinesis Analytics - only lets you join to reference data from one source. That seems really restrictive! Unless I am not understanding it. I'd want to be able to JOIN on say, USERS, and an ADDRESS reference data. I can't?
PipelineDB - says it supports JOINs, but the docs don't have JOIN examples to multiple reference tables. Does PipelineDB support joining multiple reference tables in it's STREAMS and/or CONTINUOUS VIEWs?
Question 2: Refreshing reference data
AWS Kinesis Analytics - says you have to jump through some hoops (e.g. calling AWS APIs, etc.) to refresh reference data stored in its S3 bucket for the stream
PipelineDB - Can streams simply get the latest reference data as it is updated using standard SQL updates to the reference tables?
Can PipelineDB JOIN to regular SQL VIEWs, so, in essence the SQL VIEW is updated automatically each time the underlying data is changed?