腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何在运行时从
flink
中
的
数据流映射或flatMap执行
sql
查询
apache-flink
、
flink-streaming
、
flink-sql
、
flink-batch
我是
flink
的
新手,想了解如何使用
FLINK
运行我
的
用例:应用程序有三个输入数据源a)历史数据b)从kafka获取所有实时事件c)获取将具有触发条件
的
控制事件 由于应用程序正在处理历史数据,因此我认为我将合并历史数据和实时数据要触发事件,我们必须在控制事件
的
帮助下编写
SQL
查询
,该事件是输入源,并且包含where子句。我
的
问题是在数据位于Stream
中
时构建
SQL
查询
,并且当我执
浏览 37
提问于2020-07-01
得票数 1
2
回答
Apache
中
的
top-n
查询
使用了多少状态?
apache-flink
、
flink-sql
我想知道一般对
查询
和表使用了多少状态。首先,我使用
Flink
SQL
处理来自Kafka主题
的
消息: country STRING,) WITH (状态管理
的
是这样说
的
: 那么,我是否正确地理解
Flink
浏览 8
提问于2021-12-11
得票数 0
回答已采纳
1
回答
Flink
可以在非
动态
表上运行连续
查询
吗?
apache-flink
、
flink-sql
我希望使用
Flink
SQL
作为多个不同服务上
的
物化视图。例如,从MySQL & Redis & RPC服务读取数据,将它们连接在一起,然后更新存储在PostgreSQL
中
的
结果表。如果“通知”包含源表
中
的
所有信息,那么我可以只使用
动态
表。但是,源表
中
的
数据太大,无法将它们全部存储在
动态
表
中
,这将是一种浪费。所以最好
的
方法是:
Flink<
浏览 5
提问于2020-10-27
得票数 1
1
回答
使用多个不同
的
SQL
查询
(聚合)安装
Flink
应用程序
apache-flink
、
flink-streaming
、
amazon-kinesis
、
flink-sql
我需要从同一个来源构建一个具有不同列聚合
的
管道,比如由userId构建
的
管道,由productId构建
的
管道,等等。我还希望有不同
的
粒度聚合,比如按小时、每天进行聚合。每个聚合将有一个不同
的
接收器,比如不同
的
nosql表。 使用Table构建
SQL
查询
似乎很简单。但是我想减少管理太多
Flink
应用程序
的
操作开销。所以我想把所有不同
的
SQL
查询
放在一个pyflink
浏览 4
提问于2021-10-03
得票数 0
回答已采纳
1
回答
Apache表1.4:表上可能有外部
SQL
执行吗?
java
、
apache-flink
、
flink-sql
是否可以在外部
查询
现有的StreamTable,而不上传.jar获取执行环境和检索表环境?由于Apache表1.4
的
动态
(连续)表特性,我一直在等待它
的
发布。我期待其他
的
东西,我认为在运行时修改表并修改它
的
参数是可能
的
。为了执行一些活动
查询
,而不是在数据流之上定义(连续
的
或仅附加
的
)数据库视图。我知道我可以将我
的
表导出到一些数据库
中
,并使用
SQL
动态</e
浏览 5
提问于2017-10-25
得票数 2
回答已采纳
1
回答
Flink
中
的
动态
SQL
查询
apache-flink
、
flink-streaming
、
flink-sql
我有一个这样
的
SQL
查询
String ipdetailsSql = "select sid, _zpsbd6 as ip_address, ssresp, reason, " +GROUP BY TUMBLE(ts, INTERVAL '1' MINUTE), sid, _zpsbd6, ssresp, reason"; 根据用户输入,我希望将botcode='r1‘更改为给定
的
输入我在
flink
1.7上使用stream env。我尝试了配
浏览 19
提问于2019-05-30
得票数 0
回答已采纳
1
回答
不能在
Flink
sql
-client
中
创建源文件。
apache-flink
、
flink-streaming
、
flink-sql
我一直试图在
Flink
中使用SOURCE语句创建一个文件。从医生那里: /opt/
flink
# echo "select 'hello';" > test.<e
浏览 8
提问于2021-06-11
得票数 0
回答已采纳
1
回答
在
Flink
中
对数据流执行
sql
查找
的
最有效方法
sql
、
apache-flink
给定来自Kafka
的
数据流,是否有内置
的
方法,或者执行
SQL
查找
的
最有效方法是什么。 例如,将流对象连接到
sql
表,并将其与Kafka数据流连接。给定可以在自组织基础上更新
的
sql
表,
浏览 16
提问于2020-04-15
得票数 0
回答已采纳
1
回答
Flink
-使用JdbcDynamicTableSource对JDBC数据库进行连续
查询
。
postgresql
、
apache-flink
、
flink-streaming
、
flink-sql
我正在使用
Flink
从postgresql数据库
中
读取数据,该数据库经常使用新
的
数据进行更新。目前,我可以使用
Flink
的
从这个数据库进行一次
查询
.我想在这个数据库上运行一个连续
查询
,但是由于这个
sql
源不是一个无限制
的
输入,所以我
的
查询
只运行一次并停止。据我所知,我可以: 以一种强力
的
方式重复运行这些
查询
,可能使用。使用,因为连续
查询
是在<
浏览 6
提问于2020-11-24
得票数 0
回答已采纳
1
回答
Apache :如何在滚动时间窗口中使用DISTINCT?
apache-flink
、
flink-streaming
、
flink-sql
我有一个像这样
的
流:<_time(timestamp), uri(string), userId(int)>。: "SELECT tumble_start(_time, interval '10' second) as timestart, " +"GROUP BY tumble(_time, interval '10' second), uri"; final Table table = tableEnv.sql
浏览 1
提问于2018-03-02
得票数 1
1
回答
Flink
- kubernetes上部署
flink
应用程序
的
多个实例
kubernetes
、
apache-flink
、
flink-streaming
、
flink-sql
、
flink-batch
我需要在K8上部署
Flink
应用程序
的
帮助 我们有3个源,将以
SQL
查询
的
形式发送触发条件。总
查询
数约为3-6k,有效地增加了
flink
实例
的
负载。由于大量
的
查询
,我们决定为每个源创建多个
flink
应用实例。因此,一个
flink
实例实际上只能执行~1-2K个
查询
。示例:
sql
查询
源为A、B、C
Flink
实例
浏览 31
提问于2020-08-24
得票数 1
1
回答
如何理解
Flink
中
的
流表?
hadoop
、
apache-flink
、
flink-streaming
、
flink-sql
对我来说,很难理解
Flink
中
的
流表。我可以理解Hive,将一个固定
的
静态数据文件映射到一个“表”,但是如何体现一个建立在流数据之上
的
表呢?例如,每1秒就有5个具有相同结构
的
事件被发送到Kafka流:{"num":2, "value": "b"} ....构建在它们上
的
动态
表是什么样
浏览 2
提问于2020-10-29
得票数 0
回答已采纳
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
1
回答
DataStream上
的
Flink
sql
查询
(Apache )
java
、
apache-flink
、
stream-processing
、
event-stream-processing
我完全是阿帕奇·弗林克
的
菜鸟。只是想弄脏我
的
手。我有下面的场景。事件数据报 我正在学习
动态
表和
Flink
SQL
的
概念。我不知道如何进一步处理。有人能帮帮我吗?
浏览 0
提问于2018-02-09
得票数 0
2
回答
有任何方法可以在Apache表API
中
解析字符串表达式吗?
apache-flink
、
flink-streaming
、
flink-sql
我试图使用
Flink
表API执行聚合,方法是接受group字段和字段聚合表达式作为用户
的
字符串参数。输入 $("max(salary)").as("maxSalary")它将引发以下异常 Excepti
浏览 7
提问于2022-10-06
得票数 0
1
回答
运行
Flink
应用程序需要JAR文件吗?
scala
、
apache-flink
我正在阅读费边·韦斯克和瓦西利基·卡拉维里
的
“Stream Processing with Apache
Flink
”一书。在运行之前,必须将其转换为JAR文件吗?如果是这样,如何将文件转换为JAR?
浏览 2
提问于2022-01-20
得票数 0
回答已采纳
1
回答
Flink
SQL
客户端连接到安全
的
kafka集群
apache-kafka
、
apache-flink
、
flink-sql
我想对
Flink
SQL
表执行一个
查询
,该
查询
由安全
的
kafka集群
的
kafka主题支持。我能够以编程方式执行
查询
,但无法通过
Flink
SQL
客户端执行。
Flink
SQL
查询
以编程方式 // Create the execution environment通过
浏览 1
提问于2021-02-23
得票数 1
1
回答
是否有方法可以将Azure
SQL
server用作数据源?
apache-flink
、
pyflink
我
的
项目目前构建在Azure上(数据存储在Azure
SQL
server
中
),我目前正在尝试通过利用PyFilnk将流/批处理功能引入到我
的
项目中。但是,我没有找到任何关于如何将PyFlink连接到Azure
SQL
server
的
文档,有没有一种方法可以在PyFlink中使用Azure
SQL
server作为数据源?
浏览 13
提问于2021-07-22
得票数 0
1
回答
表选项不包含选项键“connector”
apache-flink
我想使用
flink
sql
client创建一个配置单元表。我可以成功创建表t2,但是当我
查询
t2时,它会报错 Table options do not contain an option key 'connector' for discovering a connector我已经在conf/
sql
-client-defaults.yaml文件
中
设置执行类型为batch。 我会问这里有什么问题。谢谢!
Flink
SQL
> use te
浏览 103
提问于2020-12-21
得票数 0
回答已采纳
2
回答
Flink
SQL
client:选择'hello‘引发
的
[错误]无法执行
SQL
语句
apache-flink
、
flink-sql
我正在跟踪
Flink
。打开
Flink
SQL
客户端看起来很好,但是SELECT 'hello world'不能工作。$ /data/apache/
flink
/
flink
-1.12.0/bin/
sql
-client.sh embedded SLF4J: Class path contains multiple SLF4JSearching for '/data/apache
浏览 14
提问于2021-03-26
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Flink:动态表上的连续查询
mybatis中的动态SQL
Flink基础教程(三):生产环境中的Flink
慢查询sql的检测与记录
SQL语法基础——SQL查询语句的执行顺序解析(建议收藏)
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券