java讀取hive匯出的資料

通過hql語句：

insert overwrite directory '/comp/206/out/ldapd_busi_cmnctn_accu/$'

select  callingnum,custphone,count(*) as callcount
from dapd_voice_log_tmp
group by callingnum,custphone;

將統計資訊匯出到hdfs上，匯出了3個字段，hive預設字段分隔符為'\001'，我將匯出到hdfs的資料拷貝到了本地d盤重新命名為testdata，嘗試解析它，解析**如下：

public static void main(string args) throws exception ;

string sendstring = new string(bytes, "gbk");
arrs = line.split(sendstring);
system.out.println(arrs[0] + " : " + arrs[1] + " : " + arrs[2]);
}		br.close();
reader.close();
}

輸出為：

13860393195 : 114 : 1

15280154404 : 0591-87677500 : 1

18059386085 : 0593-7668885 : 1

說明可以被正確的解析。

hive資料匯出

一.操作前資料準備及資料資訊準備。二.使用select語句查詢結果寫入檔案中。命令範例一 命令範例二 註解 local的有無決定輸出檔案在本地檔案系統還是hdfs rowformat delimited fields terminated by t 決定檔案中資料的格式，且hive版本0.11之後才...

hive 匯出資料

hive有三種匯出資料的方式 匯出資料到本地 匯出資料到hdfs 匯出資料到另乙個表 匯出資料到本地檔案系統 insert overwrite local directory desfile select from srcfile 例 insert overwrite local directory...

hive 匯出資料

hive的資料匯出方式 hive有三種匯出資料的方式 匯出資料到本地檔案系統 insert overwrite local directory desfile select from srcfile 例 insert overwrite local directory home wyp wyp se...