腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
圈层
工具
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何
连接
countWindow
和
timeWindow
?
、
我正在尝试设置一个流,其中首先执行一个
countWindow
。
countWindow
发出的结果需要传递给不同的
timeWindow
。问题是
timeWindow
没有发出任何结果。String] { println("getKey 1") } .
countWindow
String] { override def getKey(value
浏览 24
提问于2019-09-02
得票数 0
回答已采纳
2
回答
在同一数据上Flink多个Windows
、
、
Size=18340663,maxSize=5242880可以应用
TimeWindow
和
CountWindow
的OR函数吗?
浏览 3
提问于2019-01-30
得票数 2
1
回答
添加窗口后没有执行CEP模式
、
、
创建一个由十项组成的窗口 public void apply(Tuple tuple, GlobalWindow
timeWindow
模式是匹配的 我打印了inputStream
和
WindowedStream,我可以看到它们都发送类
浏览 1
提问于2017-01-06
得票数 0
1
回答
Siddhi:状态持久性
和
实时可查询状态?
、
我的场景是这样的.我在上见过这个。假设我有一个查询来统计故障总数,每12小时加一次窗口。我想问(从另一个应用程序)活动聚合窗口的当前计数是多少。注意,活动窗口仍在处理中。这个是可能的吗?如果是的话,怎么做?
浏览 0
提问于2018-12-09
得票数 0
2
回答
Apache API没有mapPartition转换
Spark有mapPartition API,而Flink DataStream API没有。有谁能帮助解释原因吗?我想要做的是在Flink上实现一个类似于星火reduceByKey的API。
浏览 2
提问于2015-10-28
得票数 7
回答已采纳
1
回答
寻找windowAll()的另一种形式,将数据保存在同一节点上进行聚合
、
关键的好处是它将减少网络
和
CPU
和
内存命中的windowAll(),通过在您正在运行的所有节点上分发它。目前,我必须为我的节点分配更多的资源,以适应这种总结。我已经考虑过使用一个随机值作为第二层的密钥,但我认为这会导致数据的完全重新平衡,因此它解决了我的CPU
和
内存问题,但没有解决网络问题。
浏览 3
提问于2017-08-05
得票数 3
1
回答
如何
在iOS 16.0的Swift图表中配置轴线并在线图上设置明确的轴起点
和
终点
、
、
)}var
timeWindow
: ClosedRange<Double> { return Double(index) * (1 &
浏览 12
提问于2022-08-04
得票数 1
1
回答
是否使用exchange web服务获取日历项目所需的与会者?c#
、
、
、
我想我需要使用CalendarItemType,但我不确定
如何
实现它。到目前为止,我的代码如下: { AvailabilityData requestedData = AvailabilityData.FreeBusywrk.EmailAddress));
浏览 0
提问于2011-08-03
得票数 3
回答已采纳
1
回答
仅用于嵌套类的自定义jackson反序列化器
、
、
、
、
=
timeWindow
; }public final class Location {this.latitude = latitude; }// vehicle.json &
浏览 1
提问于2022-03-05
得票数 0
回答已采纳
3
回答
Elasticsearch日期直方图在一段时间内的聚合
我在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中缓冲一批数据
、
、
我想在flink中缓冲一个数据流。我最初的想法是将100条数据缓存到一个列表或元组中,然后使用insert into values (???)将数据批量插入到clickhouse中。你有没有更好的方法呢?
浏览 36
提问于2021-09-16
得票数 1
1
回答
Datastream -过去日期的
TimeWindow
、
、
、
(millions of records)我可以有一个TimeExtractor类来获取数据中的EventTime但是
如何
实现getCurrentWatermark方法。它应该有过去的日期
和
时间
浏览 3
提问于2017-04-11
得票数 0
回答已采纳
2
回答
Apache从另一个流的WindowedStream MapFunction访问内部缓冲区
、
窗口流使用
CountWindow
与size=100,slide=1 (滑动计数窗口)。 in .
countWindow
(Note
浏览 0
提问于2018-04-21
得票数 0
回答已采纳
2
回答
在SessionWindows启动
和
结束时向Kafka发送消息
、
、
我想发送一个信息给卡夫卡主题,何时创建新的SessionWindow
和
何时结束。现在,我想在新会话启动时发送消息(使用一些元数据,如web浏览器
和
时间戳,这些信息在流的每个元素中都可用),并在会话结束时(在本例中,在最后一个元素之后10秒)向Kafka发送包含总请求数的消息。
浏览 0
提问于2019-08-08
得票数 0
回答已采纳
2
回答
如何
仅当SQL数据仓库中不存在分区边界时才添加分区边界?
、
[StatsPerBin1]([
TimeWindow
] [datetime] NOT NULL,( CLUSTERED INDEX([Bin1]), ( )只有当没有这样的边界时,我才应该
如何
拆分分
浏览 6
提问于2018-09-14
得票数 1
1
回答
Flink Scala扩展WindowFunction
、
、
我想弄清楚
如何
写我自己的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
回答已采纳
1
回答
当您摄入Apache的数据时,Apache是
如何
生成水印的?
、
当你摄入Apache的数据时,我不知道水印到底是
如何
工作的。 .trigger(new Trigger<String,
TimeWindow
{
浏览 2
提问于2022-01-05
得票数 0
回答已采纳
1
回答
KTable状态存储无限保留
、
我们有以下高级DSL处理拓扑:KTable<Windowed<K>, Long&g
浏览 3
提问于2017-11-22
得票数 8
回答已采纳
1
回答
Flink:有没有其他方法可以代替RichAggregateFunction来计算平均值
和
状态变量?
、
我该
如何
在Flink中解决这个问题?
浏览 180
提问于2019-02-28
得票数 2
回答已采纳
1
回答
Flink keyby/window操作符任务执行位置
和
内部
、
但我无法得到关于钥匙
和
窗口操作的内部信息。setParallelism(2).name("MyPojoMapper").keyBy(new MyKeyExtractor()).name("S3FileSink")在部署Flink作业时,我在Flink UI中得到以下图表, 从上面的图片我完全理解它使用了2个任务
和
4第一个任务有源,poj
浏览 1
提问于2020-05-01
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
热门
标签
更多标签
云服务器
ICP备案
云直播
对象存储
腾讯会议
活动推荐
运营活动
广告
关闭
领券