腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
Apache作业
中
的
多
流
支持
frameworks
、
apache-flink
、
apache-nifi
、
flink-streaming
我
的
问题是关于Apache框架。我目前工作在星火
流
,这是限制在那里。 通过其他
流
框架(
如
Apache、Storm或NIFI )可以实现这一点吗?人们期待着人们
的
回应。
浏览 5
提问于2016-11-06
得票数 5
回答已采纳
1
回答
为什么
Flink
流
不支持左联接表达式?
flink-streaming
Flink
流
支持内部
连接
表达式,
如
window- join,interval-join.但不支持左联接/完全联接表达式。当然,窗口-cogroup表达式可以实现相同
的
语义,即使事件立即加入,也必须等待完全窗口大小
的
时间。我
的
问题是: 如何从设计角度解释
Flink
流
不支持左
连接
/完全
连接
表示?如何通过
Flink
DataStream API (如果能够立即转发<e
浏览 3
提问于2021-08-15
得票数 0
回答已采纳
1
回答
Flink
的
窗口操作是处理窗口末尾
的
元素,还是做滚动处理?
apache-flink
、
flink-streaming
我有一些困难,了解窗口是如
何在
内部实现
Flink
,并没有找到任何文章,以解释这一点
的
深入。在我看来,有两种方法可以做到。.window(Time.of(500, TimeUnit.SECONDS)).sum(1) 方法1:将所有事件存储500秒,在窗口
的
末尾,通过对存储
的
事件应用和操作来处理所有事件。方法2:我们使用一个计数器来存储每个窗口
的
滚动金额。当窗口中
的
每个事件出现时,我们不会存储单个事件,而是继续将1添加到以前存储
的
计数器
中
浏览 6
提问于2022-01-17
得票数 0
回答已采纳
2
回答
如
何在
Flink
中
连接
2个
以上
的
流
?
apache-flink
、
flink-streaming
我有3个不同类型
的
键控数据
流
。DataStream<A> first;DataStream<C> third; 每个
流
都定义了自己
的
处理逻辑,并在它们之间共享一个状态。我想
连接
这3个
流
,当数据在任何
流
中
可用时,触发相应
的
处理功能。在两个流上
连接
是可能
的
。first.connect(second).process(<
浏览 57
提问于2020-10-31
得票数 5
回答已采纳
1
回答
如何通过datastrem或
Flink
/SQL在给定
的
键和公共窗口上
连接
三个或多个数据存储区/tables?
apache-flink
、
flink-streaming
、
flink-sql
我希望在给定
的
键和公共窗口上加入三个或多个数据
流
或表。但是,我不知道如何正确地编写代码。正式文档给出了下面的示例,但是它只是
连接
两个数据
流
,那么如
何在
给定
的
键和公共窗口上
连接
三个或多个数据
流
?.}); 我尝试用公共窗口
连接
两个数据
流
,并利用结果数据
流
将第三个数据
流
与公共窗口
连接
起来。然而,当我们将TimeCharacteristic设置为事件时,这三种数据
浏览 1
提问于2018-06-13
得票数 2
1
回答
如何组织复杂
的
Apache应用程序?
apache-flink
、
flink-streaming
、
flink-sql
我们使用
flink
从一些IoT传感器生成事件。每个传感器都可以用来产生不同类型
的
事件(
如
温度、湿度等)。一对多
的
比率(传感器->启用事件)。存储在关系数据库
中
的
传感器和启用事件之间
的
映射 为了丰富传感器数据,我们将传感器数据和表API
连接
起来。只需添加带有启用事件列表
的
元数据。因此,如果某些特定
的
sensor-123只启用了TEMP和PRESSURE事件,如何仅将传感器数据发送到这两个已定义
的
浏览 4
提问于2022-01-25
得票数 1
1
回答
如
何在
执行表
连接
时获得最后
的
结果(在
flink
sql中使用toRetractStream
apache-flink
、
flink-streaming
、
flink-sql
、
flink-table-api
下面是我使用
flink
sql API
连接
两个表
的
代码 tEnv.createTemporaryView("A", streamA,"speed_sum,cnt,window_start_time,window_end_timeRow>> streamResult = tEnv.toRetractStream(table, Row.class).; streamResult.print("streamResult"); 我
的
输出是这样
的
浏览 211
提问于2021-10-27
得票数 1
2
回答
flink
流
与
flink
批处理
中
的
内存管理
apache-flink
、
flink-streaming
我浏览了很多博客和堆栈溢出答案,但我不清楚
Flink
内存管理。在少数博客
中
,我找到了“内存管理器池”和"Rocksdb“。我正在使用rocksdb,并且假设我
的
所有状态都存储在该db
中
。这是我
的
怀疑..。 在
流
中</e
浏览 9
提问于2020-05-01
得票数 1
2
回答
使用
Flink
同步
的
进程2
流
java
、
scala
、
apache-flink
、
flink-streaming
、
amazon-kinesis
我有两个
流
A和B。 我开始同时摄入A和B。
流
A只在每分钟
的
59秒获得一条记录。
流
B获取一分钟内
的
任何一秒
的
记录。 我希望处理两个
流
是同步
的
。示例:从
流
A在10:01:59之后,我将在10:02:59收到一条记录,直到10:02:59我也不想从
流
B读取任何内容。 这可以在
Flink
中
实现吗?
浏览 48
提问于2021-01-21
得票数 0
1
回答
是否有用于Python
Flink
1.13版本
的
?
python
、
apache-flink
、
amazon-kinesis
、
pyflink
、
amazon-kinesis-analytics
我正在尝试用Python
中
的
Flink
1.13版本使用构建一个
流
应用程序。使用使用
Flink
1.13版本
的
连接
有没有其他方法?
浏览 14
提问于2022-09-27
得票数 0
1
回答
如
何在
其他基础上过滤Apache
流
?
apache-flink
、
flink-streaming
我有两个
流
,一个是Int
流
,另一个是json .In,json,有一个键,就是一些int .So,我需要通过键比较来过滤json
流
和其他整数
流
,所以在
Flink
中
可以吗?
浏览 1
提问于2017-04-20
得票数 2
回答已采纳
1
回答
如何将
流
数据保存到Azure数据湖?
azure
、
apache-kafka
、
apache-flink
、
azure-data-lake
我使用Apache进行
流
.I,将Apache
的
数据作为流通过
flink
,并在Azure数据lake.Is
中
拥有并保存最终
的
流
,在
flink
中有可用
的
连接
器在Azure数据湖中转储
流
数据吗?
浏览 2
提问于2017-04-12
得票数 0
回答已采纳
1
回答
Flink
: Rowtime属性不能在常规联接
的
输入行
中
java
、
apache-flink
、
flink-sql
使用
flink
SQL API,我希望将多个表
连接
在一起,并在一段时间内进行一些计算。我有3个来自CSV文件
的
表格,还有一个来自Kafka。在Kafka表
中
,我有一个字段timestampMs,我想将其用于我
的
时间窗口操作。processed.insertInto("MySink"); 但是当我运行它时,我得到了以下错误: Exception in thread "main" org.apache.
flink
.tab
浏览 96
提问于2019-07-24
得票数 2
1
回答
按两列
连接
单个表
flink
表
sql
、
scala
、
join
、
apache-flink
、
flink-sql
我有一个包含数据
的
表,我需要用两个字段
连接
。val table = tableEnv.sqlQuery(query)Exception in thread "main" org.apache.
flink
.table.api.TableException
浏览 1
提问于2018-06-27
得票数 1
回答已采纳
1
回答
流在Hadoop
中
的
应用
hadoop
、
spark-streaming
、
apache-flink
、
flink-streaming
、
flink-cep
我正在尝试学习
的
例子。在这个例子
中
,我确实看到他们创建了一个单独
的
应用程序(类似于
流
应用程序),该应用程序生成和消费数据,并在数据上应用模式匹配。他们现在还没有在.Till(
如
卡夫卡)之间放置一个
流
层,单应用程序就足以满足这一目的,这使得它非常优化。现在,我知道,如果我使用Kafka,那么我需要两个应用程序;一个用于将数据摄取到Kafka主题中,另一个用于消费Kafka主题
的
数据。我有几个问题我没有得到回答: 为什么在这个例子
中
他们没有使用任何<e
浏览 2
提问于2016-06-13
得票数 0
2
回答
Apache与Hadoop上
的
Mapreduce相比如何?
hadoop
、
mapreduce
、
apache-flink
Apache与Hadoop上
的
Mapreduce相比如何?在哪些方面更好,为什么呢?
浏览 9
提问于2015-04-28
得票数 14
回答已采纳
2
回答
Flink
DataStream[String] kafkaconsumer转换为Avro for Sink
apache-flink
、
flink-streaming
FLINK
流
:,我有来自kafkaconsumer
的
DataStreamString,这是JSON .addSource(new FlinkKafkaConsumer[:406)在mapper
中
初始化架构后,获得强制转换异常。AppendWriteException: java.lang.ClassCastException: scala.Tuple2 cannot be cast to java.util.Map 下面是屏幕
中
的<
浏览 16
提问于2020-07-24
得票数 0
2
回答
Apache
Flink
1.4与Apache Kafka 1.0.0
apache-kafka
、
sbt
、
apache-flink
、
flink-streaming
当我试图在我
的
build.sbt文件
中
添加
flink
连接
器-kafka包时,我会看到一个错误,它不能解决它。然后,当我查看maven存储库
中
可用
的
选项时,对于0.10.2
以上
的
任何版本,Apache 2.11-1.0.0都不存在maven依赖关系。% "provided", "org.apache.
flink
" %% "
flink
-streaming-scal
浏览 2
提问于2018-03-03
得票数 2
回答已采纳
1
回答
在
Flink
或任何其他系统
中
合并两种不同类型
的
数据
流
apache-flink
、
flink-streaming
、
complex-event-processing
、
flink-cep
我想用
Flink
进行远程病人监测,包括陀螺仪、加速度计、心电流、心率
流
、RR率等多种传感器。
连接
diff
流
早些时候,我是基于传感器
的
时间戳执行
连接
的
,但它并不会导致所有事件
的
连接
,因为diff
流
可以在微秒内具有不同
的
时间戳,因此很少会出现时间戳完全相等
的
情况。为此,我在
Flink
文档中发现,我可以使用,但是它们应该具
浏览 2
提问于2017-11-14
得票数 1
回答已采纳
1
回答
如何设置作用于多个
流
的
Flink
运算符
apache-flink
、
apache-storm
、
flink-streaming
我正在研究使用
Flink
作为流媒体引擎。我来自apache-storm,据我所知,storm
的
Bolt类似于
Flink
的
任务/操作符。在风暴
中
,一个人可以 builder.setBolt("TEST", new TestBolt(),5) .fie
浏览 32
提问于2021-07-20
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
从Storm到Flink:大数据处理的开源系统及编程模型
什么是 Apache Flink?
Flink CDC 与 Debezium 有何关系?
Flink CDC 的实现原理是什么?
Flink CDC 是什么?
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券