扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
这篇文章将为大家详细讲解有关hive支持MongoDB具体的连接方法,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
创新互联-专业网站定制、快速模板网站建设、高性价比甘谷网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式甘谷网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖甘谷地区。费用合理售后完善,10年实体公司更值得信赖。
hive支持mongodb,具体的连接方法如下:
创建基于MongoDB的Hive表是通过MongoStorageHandler来处理的。它同样处理从Hive表里查询与插入数据(通过select与insert)。
CREATE [EXTERNAL] TABLE( ) STORED BY 'com.mongodb.hadoop.hive.MongoStorageHandler' [WITH SERDEPROPERTIES('mongo.columns.mapping'=' ')] TBLPROPERTIES('mongo.uri'=' ');
有两种方式来指定所需连接的Mongo Collection。
1. 在上述示例里面,通过mongo.uri这个表属性来指定,属性的值填入的是MongoDB connection string,通过它来指向具体的collection。这种方式会将这个URI存入表的metadata里面,如果需要填写连接的一些认证信息(如username:password等),该方式不太适合。
2. 第二种方式是把connection string填入一个properties文件,如:
# HiveTable.properties mongo.input.uri=mongodb://...
然后提供这个文件的路径给mongo.properties.path这个表参数,如
CREATE TABLE ... TBLPROPERTIES('mongo.properties.path'='HiveTable.properties')
备注:在创建相应Hive表时所引用的MongoDB collection不一定要空的。
在创建Hive表的时候,也可以选择性的指定MongoDB collection里的字段与Hive的列字段或struct字段的映射。指定的方式是在SERDEPROPERTIES里通过mongo.columns.mapping属性来指定。在创建基于BSON文件的Hive表时也可以用到。
如果创建的表是EXTERNAL的,那么在Hive里删除这张表时,不会影响MongoDB里面的数据,只会删除这张表的metadata。如果没有指定EXTERNAL,那么删除表的时候会连带MongoDB里的数据一并删除,因此最好是指定创建的表为EXTERNAL。
关于hive支持mongodb具体的连接方法就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流