HCatalog-テーブルの作成
この章では、テーブルを作成する方法とテーブルにデータを挿入する方法について説明します。HCatalogでテーブルを作成する規則は、Hiveを使用してテーブルを作成するのと非常によく似ています。
テーブルステートメントの作成
Create Tableは、HCatalogを使用してHiveメタストアにテーブルを作成するために使用されるステートメントです。その構文と例は次のとおりです-
構文
CREATE [TEMPORARY] [EXTERNAL] TABLE [IF NOT EXISTS] [db_name.] table_name
[(col_name data_type [COMMENT col_comment], ...)]
[COMMENT table_comment]
[ROW FORMAT row_format]
[STORED AS file_format]例
次の名前のテーブルを作成する必要があると仮定します employee を使用して CREATE TABLEステートメント。次の表に、のフィールドとそのデータ型を示します。employee テーブル-
| シニア番号 | フィールド名 | データ・タイプ |
|---|---|---|
| 1 | イード | int |
| 2 | 名前 | ストリング |
| 3 | 給料 | 浮く |
| 4 | 指定 | ストリング |
次のデータは、次のようなサポートされるフィールドを定義します。 Comment、などの行形式のフィールド Field terminator、 Lines terminator、および Stored File type。
COMMENT ‘Employee details’
FIELDS TERMINATED BY ‘\t’
LINES TERMINATED BY ‘\n’
STORED IN TEXT FILE次のクエリは、という名前のテーブルを作成します employee 上記のデータを使用します。
./hcat –e "CREATE TABLE IF NOT EXISTS employee ( eid int, name String,
salary String, destination String) \
COMMENT 'Employee details' \
ROW FORMAT DELIMITED \
FIELDS TERMINATED BY ‘\t’ \
LINES TERMINATED BY ‘\n’ \
STORED AS TEXTFILE;"オプションを追加した場合 IF NOT EXISTS、テーブルがすでに存在する場合、HCatalogはステートメントを無視します。
テーブルが正常に作成されると、次の応答が表示されます-
OK
Time taken: 5.905 secondsデータステートメントのロード
通常、SQLでテーブルを作成した後、Insertステートメントを使用してデータを挿入できます。ただし、HCatalogでは、LOADDATAステートメントを使用してデータを挿入します。
HCatalogにデータを挿入するときは、LOADDATAを使用してバルクレコードを保存することをお勧めします。データをロードする方法は2つあります。1つはlocal file system そして2番目はからです Hadoop file system。
構文
LOADDATAの構文は次のとおりです-
LOAD DATA [LOCAL] INPATH 'filepath' [OVERWRITE] INTO TABLE tablename
[PARTITION (partcol1=val1, partcol2=val2 ...)]- LOCALは、ローカルパスを指定するための識別子です。オプションです。
- OVERWRITEは、テーブル内のデータを上書きするためのオプションです。
- PARTITIONはオプションです。
例
以下のデータをテーブルに挿入します。名前の付いたテキストファイルですsample.txt に /home/user ディレクトリ。
1201 Gopal 45000 Technical manager
1202 Manisha 45000 Proof reader
1203 Masthanvali 40000 Technical writer
1204 Kiran 40000 Hr Admin
1205 Kranthi 30000 Op Admin次のクエリは、指定されたテキストをテーブルにロードします。
./hcat –e "LOAD DATA LOCAL INPATH '/home/user/sample.txt'
OVERWRITE INTO TABLE employee;"ダウンロードが成功すると、次の応答が表示されます-
OK
Time taken: 15.905 seconds