国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

python處理數據,存進hive表的方法

2020-02-15 22:12:00
字體:
來源:轉載
供稿:網友

首先,公司的小組長給了我一個任務,把一個txt的文件中的部分內容,存進一個在hive中已有的表的相同結構的表中。所以我的流程主要有三個,首先,把數據處理成和hive中表相同結構的數據,然后仿照已有的hive中表的結構再創建一張新的數據表,最后把本地的txt文件上傳到hive中新建的數據表中。

1:已有的數據表的結構和在hive表中的結構完全對不上,下面的圖是原來hive中表的結構和小組長給我的txt中表的結構:

大家可以看出,我們原來的hive中表的字段一共有17個,而組長給我的表中的字段一共有9個,其中最后一個為json結構,而且順序還不對,所以我們要進行篩選,把對應上的字段放到相應位置,對應不上的字段寫成空。

大家要注意幾個地方,原來的數據是按照tab來劃分的,所以我們要數好對應的tab的數目,好來計算出來數據的實際的位置信息,然后我們按照原來hive表中的數據順序,重新排列我們新建表的數據的順序,下面給大家看看結果:

其中line[0]=null,line[1]=102,大家以此類推。

3:我們把本地的txt文件導入到hive表中。首先我們要新建一個和原來hive表中相同結構的數據表,然后把我們的數據導入到表中,

hive> creat table new_sft(x1 string,x2 string ,...,xn string) partitioned by (d string);

建好表之后,把數據導入到新表之中:

hive> load data local inpath‘/home/opendev/1.txt' into table new_sft;

最后給大家看看我的最終的結果:

以上這篇python處理數據,存進hive表的方法就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持武林站長站。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 淮南市| 博白县| 贵德县| 游戏| 白河县| 淅川县| 逊克县| 西贡区| 清流县| 阳高县| 日照市| 通州区| 长春市| 临海市| 会同县| 射洪县| 石首市| 美姑县| 桃源县| 林甸县| 青河县| 普兰县| 台前县| 冀州市| 奉节县| 固安县| 克山县| 治县。| 会宁县| 吉水县| 普格县| 德阳市| 滕州市| 湖南省| 肇东市| 博白县| 涟水县| 五家渠市| 凌海市| 邹城市| 涪陵区|