任何人都知道如何使用时间偏移量翻滚窗口-窗口大小是一天，时间偏移量是基于时区的小时。})
浏览 15提问于2019-11-18得票数 0
回答已采纳
1回答
我使用的是Flink 1.12。我想读取csv，并根据处理时间进行翻滚窗口分组。代码如下，但是查询sql_tubmle_window没有输出，我想知道问题出在哪里 import org.apache.flink.streaming.api.scala._import org.
浏览 5提问于2021-05-02得票数 0
回答已采纳
我希望在给定的键和公共窗口上加入三个或多个数据流或表。但是，我不知道如何正确地编写代码。正式文档给出了下面的示例，但是它只是连接两个数据流，那么如何在给定的键和公共窗口上连接三个或多个数据流？==================
对于FlinK表API和SQL，如何在给定的键和公共窗口上连接三个或多个表？正式文档只给出了下面单个表的示例。
浏览 1提问于2018-06-13得票数 2
当多个表中至少有一个表具有时间属性列时，我在使用Flink中的SQL语法连接多个表时遇到了一些问题。我有一个表Table1，它使用模式(id，value1，rowtime)，当rowtime用作flink rowtime时。
我想把这个表和一个使用模式(id，value2)的表Table2连接起来。最后，我想使用翻滚时间
浏览 9提问于2019-11-12得票数 0
我正在尝试用flink实现一个基于事件时间特征计算的翻滚窗口。import org.apache.flink.api.common.typeinfo.Types;
import org.apache.flink.ap
浏览 0提问于2021-09-27得票数 0
我用翻滚窗口和QueryableState实现了Total示例。我使用了10秒时间窗口，当我打印结果时，它会显示正确的结果，但是当我使用queryable状态并使用QueryableClient进行查询时，即使时间窗口发生变化，它也会缓存时间窗口的最后一个结果。例如，“Nirav”的字数为时间窗口11:00:01至11:00:10为5
当我在<e
浏览 0提问于2018-03-23得票数 1
回答已采纳
介绍了如何使用Flink对无序流进行排序，但我更愿意使用DataStream API。将使用一个使用PriorityQueue来缓冲事件的ProcessFunction来实现这一点，直到水印表明它们不再是无序的，但是在RocksDB状态后端(问题是每次对PriorityQueue的访问都需要整个无论使用的是哪种状态后端，我如何有效地做到这一点？
浏览 2提问于2019-12-24得票数 5
我试图对包含Flink中40多个属性的数据流执行加窗聚合查询。流的模式包含一个划时代的时间戳，我想将它用于WatermarkStrategy，这样我就可以在它上面定义翻滚的窗口。我从中了解到，您可以使用CREATE TABLE-query中的SQL定义时间戳，方法是首先在各时期使用TO_TIMESTAMP_LTZ将其转换为适当的时间戳，该时间戳可在下面的WATERMARK FOR-statement这意味着，我必须<
浏览 29提问于2022-08-09得票数 0
正如文档强烈推荐的那样，我想将uids添加到Flink中的运算符中，以实现保存操作的目的。我的工作使用Table API。我在文档中没有找到如何使用SQL查询将uids添加到运算符。GROUP BY TUMBLE(col1, INTERVAL '10' SECOND));如果我的理解是正确的，那么翻滚窗口就是内部操作员状态我正在运行Fl
浏览 0提问于2019-04-02得票数 1
我想使用一个长类型的列来翻滚。我使用UDF传输长类型到时间戳类型，但是无法工作错误消息:窗口只能在时间属性列上定义。 return null; }错误堆栈
Exception in thread "main" org.apache.<em
浏览 0提问于2019-11-27得票数 2
回答已采纳
我正在使用Flink 1.12并且我有一个键控流，在我的代码中看起来A和B共享相同的水印？import org.apache.flink.streaming.api.functions.AssignerWithPunctuatedWatermarks
import org.apache.flink.streaming.api.scala.function.WindowFunctionimport org.apache.flin
浏览 12提问于2021-05-02得票数 0
回答已采纳
我的目标是在一分钟的时间窗口中使用一个ApacheKafka主题，这将应用非常基本的信息，并将每个窗口的结果记录在一个文件中。到目前为止，我成功地将文本转换简化应用于我接收的内容，我应该使用apply或process来写入文件，但窗口的结果我有点迷失。java.util.Date;import org.apache.flink.api.java.tuple.
浏览 17提问于2019-11-08得票数 0
在使用更大的生产数据集之前，我想了解如何使用Flink API在玩具数据集上实现这一点。有关表连接的文档显示了如何连接两个表并取回另一个表，这不是我想要的： https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/tableApi.ht
浏览 66提问于2021-04-25得票数 0
回答已采纳
我正在使用flink 1.12.0。试图将数据流转换为表A，并在tableA上运行sql查询，以便按下面的方式通过窗口进行聚合，我使用f2列作为时间戳数据类型字段。kafka test");当我执行上述代码时，我得到
线程“主”org.apache.flink.table.api.TableException中的异常:窗口聚合只能在时间属性列上定义，但是遇到
浏览 5提问于2021-02-15得票数 0
回答已采纳
1回答
，我只使用每个Id2的最新记录。at org.apache.flink.table.api.TableEnvironment.runVolcanoPlanner(TableEnvironment.scala:387) at org.apache.flink.table.<em
浏览 0提问于2019-08-26得票数 0
回答已采纳
我在1.1快照版本上使用Apache的Table来评估流上的SQL查询。at org.apache.flink.api.table.TableEnvironment$$anonfun$4.apply(TableEnvironment.scala:299) at
浏览 1提问于2016-06-15得票数 0
回答已采纳
最近，我尝试使用Apache进行快速批处理。我有一个有一个列:value和一个无关索引列的表我必须加上时间戳才能做到这一点吗？是否有必要进行批处理，是否会减慢计算速度？解决这个问题的最好方法是什么？更新: --我尝试在表
浏览 2提问于2018-06-20得票数 2
我想知道一般对查询和表使用了多少状态。首先，我使用Flink SQL处理来自Kafka主题的消息： country STRING,) WITH (, product, count(*) as `purchases` from purchases group by country, product))来自Flink状态管理的是这样说的：
从概念上讲，源
浏览 8提问于2021-12-11得票数 0
回答已采纳
第一个是基于时间的流，我使用countTimeWindow接收前10个数据点来计算STAT值。我手动使用了变量cnt来只保留第一个窗口，并过滤了剩余的值，如下面的代码所示。然后，我想使用这个值来过滤主流，以便获得比我在窗口流中计算的stat值更大的值。 然而，我不知道如何合并或计算这两个流来实现我的目标。;
import org.apache.flink.api.common.functions.M
浏览 10提问于2019-02-12得票数 0
回答已采纳
2回答
我正在研究Apache流，以便在我们的ETL和机器学习平台中使用。我还没有弄明白的是如何将事件流成“会话”。更描述性:所有事件都包含一个会话id，为了丰富数据，我需要将属于会话的所有事件分组在一起。然后，在每个会话不活动X分钟之后，就可以“关闭”或将会话从缓存中驱逐出去。问题是如何在多租户系统中处理这个缓存；flink是否有分布式缓存的概念，还是包含某种智能负载均衡器，其中事件被定向到网格中的同一个分区？更广泛地说:使用流api建立会话支持的最佳方法(用例和陷阱)是什么？这有可能吗？如何
浏览 4提问于2015-10-31得票数 3
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
