已有1人关注此标签
作者: 李博 bluemind
324人浏览
1人回答
比如user对象,我用性别分组,怎么即算出年龄总和,又算出身高总和 本问题来自云栖社区【阿里Java技术进阶2群】。https://yq.aliyun.com/articles/690084 点击链接欢迎加入社区大社群。
作者: 游客irm3nny572smk
211人浏览
2人回答
使用一句话识别RESTful API以POST方式请求返回的是 HTTP/1.1 302 FoundServer: Tengine Date: Thu, 28 Mar 2019 02:52:56 GMTContent-Type: text…
作者: 游客irm3nny572smk
170人浏览
1人回答
302 Found The requested resource resides temporarily under a different URI. Powered by Tengine
作者: krystal.xu
660人浏览
1人回答
flnk 新手一枚。。我理解flink stream = 动态table, 但是sql里的 where语句条件能否使用stream/source的值。 example: DataStream<String> input…
作者: 社区小助手
335人浏览
1人回答
请教大家一个问题,spark stream连kafka,在web页面的stream标签,显示好多batch处于queued状态,这些batch是已经把数据从kafka读取进rdd,等待处理,还是还没有从kafka读取数进rdd?
作者: stevenchennet
451人浏览
2人回答
场景描述设备工作期间每隔固定周期(比如30s)就往kafka发送采集到的数据,当设备超过15分钟没有上报数据,则认为设备离网了。如何每隔10分钟计算出设备在该10分钟时间段内的离网时长? 按我的理解(可能有错,请多指正),stream不设…
作者: flink小助手
1290人浏览
1人回答
我有一个来自Kafka的DataStream,它对MyModel中的一个字段有两个可能的值。MyModel是一个pojo,其中包含来自Kafka的消息解析的特定于域的字段。 DataStream stream = env.addSourc…
作者: flink小助手
351人浏览
1人回答
我将Apache Beam SDK与用于流处理的Flink SDK进行比较,以确定使用Beam作为附加框架的成本/优势。 我有一个非常简单的设置,其中从Kafka源读取数据流并由运行Flink的节点集群并行处理。 根据我对这些SDK如何工…