日本免费全黄少妇一区二区三区-高清无码一区二区三区四区-欧美中文字幕日韩在线观看-国产福利诱惑在线网站-国产中文字幕一区在线-亚洲欧美精品日韩一区-久久国产精品国产精品国产-国产精久久久久久一区二区三区-欧美亚洲国产精品久久久久

  1. 首頁 > 云知道 > >

通過CDH5 Hadoop讀取和寫入OSS數(shù)據(jù)( 三 )

云知道云服務(wù)器

  • 重啟所有節(jié)點(diǎn)的impala相關(guān)進(jìn)程 。
    重啟完成后即可使用impala查詢OSS數(shù)據(jù) 。
    • 驗(yàn)證配置TPC-DS的benchmark有一張表為call_center，假設(shè)該表存儲(chǔ)在OSS中，我們可以創(chuàng)建一個(gè)外部表指向它，并且查詢這張表根據(jù)cc_country分組分別有多少條記錄 。
    [root@cdh-master ~]# impala-shell -i cdh-slave01:21000
    Starting Impala Shell without Kerberos authentication
    Connected to cdh-slave01:21000
    Server version: impalad version 2.11.0-cdh5.14.4 RELEASE (build20e635646a13347800fad36a7d0b1da25ab32404)
    ***********************************************************************************
    Welcome to the Impala shell.
    (Impala Shell v2.11.0-cdh5.14.4 (20e6356) built on Tue Jun 1203:43:08 PDT 2018)
    The HISTORY command lists all shell commands in chronological order.
    ***********************************************************************************
    [cdh-slave01:21000] > droptableifexists call_center;
    Query: droptableifexists call_center
    [cdh-slave01:21000] >
    [cdh-slave01:21000] > createexternaltable call_center(
    >cc_call_center_skbigint
    > ,cc_call_center_idstring
    > ,cc_rec_start_datestring
    > ,cc_rec_end_datestring
    > ,cc_closed_date_skbigint
    > ,cc_open_date_skbigint
    > ,cc_namestring
    > ,cc_classstring
    > ,cc_employeesint
    > ,cc_sq_ftint
    > ,cc_hoursstring
    > ,cc_managerstring
    > ,cc_mkt_idint
    > ,cc_mkt_classstring
    > ,cc_mkt_descstring
    > ,cc_market_managerstring
    > ,cc_divisionint
    > ,cc_division_namestring
    > ,cc_companyint
    > ,cc_company_namestring
    > ,cc_street_numberstring
    > ,cc_street_namestring
    > ,cc_street_typestring
    > ,cc_suite_numberstring
    > ,cc_citystring
    > ,cc_countystring
    > ,cc_statestring
    > ,cc_zipstring
    > ,cc_countrystring
    > ,cc_gmt_offsetdouble
    > ,cc_tax_percentagedouble
    > )
    > rowformatdelimitedfieldsterminatedby'|'
    > location 'oss://${your-bucket-name}/call_center';
    Query: createexternaltable call_center(
    cc_call_center_skbigint
    ,cc_call_center_idstring
    ,cc_rec_start_datestring
    ,cc_rec_end_datestring
    ,cc_closed_date_skbigint
    ,cc_open_date_skbigint
    ,cc_namestring
    ,cc_classstring
    ,cc_employeesint
    ,cc_sq_ftint
    ,cc_hoursstring
    ,cc_managerstring
    ,cc_mkt_idint
    ,cc_mkt_classstring
    ,cc_mkt_descstring
    ,cc_market_managerstring
    ,cc_divisionint
    ,cc_division_namestring
    ,cc_companyint
    ,cc_company_namestring
    ,cc_street_numberstring
    ,cc_street_namestring
    ,cc_street_typestring
    ,cc_suite_numberstring
    ,cc_citystring
    ,cc_countystring
    ,cc_statestring
    ,cc_zipstring
    ,cc_countrystring
    ,cc_gmt_offsetdouble
    ,cc_tax_percentagedouble
    )
    rowformatdelimitedfieldsterminatedby'|'
    location 'oss://${your-bucket-name}/call_center'
    Fetched 0row(s) in0.07s
    [cdh-slave01:21000] > select cc_country, count(*) from call_center groupby cc_country;
    Query: select cc_country, count(*) from call_center groupby cc_country
    Query submitted at: 2018-10-2816:21:13 (Coordinator: http://cdh-slave01:25000)
    Query progress can be monitored at: http://cdh-slave01:25000/query_plan?query_id=fb4e09977145f367:3bdfe4d600000000
    +---------------+----------+
    | cc_country| count(*) |
    +---------------+----------+
    | United States | 30|
    +---------------+----------+
    Fetched 1 row(s) in 4.71s    了解更多的互聯(lián)網(wǎng)醫(yī)藥攻略聯(lián)系我們（微信）：kinnah333

    推薦閱讀