我尝试在Flink Java中创建一个每行2行的翻滚时间窗口。这必须基于dateTime (TimeStamp3数据类型)或unixDateTime(BIGINT数据类型)列。当我打印Table对象的数据类型时，我看到以下内容：|-- mID: INT |-- dateTime: TIMESTAMP(3) *ROWTIME* |-- mValue: DOUBLE |--tableEnv.toAppendStream(HTable, tupleTy
浏览 43提问于2019-10-21得票数 0
我对Apache Flink和它的API.I非常陌生。我想创建Java程序，它将与翻滚窗口进行基于事件时间的处理。我想计算给定窗口中元素的数量。然而，我不知道该怎么做。
浏览 24提问于2019-12-08得票数 0
我有以下简单的代码，执行基于处理时间的翻滚窗口，与表api，但异常抛出时，我运行它。我不知道它在说什么，有人能帮我看看吗?谢谢！._ at org.apache.flink.table.expressions.ApiExpressionUtils.lambda$toMilliInterval$6(ApiExpressionUtils.java:315)
浏览 85提问于2021-01-05得票数 0
回答已采纳
我的问题是，这个状态存储不是在翻滚的窗口中保存的，也就是说，如果我首先在窗口0,999中存储一些东西，然后从window 1000,1999访问这个存储，那么这个存储是空的。我还尝试创建一个最低限度的工作示例来调查这一点：import org.apache.flink.api.common.state.MapSta
浏览 3提问于2020-06-18得票数 0
我不得不为窗口的()方法编写自定义逻辑。基本上，我希望减少窗口中的所有元素，然后将时间戳附加到该值，因此我从一个WindowedStream创建了一个DataStream，但是当我试图为apply()定义函数时，它会在编译时失败。())[ERROR] [R](preAggregator: ((Int, String, Int), (Int, String, Int)) => (Int, String, Int), windo
浏览 2提问于2016-04-28得票数 3
回答已采纳
目前在阅读flink的文档时，我发现flink中有很多支持，比如翻滚窗口、滑动窗口、会话窗口和自定义窗口的实现谢谢你的点子和建议~
浏览 0提问于2018-11-05得票数 0
使用DataStream函数创建fromElements函数时出错
由: java.io.IOException:未能从源反序列化元素引起。如果正在使用用户定义的序列化(Value和Writable类型)，请检查序列化函数.序列化程序是org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer@599fcdda at org.apache.flink.st
浏览 7提问于2015-12-20得票数 1
我是Flink流媒体的初学者。代码在下面。但是，当我将这些值一个一个地放入行的字段中时，会引发一个null异常，因为字段为null。at org.apache.flink.types.Ro
浏览 23提问于2022-01-06得票数 0
我在Apache Flink中关于多个流的迭代的问题。例如，查询每隔5分钟(翻滚窗口)计算一次传递闭包。在迭代期间，inputStream应该是“持有”的，并为我的outputStream提供数据。
在Flink中可以做到这一点吗？谢谢你的帮助！
浏览 9提问于2018-02-13得票数 0
回答已采纳
当窗口中有5个事件时，我使用自定义触发器来触发。这对于TumblingEventTimeWindow和SlidingTimeWindow都很有效，因为它们都有固定的窗口开始和结束。但该逻辑不适用于会话窗口，因为每个事件都会导致创建一个窗口，然后再进行合并。我使用reducing状态来计算事件数。 required: org.<em
浏览 1提问于2018-03-29得票数 1
当多个表中至少有一个表具有时间属性列时，我在使用Flink中的SQL语法连接多个表时遇到了一些问题。我有一个表Table1，它使用模式(id，value1，rowtime)，当rowtime用作flink rowtime时。只使用SQL语法就可以做到这一点吗？(HepPlanner.
浏览 9提问于2019-11-12得票数 0
我用翻滚窗口和QueryableState实现了Total示例。我使用了10秒时间窗口，当我打印结果时，它会显示正确的结果，但是当我使用queryable状态并使用QueryableClient进行查询时，即使时间窗口发生变化，它也会缓存时间窗口的最后一个结果。例如，“Nirav”的字数为时间窗口11:00:01至11:00:10为5
当我在时间上查询'Nirav‘时，11:00:50，然
浏览 0提问于2018-03-23得票数 1
回答已采纳
我的flink作业有keyBy操作符，它以date~clientId(日期为yyyymmddhhMM，MM为分钟，5分钟后更改)为关键字。此操作符之后是5分钟的翻滚窗口。下面是我的疑虑：
3)窗口大小对检查点时间的影响。
4)在任何5分钟内不同客户的数量增加5-10倍的场景中，会有什么影响。这会造成数据失真吗？因为在我的工作中，1-2个子任务总是需要大约1-2分钟，而其他800个子任务只需要10
浏览 1提问于2020-03-12得票数 0
我正在构建一个具有以下目标的Flink应用程序：
package io.github.streamingwithflink.jv
import jav
浏览 1提问于2019-08-29得票数 1
回答已采纳
1回答
我在使用Maven时遇到了问题。我有一个Apache项目，希望在我的服务器上运行它。在本地，它运行良好，但在服务器上，它因错误而中止：
java.lang.NoClassDefFoundError: org/apache/flink/examples/java/ml/util/LinearRegressionData在我的Java
浏览 0提问于2015-07-27得票数 4
回答已采纳
我正在尝试用flink实现一个基于事件时间特征计算的翻滚窗口。import org.apache.flink.api.common.typeinfo.Types;
import org.apach
浏览 0提问于2021-09-27得票数 0
我开始在Java的ApacheFlink中工作。import org.apache.flink.api.common.serialization.SimpleSt
浏览 17提问于2019-11-08得票数 0
3回答
使用$SPARK_HOME/jars中的本地jar文件，它正确运行，但使用maven依赖于它的错误：以下是代码：import org.apache.spark.api.java.JavaRDD;import org.apach
浏览 19提问于2017-11-28得票数 0
回答已采纳
我在Apache中有两个DataStreams来自Flink训练 .apply {(r, f) => (r,f)}
哪种类型的窗口使用
浏览 3提问于2021-05-19得票数 0
1回答
我一直在努力建立一个flink应用程序，该应用程序可以从csv文件创建一个Datastream<Tuple3<Integer, java.sql.Time, Double>>。该文件中的列(列ID, dateTime and Result)都是字符串，但它们应该转换为Integer、java.sql.Time和Double。我想要的另一件事是每天使用数据创建翻滚的窗口，并平均该窗口中的resu
浏览 4提问于2019-10-14得票数 0
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
