腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(62)
视频
沙龙
2
回答
为什么不能通过调用addColumns添加获取时间?
、
、
tableEnv.
fromDataStream
(xxxStream).addColumns('processTime.proctime)org.apache.flink.table.api.ValidationException但这会奏效的但我必须用这种方式重复所有的列。
浏览 4
提问于2020-03-13
得票数 2
2
回答
如何用flink用kotlin写$(“user”)
、
在flink 1.14中,它建议使用$()检索如下所示的元素:那么是否有一种方法可以将其转换为kotlin,因为它会导致kotlin中的编译器错误: var table = tableEnv.
fromDataStream
(ds, $("user
浏览 5
提问于2022-02-16
得票数 1
1
回答
如何使用一个流和两个静态配置单元表进行连接
我是Flink的新手,我使用的是Flink 1.3(旧版本,但我的公司已经使用了这个版本...)来编写流应用程序。这个应用程序涉及连接一个流(来自kafka)和两个静态Hive表(每天更改一次,两个表大约有1亿行),此时,我想知道应该使用哪种api (数据流api或流sql api)。
浏览 0
提问于2019-09-23
得票数 0
1
回答
如何将DataStream[Row]转换为表格?
对于这种情况,java环境支持使用returns()方法来指定类型信息。但是int scala环境,org.apache.flink.streaming.api.scala.DataStream没有return()。如何将scala DataStreamRow转换为scala Table?
浏览 26
提问于2019-11-22
得票数 0
2
回答
Flink表异常:只能在时间属性列上定义窗口聚合,但遇到时间戳(6)
、
、
、
DataStreamSource<Avrotest> stream = Table tableA = tEnv.
fromDataStream
浏览 5
提问于2021-02-15
得票数 0
回答已采纳
1
回答
比较Flink中的两个数据流以检索丢失的数据
、
、
、
Table t1 = streamTableEnvironment.
fromDataStream
(dataStream1,$("a"),$("atime").proctime());我需要在5秒内得到T1中没有在
浏览 3
提问于2021-03-08
得票数 1
回答已采纳
1
回答
如何使用Flink时态表?
WHERE m.siteId = s.id// { "streamName": "sitemembership", "key": "siteId" } // { "streamName": "site", "key": "
浏览 0
提问于2019-01-30
得票数 2
回答已采纳
1
回答
Flink嵌套类toDataStream转换错误
、
、
StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env); tableEnv.
fromDataStream
浏览 7
提问于2021-05-14
得票数 1
1
回答
数据端口-1在flink web UI中的意义是什么?
senv.fromElements(1, 2, 3, 4)val streamTable = stenv.
fromDataStream
浏览 1
提问于2020-06-10
得票数 1
回答已采纳
1
回答
即使在apache中实现AppendTableStream接口之后,也会出现错误
、
、
StreamTableEnvironment StreamTableEnv = TableEnvironment.getTableEnvironment(env); "member_id"); StreamTableEnv.registerTable("emp1",
fromDataStream
);
浏览 1
提问于2017-08-24
得票数 0
1
回答
在Apache Flink Java中创建翻滚窗口时出错
、
Table table = tableEnv.
fromDataStream
(dsTuple, "mID, dateTime.rowtime, mValue, unixDateTime, mType");Table table = tableEnv.
fromDataStream
(dsTuple, "mID, dateTime.rowtime, measurementValue, unixDateTime
浏览 43
提问于2019-10-21
得票数 0
1
回答
与表api一起使用行时的NullPointerException
= t.birthday.getTime val tenv = StreamTableEnvironment.create(env) val table = tenv.
fromDataStream
浏览 2
提问于2020-12-25
得票数 0
回答已采纳
1
回答
Apache 1.52行时间戳为空
、
我正在对以下代码进行一些查询: DataStream<Row> ds = SourceHelp.builder().env(env).consumer010(MyKafka.builder().build().kafkaWithWaterMark2()) .build().source4()
浏览 1
提问于2018-09-17
得票数 1
1
回答
org.apache.flink.table.api.TableException:不支持的查询:合并到
、
、
Table table = tableEnv.
fromDataStream
(KafkaStreamTableDataStreamStream); tableEnv.createTemporaryView
浏览 5
提问于2022-08-31
得票数 0
回答已采纳
1
回答
Flink TableAPI中的异常
、
、
org.apache.flink.table.api.StreamTableEnvironment.registerDataStreamInternal(StreamTableEnvironment.scala:546) new WC("Hello",1L)); Table t1 = streamTableE
浏览 0
提问于2020-09-01
得票数 0
1
回答
Flink+Kafka 0.10:如何创建一个以卡夫卡消息时间戳为字段的表?
、
assignTimestampsAndWatermarks(new KafkaAssigner[String]) at org.apache.flink.table.api.scala.StreamTable
浏览 1
提问于2017-10-28
得票数 1
回答已采纳
1
回答
在Flink SQL窗口中使用具有延迟的事件时间
、
、
new BoundedOutOfOrdernessTimestampExtractor<>(Time.seconds(30))); Table table = bsTableEnv.
fromDataStream
浏览 47
提问于2020-02-14
得票数 1
2
回答
Flink -将Avro数据转换为表
、
、
、
.; Table table = tableEnv.
fromDataStream
浏览 0
提问于2020-12-29
得票数 2
1
回答
如何在Apache Flink的StreamTableEnvironment中实现timeWindow()?
、
、
、
、
stream.keyBy("x").timeWindow(Time.seconds(5), Time.seconds(5)) val tableA = tableEnv.
fromDataStream
浏览 24
提问于2020-05-15
得票数 0
2
回答
Flink窗口聚合方法在时间戳上的失败
、
、
、
我们数据库里有一张表A。我们使用flink SQL JdbcCatalog将该表加载到Flink中。val catalog = new JdbcCatalog("my_catalog", "database_name", username, password, url)val query
浏览 79
提问于2022-11-22
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
实时计算框架 Flink 在教育行业的应用实践
热门
标签
更多标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频
活动推荐
运营活动
广告
关闭
领券