回答情况：
提问时间：
问题标签：
我试图将一个Seq[DataSet(Long,Long,Double)]与Flink中的单个DataSet[(Long,Long,Double)]结合起来： el.vector, 150, metric)).reduce( ).collect()我
浏览 1修改于2015-07-24得票数 4
回答已采纳
我的生产者是apache Kafka，我们想要监听一批事件来处理它们，并将处理后的事件写入数据库。如果我使用流/批处理，每个事件都会命中一个对DB的查询。我不想把每个事件都作为一个查询来处理。如何批量处理一些事件并将这些批量数据写入DB？ 注意:我们使用的是DataStream接口
浏览 44提问于2021-04-28得票数 0
/start-slave.sh spark://ApacheFlink:7077开始这是scala代码。= {
val conf = new SparkConf().setAppName("TestInput").setMaster("spark://ApacheFlink
浏览 14提问于2017-08-09得票数 0
我开始在Java的ApacheFlink中工作。
我的目标是在一分钟的时间窗口中使用一个ApacheKafka主题，这将应用非常基本的信息，并将每个窗口的结果记录在一个文件中。
浏览 17提问于2019-11-08得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号