Bu konu, E-MapReduce (EMR) kümesinde Impala kullanarak OSS-HDFS üzerinde depolanan verilerin nasıl sorgulanacağını açıklar.
Önkoşullar
Impala hizmeti seçilerek EMR V3.42.0 veya sonraki bir sürüm ya da EMR V5.8.0 veya sonraki bir sürüm içeren bir küme oluşturun. Daha fazla bilgi için bkz. Küme oluşturma.
Bir paket için OSS-HDFS'yi etkinleştirin ve OSS-HDFS üzerinde erişim izinleri verin. OSS-HDFS'yi etkinleştirme hakkında daha fazla bilgi için bkz. OSS-HDFS'yi etkinleştirme ve erişim izinleri verme.
Yordam
-
Impala'ya bağlanmak için terminalde aşağıdaki komutu çalıştırın.
Daha fazla bilgi için bkz. Impala'ya bağlanma.
impala-shell -i core-1-1 -
OSS-HDFS üzerinde depolanan verileri sorgulamak için Impala'yı kullanın.
-
Bir veritabanı oluşturun.
CREATE DATABASE store LOCATION 'oss://<bucket-name>.<endpoint>/impala'; -
Veritabanını kullanın.
USE store; -
Bir tablo oluşturun.
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; -
Tabloya veri ekleyin.
INSERT INTO customer_demographics VALUES (1, 'Male', 'Single', 'Graduate', 1000, 'AAA', 2, 1, 1), (2, 'Female', 'Married', 'Undergraduate', 2000, 'BBB', 3, 2, 2); -
Tablodaki verileri sorgulayın.
select * from customer_demographics;
-