使用Impala操作Kudu_MapReduce服务 MRS

link管理

链接快照平台

输入网页链接，自动生成快照
标签化管理网页链接

相关文章推荐

卖萌的佛珠 · 方案巴巴-每天看10000+营销策划方案· 2 月前 ·

狂野的马克杯 · Empower the ...· 3 月前 ·

霸气的胡萝卜 · 梯子npv加速小火箭-· 4 月前 ·

痴情的单杠 · Help And Training ...· 5 月前 ·

唠叨的薯片 · es6入门6--数组拓展运算符，Array. ...· 6 月前 ·

登录安装客户端的节点。

执行如下命令初始化环境变量。

source /opt/Bigdata/client/bigdata_env

若集群开启Kerberos认证，请执行如下步骤认证用户。若集群未开启Kerberos认证请跳过该步骤。

kinit 业务用户

执行如下命令登录impala客户端。

impala-shell

默认情况下， impala-shell 尝试连接到localhost的21000端口上的Impala守护程序。如需连接到其他主机，请使用 -i <host:port> 选项。要自动连接到特定的Impala数据库，请使用 -d <database> 选项。例如，如果您的所有Kudu表都位于数据库“impala_kudu”中，则 -d impala_kudu 可以使用此数据库。要退出Impala Shell，请使用以下命令 quit 。

执行如下命令创建Impala表并导入已准备好的数据，例如/tmp/data10。

create table dataorigin (name string,age string,pt string, date_p date) row format delimited fields terminated by ',' stored as textfile;

load data inpath '/tmp/data10' overwrite into table dataorigin;

执行如下命令创建Kudu表，其中kudu.master_addresses地址为KuduMaster实例的IP，请根据实际集群地址填写。

create table dataorigin2 (name string,age string,pt string, date_p date, primary key(name)) stored as kudu TBLPROPERTIES('kudu.master_addresses'='192.168.190.164:7051,192.168.204.178:7051,192.168.244.63:7051');

执行如下命令操作Kudu表。

插入数据

insert into dataorigin2 select * from dataorigin;

更新数据

UPDATE dataorigin2 SET date_p="2021-03-31" where age="73";

更新或插入行

UPSERT INTO dataorigin2 VALUES ("spjted","75","28","2021-03-32");

UPSERT INTO dataorigin2 VALUES ("kwhakb","92","29","2021-03-33");

UPSERT INTO dataorigin2 VALUES ("oftrkf","13","30","2021-03-34");

UPSERT INTO dataorigin2 VALUES ("kiewti","36","31","2021-03-35");

UPSERT INTO dataorigin2 VALUES ("rknmql","98","32","2021-03-36");

UPSERT INTO dataorigin2 VALUES ("fwcoij","52","33","2021-03-37");

UPSERT INTO dataorigin2 VALUES ("pgvpdo","37","34","2021-03-35");

删除行

DELETE FROM dataorigin2 WHERE date_p="2021-03-31";