Este tópico descreve como usar o Impala em um cluster do E-MapReduce (EMR) para consultar dados armazenados no OSS-HDFS.
Pré-requisitos
Um cluster do EMR V3.42.0 ou posterior, ou EMR V5.8.0 ou posterior, deve estar criado com o service Impala selecionado. Para mais informações, consulte Create a cluster.
O OSS-HDFS deve estar ativo para um bucket, com as permissões de acesso devidamente concedidas. Para saber como ativar o OSS-HDFS, consulte Enable OSS-HDFS and grant access permissions.
Procedimento
-
Execute o seguinte comando no terminal para se conectar ao Impala.
Para mais informações, consulte Connect to Impala.
impala-shell -i core-1-1 -
Use o Impala para consultar dados armazenados no OSS-HDFS.
-
Crie um banco de dados.
CREATE DATABASE store LOCATION 'oss://<bucket-name>.<endpoint>/impala'; -
Selecione o banco de dados.
USE store; -
Crie uma tabela.
CREATE EXTERNAL TABLE customer_demographics ( `cd_demo_sk` INT, `cd_gender` STRING, `cd_marital_status` STRING, `cd_education_status` STRING, `cd_purchase_estimate` INT, `cd_credit_rating` STRING, `cd_dep_count` INT, `cd_dep_employed_count` INT, `cd_dep_college_count` INT) STORED AS PARQUET; -
Insira dados na tabela.
INSERT INTO customer_demographics VALUES (1, 'Male', 'Single', 'Graduate', 1000, 'AAA', 2, 1, 1), (2, 'Female', 'Married', 'Undergraduate', 2000, 'BBB', 3, 2, 2); -
Consulte os dados da tabela.
select * from customer_demographics;
-