1回答
要将值插入到具有数组类型的列。在KSQL参考指南中找不到任何与此相关的参考。请让我知道ksql是否支持此功能？如果是，是如何实现的？ 为ARRAY<INTEGER>尝试了以下方法，但都不起作用。
浏览 14提问于2019-10-15得票数 0
回答已采纳
KSQL支持GlobalKtable与Ktable连接吗？
在这一点上我找不到任何类似的东西。如果没有，是否有任何已知的解决办法？
浏览 0提问于2019-07-16得票数 1
回答已采纳
如何使用ksqldb REST 接收墓碑值？如何将墓碑值插入表中。。以下通过REST进行的ksql查询没有接收到这些“已删除”值：Accept: application/vnd.ksql.v1+json
{"ksql":"SELECT * FROM Mo
浏览 1提问于2021-02-22得票数 0
1回答
Kafka键格式
、、
在我的ksql语句中，我想将它提取到两个不同的字段，而不是一个，这样以后我就可以过滤并加入。在文档中，它似乎允许我只将整个字符串插入键中，而不是允许将其格式化为JSON (就像FORMAT_VALUE一样)，请参见下面.对此有什么建议吗？VALUE_FORMAT (必需)指定主题中消息值的序列化格式。支持的格式: JSON、定界符和AVRO
KEY Associates将Kafka主题中的消息键与KSQL流中的一列关联起来。
浏览 2提问于2018-04-15得票数 1
回答已采纳
1回答
有人知道AWS MSK (Kafka的托管流)是否支持KSQL吗？我在confluent平台上看到了许多关于KSQL的视频和文档，但没有看到AWS MSK。请让我知道它是否支持，如果AWS MSK中有任何关于KSQL设置的文档，请让我知道。
谢谢，巴拉
浏览 18提问于2021-05-17得票数 0
我有一个名为getCityStats(string，double string)的自定义UDF，它接受2个参数并返回一个JSON字符串(对象)数组，如下所示
我想在KSQLgetCityStats(cit
浏览 0提问于2018-09-18得票数 0
我尝试使用如下的值格式将大量消息(350米)发送到客户主题(源主题)
从上述源主题的原始值中，该命令如何将值</e
浏览 0提问于2018-06-07得票数 2
回答已采纳
1回答
对于KTable本身由一个Kafka主题定义的KSQL查询，我得到了意想不到的结果。KTABLE是“贸易”，它的背后是紧凑的主题"localhost.dbo.TradeHistory“。贸易的定义ksql> select AccountId, count(*) as Count, sum(Amoun
浏览 3提问于2019-10-12得票数 1
回答已采纳
我从table在ksql中创建了一个kafka topic。将一组数据推送到主题和表中。发布了一个查询并得到了响应。这是我第二次将相同的数据推到topic中，table再次加载。我认为，如果相同的ksql table进入并保留最新值，则key应该覆盖该值。但这是不可能的。我的理解正确吗？
如何使table保留最新值并在相同键上丢弃以前的值，以插入/更新？谢谢
浏览 1提问于2019-04-05得票数 2
回答已采纳
我已经使用KSQL创建了一个流和该流的聚合表。{ "streamsProperties":{
"ksql.strea
浏览 1提问于2019-01-04得票数 2
1回答
我正在尝试构建一个从MySql到Ksql的数据管道。我在用 name VARCHAR(255) NOT NULL, weight FLOAT4.)将数据插入表格proproducts&#x
浏览 0提问于2018-10-23得票数 1
回答已采纳
1回答
我正在尝试将嵌套数组对象插入到KSQL表中。WITH (KAFKA_TOPIC = 'nlpArticlesTrain', PARTITIONS=1, REPLICAS=1, VALUE_FORMAT='AVRO');
我知道我可以使用具有Avro支持的标准在中，我遗漏了一个插入的示例。
浏览 14提问于2020-05-10得票数 0
回答已采纳
1回答
-1 --network cp-all-in-one_default confluentinc/cp-ksql-cli:5.4.0 http://ksql-server:8088
考虑到关系数据库中提供给我的模式(我没有控制)，还有其他(也许更简单)的方法来获得想要的结果吗？当前的方法是使用，它(对于ksql的5.4.0版本)支持每一行的t
浏览 3提问于2020-02-18得票数 0
我有一个名为“stream_car_1”的KSQL数据流，它以lat-lon对的形式给出了它当前的位置。我有另一个KSQL数据流'stream_car_2‘，它以lat-lon对的形式给出了它当前的位置。我必须找到这两辆车之间的地理距离每一次实时的基础上。这可以通过KSQL实现吗？如果是，怎么做？
浏览 2提问于2020-03-24得票数 0
回答已采纳
1回答
, r2) => MyClass(r1.get("f1"), r2.get("f2")), JoinWindows.of(Duration.ofSeconds(30))
在中可用WHERE子句的等效值是什么仅仅使用stream3.filter是个好主意吗？这种方法是否与由KSQL创建的流具有相同的效率？
浏览 0提问于2019-05-03得票数 2
回答已采纳
1回答
cpu","plugin_instance":"23","type":"cpu","type_instance":"idle","meta":{"network:received":true}}]
它是数组，It和浮点数的组合.整件事都在一个json数组里。因此，我花了很长时间使用ksql对这些数据做任何事情。ROWKEY | VARCHAR(STRING) (syst
浏览 1提问于2018-06-25得票数 0
回答已采纳
我没有找到任何用于打印KSQL Server版本的CLI命令，但是当我进入KSQL时，可以在附加的屏幕截图中找到我看到的内容。
KEY= 'GEOFENCEID');
每当从REST MongoDB支持的web应用程序对Geofence MongoDB集合执行插入或更新操作时，数据都会从Kafka API源连接器传入geofence KSQL表。使geofence成为一个表
浏览 12提问于2020-06-04得票数 3
1回答
我正在尝试使用有效负载执行REST的http请求 "ksql": "SELECT * FROM MY_KTABLE;", "auto.offset.reset
浏览 4提问于2017-12-11得票数 0
回答已采纳
首先创建目标流，然后尝试从另一个源流向当前流插入数据。有什么建议吗？ksql> CREATE STREAM sourceTopic1Stream (category varchar, source varchar, type varchar, id varchar, payload%';
--------------------------------------------------------
ksqlksql</e
浏览 3提问于2018-11-06得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
