大数据Kudu（十）：Flink操作Kudu

向右看齐 2024-03-30 11:02 197阅读 0赞

文章目录

Flink操作Kudu

Flink主要应用场景是流式数据处理上，有些公司针对流式数据使用Flink实时分析后将结果存入Kudu,例如快手公司。这里将实时计算的结果存入Kudu需要自定义Flink Kudu Sink。

场景：Flink实时读取Socket数据，将结果存入Kudu表t_flink_result,为了方便操作不再创建Kudu外表，这里在Impala中创建Kudu内表t_flink_result：

create table t_flink_result
(
    id  int,
    name string,
    age int,
    primary key (id)
)
partition by hash partitions 3
stored as kudu
tblproperties(
 'kudu.master_address' = 'cm1:7150,cm2:7150'
)

在Maven中导入以下Flink 包

发表评论取消回复

表情：

评论列表（有 0 条评论，197人围观）

大数据Kudu（十）：Flink操作Kudu

Flink操作Kudu

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关大数据Kudu（十一）：ClickHouse与Kudu对比

相关大数据Kudu（十）：Flink操作Kudu

相关大数据Kudu（九）：Spark操作Kudu

相关大数据Kudu（八）：Kudu与Impala整合

相关大数据Kudu（七）：Kudu分区策略

相关【大数据入门核心技术-Kudu】（二）Kudu安装部署

相关【大数据入门核心技术-Kudu】（一）Kudu简介

相关大数据存储引擎——Kudu

相关 kudu

相关 kudu

随便看看

(3/3)Oracle中用Exp命令导出指定用户下的所有表的前N行数据，并用imp数据导入到本地数据库中--修改编码

实现el-table点击任意位置选中当前行并设置默认值

HBase逻辑和物理存储结构

人工智能三大关键能力，终于有人讲明白了

数据缺失值的3种处理方式，终于有人讲明白了

2021年，AI哪个方向最火？看看大神们怎么说

教程文章

热评文章

1江湖小白之一起学Python （二）爬取数据的保存

2Java Shiro：简化身份验证和授权的安全框架

3Java中try()catch{}的使用方法

4Swagger注解-@ApiModel 和 @ApiModelProperty

5windows下强制杀死tomcat进程

6uni-app 条形码(一维码)/二维码生成实现

标签列表