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 terminatorLines 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