腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Python
API
是否
支持
DataStream
和
表
之间
的
转换
apache-flink
、
pyflink
在最新
的
稳定版本V1.13.2中,
Python
API
是否
支持
DataStream
和
Table
之间
的
转换
?
浏览 16
提问于2021-09-28
得票数 0
1
回答
Flink :
DataStream
到
表
apache-kafka
、
apache-flink
、
flink-streaming
、
flink-sql
Usecase:从Kafka读取protobuf消息,反序列化它们,应用一些
转换
(平放一些列),然后写到dynamodb。问题:--如果我可以用
datastream
对象创建一个
表
,那么我就可以接受在该
表
上运行
的
查询。这将使
转换
部分无缝
和
通用。可以在
datas
浏览 3
提问于2020-04-28
得票数 2
回答已采纳
3
回答
Apache :如何为动态
表
启用“向上插入模式”?
apache-flink
、
flink-streaming
、
flink-sql
在Flink文档
和
官方Flink博客中,我看到了几次提到动态
表
的
“向上插入模式”
的
情况。但是,我没有看到任何关于如何在动态
表
上启用此模式
的
示例/文档。示例: 当通过update模式在流上定义动态
表
时,我们可以在
表
上指定一个唯一
的
键属性。在这种情况下,对key属性执行更新和删除操作。更新模式如下图所示。:
转换
为上插入流
的
动态
表
需要(可能是复合
的
)
浏览 3
提问于2018-02-01
得票数 5
回答已采纳
1
回答
从Flink中
的
进程函数访问
表
API
java
、
apache-flink
、
flink-streaming
我是新来
的
弗林克,我正在努力学习。在聚合了一些行之后,我尝试在流程函数中使用Table,这样我就可以根据特定
的
标准进行操作和插入。目标是处理带有table_name
的
元组
和
要插入
的
行列表。这是一个可以接受
的
模式吗?
浏览 2
提问于2022-01-24
得票数 0
1
回答
为什么Flink流不
支持
左联接表达式?
flink-streaming
Flink流
支持
内部连接表达式,如window- join,interval-join.但不
支持
左联接/完全联接表达式。当然,窗口-cogroup表达式可以实现相同
的
语义,即使事件立即加入,也必须等待完全窗口大小
的
时间。我
的
问题是: 如何从设计角度解释Flink流不
支持
左连接/完全连接表示?如何通过Flink
DataStream
API
(如果能够立即转发连接事件)来实现它?
是否
有一种方法可以扩展Flink <e
浏览 3
提问于2021-08-15
得票数 0
回答已采纳
2
回答
Scala选项类型在apache
表
api
中不被识别
scala
、
apache-flink
、
flink-streaming
、
flink-sql
、
iceberg
我正在构建一个flink应用程序,它从kafka主题读取数据,应用一些
转换
并写入Iceberg
表
。对
datastream
的
所有
转换
都工作得很好。但是,当我试图将流
转换
为
表
以写入冰山
表
时,由于案例类,列将
转换
为Raw类型,如下所示。Sink schema: [app_name: STRING, .......
浏览 17
提问于2022-02-20
得票数 1
回答已采纳
1
回答
Flink -如何将数据集写入orc文件?
apache-flink
、
flink-streaming
、
flink-batch
是否
存在将Dataset对象写入ORC文件
的
问题?我知道Dataset对象可以使用AvroOutputFormat编写为avro文件,但似乎没有与orc等效
的
类吗?如果无法做到这一点,
是否
有任何方法将数据集
转换
为
表
或
DataStream
?Dat
浏览 4
提问于2022-10-25
得票数 0
2
回答
Flink
表
API
无法将DataSet
转换
为
DataStream
java
、
apache-flink
、
flink-streaming
、
flink-cep
我使用
的
是使用Java
的
Flink
表
API
,其中我想将DataSet
转换
为
DataStream
.以下是我
的
代码:DataSet<MyClass>ds2=tableEnvironment.toDataSet(tab1, MyClass.class);
Data
浏览 4
提问于2016-05-13
得票数 4
1
回答
如何在最新
的
flink1.14或flink1.15
表
/sql中使用dataset
api
(如dataset.output(outputFormat) )
dataset
、
apache-flink
、
flink-sql
、
outputformat
我得到了一个使用dataset
api
的
项目,比如dataset.output(outputFormat)。outputFormat是userDefined(向neo4j写入批处理数据),因此我希望保留它,但在flink use OutputFormat中找不到最新版本
的
表
/sql。谢谢你
的
帮助。
浏览 38
提问于2022-09-08
得票数 0
回答已采纳
1
回答
Flink从Hadoop读取数据并发布到Kafka
apache-flink
、
flink-streaming
、
flink-batch
因为它们是DataSet
和
DataStream
API
的
一部分,所以可以在一个工作中完成我想要做
的
事情吗?
浏览 34
提问于2020-04-29
得票数 0
回答已采纳
1
回答
Flink:在
DataStream
API
的
批处理模式下,左连接等价于Dataset
API
?
apache-flink
、
flink-streaming
、
flink-batch
Flink文档中提到了在未来
的
发展。因此,我正在研究Dataset
API
到 中
的
DataStream
API
(我认为现在在Beta中)迁移
的
原型。我们
的
代码库中有(类似的)代码,它在leftOuterJoin上使用DataSet。由于他们正在考虑完全反对DataSet
API
,所以我假设现在应该有一种方法来实现
DataStream
API
中
的
左外部连接。 有人能以正确
的
方式引导
浏览 5
提问于2021-09-29
得票数 0
回答已采纳
1
回答
Apache Flink中
DataStream
与Table
API
的
区别
apache-flink
、
flink-streaming
、
flink-sql
我是Apache Flink
的
新手,我想了解
DataStream
和
Table
API
之间
的
用例。请您帮我了解一下,什么时候选择Table接口而不是
DataStream
接口。据我所知,用Table
API
可以做
的
事情,也可以用
DataStream
API
来做。这两个
API
有什么不同?
浏览 14
提问于2018-08-01
得票数 2
回答已采纳
1
回答
有没有一种方法可以将批量数据移动到数据流中?
apache-flink
我正在查看Table-
API
。能否将批处理数据集
转换
为
表
,然后使用todatastream函数
转换
为数据流?我知道前段时间也有类似的问题,答案
是否
定
的
。在重写Table
API
之后,这种情况发生了变化吗?
浏览 2
提问于2018-08-14
得票数 0
1
回答
Flink:执行计划中
的
表
API
复制运算符
scala
、
apache-flink
我使用Flink 1.2.0 Table
API
来处理一些流数据。
DataStream
_Operators -> TableA_Operators -> TableA_Sink |-> Copy_of_TableA_Ope
浏览 0
提问于2017-05-26
得票数 0
1
回答
在Flink中
的
范式
之间
移动数据
apache-flink
我在一个关系数据库中有一些批处理
的
数据,我想使用Flink将它们推送到消息总线上。由于Flink同时
支持
批处理
和
流模式,因此它看起来非常适合。此任务
是否
更适合FlinkSQL环境? 这个是可能
的
吗?我需要注意什么?
浏览 25
提问于2021-04-28
得票数 0
回答已采纳
1
回答
Flink
表
左边
的
外部联接显示一个错误
apache-flink
、
flink-streaming
、
flink-table-api
我正在对flink中
的
两个
表
执行一个左外部联接,下面给出了代码,显示了一个异常,使用相同两个
表
的
内部连接工作良好,能够
转换
为
Datastream
。contact_custcode")))例外情况是: org.apache.flink.table.
api
.TableException:
表
接收器
浏览 8
提问于2022-08-11
得票数 0
2
回答
在Java Flink作业中使用
Python
用户定义函数
java
、
python
、
apache-flink
、
flink-cep
、
pyflink
有没有办法在Java Flink Job中使用
python
用户定义函数,或者用
python
用户定义函数与java通信,例如flink完成
的
转换
结果,以应用一些机器学习
的
东西: 我知道在pyFlink中你可以这样做table_env.register_java_function("hash_code", "my.java.function.HashCode") 但是我需要做一些类似的事情,但是添加来自java
的
python
函数,或者
浏览 91
提问于2020-07-04
得票数 3
1
回答
如何在使用
表
API
时将java LocalDateTime映射到Flink时间戳
java
、
apache-flink
、
flink-sql
、
flink-table-api
我
的
代码就像:tableEnv.createTemporaryView("input_tablereturns(rti);新代码工作正常,但在我看来有点扭曲,因为我必须添加一个基本不做任何事情
的
映射因此,我
的
问题是,将java LocalDateTime映射到flin
浏览 3
提问于2021-08-02
得票数 0
回答已采纳
3
回答
如何处理Flink
的
Table
API
窗口中
的
延迟元素?
scala
、
apache-flink
在使用Flink 1.55及其
表
API
的
流式应用程序中,我需要检测
和
处理延迟元素。我找不到替代
DataStream
应用编程接口.sideOutputLateData(...)
的
功能。我试着在Flink文档、https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/table/tableApi.html
和
谷歌中搜索了很多次,
浏览 36
提问于2019-06-19
得票数 2
2
回答
Flink错误: java.lang.NoSuchMethodError: org.apache.flink.
api
.table.Table
java
、
apache-flink
、
flink-streaming
我尝试使用flink
的
表
和
sql作为一个简单
的
示例,在这个示例中,我从文件中读取字符串,将其
转换
为Tuple2,并尝试将其插入
表
中。这是我
的
密码。;import org.apache.flink.
api
.table.Table; import org.apache.flink.streaming.
api
.TimeChara
浏览 1
提问于2016-12-21
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
官宣:Apache Flink 1.14.0 发布
flink handbook-flink数据流编程模型
Flink概念:编程模型上
Flink:动态表上的连续查询
《从0到1学习Flink》——Apache Flink 介绍
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券