当使用全局窗口时，该窗口是从作业启动并收到第一个事件的那一刻开始启动的，还是也从1970年1月1日00:00:00开始，如以下答案所示：flink Windows, when do they start
浏览 47提问于2021-10-20得票数 0
回答已采纳
在哪里/什么时候使用哪一个包？org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction
org.apache.flink.streaming.api.scala.function.ProcessWindowFunction对于窗口操作，就像在org.apache.flink.streaming.api.scala中一样，是正确使用的，但是找不到
浏览 1提问于2019-07-07得票数 0
我有一个键控窗口流处理应用程序(KeyStream.window.process)，窗口是一个15分钟的翻滚窗口。我想知道一个新的窗口处理什么时候开始，这个窗口处理什么时候结束，这样我就可以利用这个机会做一些清理/初始化工作globally。对于每个窗口，在处理开始之前，我想做一些初始化工作，比如截断一个db表(这个操作应该只在一个地方发生，这是一个全局操作，不应该在process方法中完
浏览 14提问于2020-02-21得票数 0
回答已采纳
我开始在Java的ApacheFlink中工作。import org.apache.flink.streaming.api.datastream.DataStream;import or
浏览 17提问于2019-11-08得票数 0
我知道全局状态和每个窗口状态声明的。我想使用全局状态。;import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnviro
浏览 3提问于2020-06-18得票数 0
作为标题，异常发生在键控窗口中，at org.apache.flink.streaming.api.operators.HeapInternalTimerService.getIndexForKeyGro
浏览 2提问于2018-07-17得票数 1
我的程序想在没有Flink窗口的情况下加入两个流。 feaCollector.collect(features);每次开始时:104)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java
浏览 4提问于2019-03-07得票数 0
我刚开始学习Flink中的窗口函数。我有一个定制的源码来产生数字，我的目标是计算偶数和奇数的和。found: org.apache.flink.streaming.api.windowing.assigners.TumblingProcessingTimeWindowsrequired: org.apache.flink.streaming.api.windo
浏览 36提问于2021-03-03得票数 0
我们应该在什么时候使用其中一个呢？ 我注意到带有编号后缀的类有一些更多的功能(例如，分级限制)。https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming
浏览 6提问于2020-09-14得票数 0
目前在阅读flink的文档时，我发现flink中有很多支持，比如翻滚窗口、滑动窗口、会话窗口和自定义窗口的实现谢谢你的点子和建议~
浏览 0提问于2018-11-05得票数 0
org.apache.flink.streaming.api.TimeCharacteristicimport org.apache.flink.streaming.api.wind
浏览 26提问于2020-06-26得票数 0
回答已采纳
对于KeyedStream#timeWindow#process，我想知道一个窗口实例是否只包含相同的键，不同的键是否使用不同的窗口实例。从以下应用程序的输出中，我看到一个窗口实例将只包含相同的键，不同的键将使用不同的窗口。
但我想问一下并确认，谢谢！import org.apache.flink.streaming.api.functions.source.import org.apache.flink.streaming.api.scala.fun
浏览 1提问于2019-09-14得票数 0
回答已采纳
2回答
更具体地说，我正在尝试使用Flink在滑动窗口中实现计数和groupBy功能。 我在一个普通的DateStream中做过，但是我不能让它在WindowedStream中工作。evidence$28: org.apache.flink.api.common.typeinfo.TypeInformation[R])org.apache.flink.streaming.api.scala.DataStream[R] <and>
[R](function: org.apache.flink
浏览 18提问于2019-05-02得票数 1
我试图在flink中实现窗口触发器，如果平均值高于阈值，就会触发窗口触发器。import org.apache.flink.streaming.api.scala._
import org.apache.flink.streaming.api.windowing.assigners.GlobalWindowsimpo
浏览 4提问于2017-03-13得票数 1
回答已采纳
我不得不为窗口的()方法编写自定义逻辑。, org.apache.flink.streaming.api.windowing.windows.TimeWindow, Iterable[(Int, String, Int)], org.apache.flink.util.Collector[R]) => Unit)(implicit evidence$6: org.apache.flink.api.common.typeinfo.TypeInformation[R])org.apache.fl
浏览 2提问于2016-04-28得票数 3
回答已采纳
我正在构建一个具有以下目标的Flink应用程序：
import org.apache.flink.streaming.api.datastream.DataStre
浏览 1提问于2019-08-29得票数 1
回答已采纳
1回答
我试图在Flink的DataStream上应用每个窗口的功能。以下是我的代码
DataStream<Tuple2<String, String>> data = ...<R>process(org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction<org.apache.flink.api.java.tuple.Tuple2<java.lang.String,java.la
浏览 1提问于2018-10-01得票数 2
回答已采纳
2回答
问题是如何在多租户系统中处理这个缓存；flink是否有分布式缓存的概念，还是包含某种智能负载均衡器，其中事件被定向到网格中的同一个分区？(即从特定的时间点开始，其中事件流为不完整的会话(即在时间点之前的事件))。提前感谢
浏览 4提问于2015-10-31得票数 3
我手动使用了变量cnt来只保留第一个窗口，并过滤了剩余的值，如下面的代码所示。 然后，我想使用这个值来过滤主流，以便获得比我在窗口流中计算的stat值更大的值。;import org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator;
import org.apache.flin
浏览 10提问于2019-02-12得票数 0
回答已采纳
我修改了Flink的基本wordcount示例，并使用窗口函数进行了播放。keyBy(t => "all")这是我对窗口函数的暗示1.3.2，这是我的进口品：import org.apache.flink.streaming.api.functions.windowing.Windo
浏览 3提问于2017-11-24得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
