我正在尝试设置一个流，其中首先执行一个countWindow。countWindow发出的结果需要传递给不同的timeWindow。问题是timeWindow没有发出任何结果。String] { println("getKey 1") } .countWindowString] {
override def getKey(value
浏览 24提问于2019-09-02得票数 0
回答已采纳
2回答
Size=18340663，maxSize=5242880可以应用TimeWindow和CountWindow的OR函数吗？
浏览 3提问于2019-01-30得票数 2
1回答
创建一个由十项组成的窗口 public void apply(Tuple tuple, GlobalWindow timeWindow模式是匹配的
我打印了inputStream和WindowedStream，我可以看到它们都发送类
浏览 1提问于2017-01-06得票数 0
我的场景是这样的.我在上见过这个。假设我有一个查询来统计故障总数，每12小时加一次窗口。我想问(从另一个应用程序)活动聚合窗口的当前计数是多少。注意，活动窗口仍在处理中。这个是可能的吗？如果是的话，怎么做？
浏览 0提问于2018-12-09得票数 0
Spark有mapPartition API，而Flink DataStream API没有。有谁能帮助解释原因吗？我想要做的是在Flink上实现一个类似于星火reduceByKey的API。
浏览 2提问于2015-10-28得票数 7
回答已采纳
关键的好处是它将减少网络和CPU和内存命中的windowAll()，通过在您正在运行的所有节点上分发它。目前，我必须为我的节点分配更多的资源，以适应这种总结。我已经考虑过使用一个随机值作为第二层的密钥，但我认为这会导致数据的完全重新平衡，因此它解决了我的CPU和内存问题，但没有解决网络问题。
浏览 3提问于2017-08-05得票数 3
)}var timeWindow: ClosedRange<Double> { return Double(index) * (1 &
浏览 12提问于2022-08-04得票数 1
我想我需要使用CalendarItemType，但我不确定如何实现它。到目前为止，我的代码如下： { AvailabilityData requestedData = AvailabilityData.FreeBusywrk.EmailAddress));
浏览 0提问于2011-08-03得票数 3
回答已采纳
1回答
= timeWindow; }public final class Location {this.latitude = latitude; }// vehicle.json &
浏览 1提问于2022-03-05得票数 0
回答已采纳
我在Elasticsearch中处理的文档具有表示为开始和结束时间的持续时间的概念，例如 issueId: 1, timeWindow: {14T17:00:00-07:00", }{ issuePriority: 1,
timeWindow因此，对于上面的示例，issue #1将被存储到17:00、17:15、17:30和</em
浏览 3提问于2015-10-15得票数 3
3回答
我想在flink中缓冲一个数据流。我最初的想法是将100条数据缓存到一个列表或元组中，然后使用insert into values (???)将数据批量插入到clickhouse中。你有没有更好的方法呢？
浏览 36提问于2021-09-16得票数 1
(millions of records)我可以有一个TimeExtractor类来获取数据中的EventTime但是如何实现getCurrentWatermark方法。它应该有过去的日期和时间
浏览 3提问于2017-04-11得票数 0
回答已采纳
窗口流使用CountWindow与size=100，slide=1 (滑动计数窗口)。
in .countWindow(Note
浏览 0提问于2018-04-21得票数 0
回答已采纳
我想发送一个信息给卡夫卡主题，何时创建新的SessionWindow和何时结束。现在，我想在新会话启动时发送消息(使用一些元数据，如web浏览器和时间戳，这些信息在流的每个元素中都可用)，并在会话结束时(在本例中，在最后一个元素之后10秒)向Kafka发送包含总请求数的消息。
浏览 0提问于2019-08-08得票数 0
回答已采纳
[StatsPerBin1]([TimeWindow] [datetime] NOT NULL,( CLUSTERED INDEX([Bin1]), ( )只有当没有这样的边界时，我才应该如何拆分分
浏览 6提问于2018-09-14得票数 1
我想弄清楚如何写我自己的WindowFunction，但有问题，但我不知道为什么。我遇到的问题是应用函数，因为它不承认MyWindowFunction是一个有效的输入，所以我无法编译。我正在流的数据包含(timestamp,x,y)，其中x和y为0和1用于测试。extractTupleWithoutTs只是返回一个元组(x,y)。我一直在用简单和运行代码，并成功地减少了函数。new TsExtractor)
val tuple = text.map( str => extractTupleWithoutTs(str)
浏览 0提问于2017-11-07得票数 1
回答已采纳
当你摄入Apache的数据时，我不知道水印到底是如何工作的。 .trigger(new Trigger<String, TimeWindow{
浏览 2提问于2022-01-05得票数 0
回答已采纳
我该如何在Flink中解决这个问题？
浏览 180提问于2019-02-28得票数 2
回答已采纳
但我无法得到关于钥匙和窗口操作的内部信息。setParallelism(2).name("MyPojoMapper").keyBy(new MyKeyExtractor()).name("S3FileSink")在部署Flink作业时，我在Flink UI中得到以下图表，
从上面的图片我完全理解它使用了2个任务和4第一个任务有源，poj
浏览 1提问于2020-05-01得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
