• linkedu视频
  • 平面设计
  • 电脑入门
  • 操作系统
  • 办公应用
  • 电脑硬件
  • 动画设计
  • 3D设计
  • 网页设计
  • CAD设计
  • 影音处理
  • 数据库
  • 程序设计
  • 认证考试
  • 信息管理
  • 信息安全
菜单
linkedu.com
导航菜单
  • 网页制作
  • 数据库
  • 程序设计
  • 操作系统
  • CMS教程
  • 游戏攻略
  • 脚本语言
  • 平面设计
  • 软件教程
  • 网络安全
  • 电脑知识
  • 服务器
  • 视频教程
  • windows
  • 服务器硬件
  • 服务器运维
  • 云计算
  • 虚拟化
  • IIS教程
  • Linux
  • Apache
  • Ftp
  • DNS
  • Nginx
您的位置:首页 > 服务器 >云计算 > hive SymlinkTextInputFormat介绍及用法,textinputformat

hive SymlinkTextInputFormat介绍及用法,textinputformat

作者:网友 字体:[增加 减小] 来源:互联网

本文主要包含hive inputformat,hive date format,hive row format,textinputformat,hive等服务器相关知识,网友希望可以进行参考

hive SymlinkTextInputFormat介绍及用法,textinputformat


1、介绍    先摘一段官方介绍,如下:    Symlink file is a text file which contains a list of filename / dirname.This input method reads symlink files from specified job input paths and takes the files / directories specified in those symlink files as actual map-reduce input. The target input data should be in TextInputFormat.     simlink文件其实就是一个text的文件,不过文件里面存放的不是hive表中要读取的数据,而是数据存放的地址。类似于linux下的软链接。simlink文件中的数据地址,支持正则表达式,用起来非常灵活。

2、举例说明
2.1 创建表  CREATE TABLE symlink_text_input_format (key STRING, value STRING) STORED AS INPUTFORMAT 'org.apache.hadoop.hive.ql.io.SymlinkTextInputFormat' OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.IgnoreKeyTextOutputFormat';
2.2 在hdfs上上传两个text格式的文件,如下,放到/tmp目录
hadoop fs -put symlink1.txt /tmp/symlink1.txt hadoop fs -put symlink2.txt /tmp/symlink1.txt
2.3 创建一个link文件,内容是真实的文件地址: /tmp/symlink1.txt /tmp/symlink1.txt
2.4 上传link文件到hive表symlink_text_input_format 的目录中 hadoop fs -put link /user/hive/warehouse/test.db/symlink_text_input_format/link
2.5 查询symlink_text_input_format 
select * from  symlink_text_input_format  ; 当查询symlink_text_input_format,首先读到的链接文件的地址,会把这些地址当做hive表中的input file。
2.6 在创建的链接文件中,支持正则表达式。如下的链接文件,会把/tmp目录下symlink开头的文件当做hive表的输入 /tmp/symlink*

3、应用场景
集群下面有3个目录,以及目录中的文件如下, /logdata/uigs/web/cnc/201401/20140414 ----/logdata/uigs/web/cnc/201401/20140414/ip1.201404141220.log ----/logdata/uigs/web/cnc/201401/20140414/ip2.201404141220.log ----/logdata/uigs/web/cnc/201401/20140414/ip3.201404141220.log ----/logdata/uigs/web/cnc/201401/20140414/ip4.201404141220.log /logdata/uigs/web/tc/201401/20140414 ----/logdata/uigs/web/tc/201401/20140414/ip5.201404141220.log ----/logdata/uigs/web/tc/201401/20140414/ip6.201404141220.log ----/logdata/uigs/web/tc/201401/20140414/ip7.201404141220.log ----/logdata/uigs/web/tc/201401/20140414/ip81.201404141220.log /logdata/uigs/web/sjs/201401/20140414 ----/logdata/uigs/web/sjs/201401/20140414/ip9.201404141220.log ----/logdata/uigs/web/sjs/201401/20140414/ip10.201404141220.log ----/logdata/uigs/web/sjs/201401/20140414/ip11.201404141220.log ----/logdata/uigs/web/sjs/201401/20140414/ip12.201404141220.log
hive中有表 uigs,以分钟当做分区,为了把上面的数据写入到logdata=201404141220的分区中,可以创建一个link文件,内容如下
/logdata/uigs/web/sjs/201401/20140414/*201404141220* /logdata/uigs/web/cnc/201401/20140414/*201404141220* /logdata/uigs/web/tc/201401/20140414/*201404141220*
然后把这个link文件put到logdata=201404141220的分区目录中。

分享到:QQ空间新浪微博腾讯微博微信百度贴吧QQ好友复制网址打印

您可能想查找下面的文章:

  • hive SymlinkTextInputFormat介绍及用法,textinputformat

相关文章

  • 关于分布式程序 java的内存管理浅谈,java内存管理浅谈
  • 系统监控软件Ganglia的安装,监控软件ganglia
  • The superclass "javax.servlet.http.HttpServlet" was not found on the Java Build Path,httpservlet
  • HBase shell 启动出错 org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = Con,
  • Stanford机器学习[第六讲]-朴素贝叶斯算法,stanford第六讲
  • hive 不以科学计数法输出,hive计数法输出
  • 我与英语技术书籍,英语技术书籍
  • Hadoop学习笔记0001——Hadoop安装配置,hadoop学习笔记0001
  • 云服务器之间实时文件同步和文件备份的最简单高效的免费方案,实时文件备份
  • 机器学习--决策树(ID3)算法案例,id3案例

文章分类

  • windows
  • 服务器硬件
  • 服务器运维
  • 云计算
  • 虚拟化
  • IIS教程
  • Linux
  • Apache
  • Ftp
  • DNS
  • Nginx

最近更新的内容

    • <转>Openstack ceilometer 宿主机监控模块扩展,openstackceilometer
    • Binary Tree Preorder Traversal (leetcode 144),preorderleetcode
    • pig里面没有if:不能判断一个条件后决定一个执行步骤,pigif
    • Spark DataFrame小试牛刀,sparkdataframe小试
    • OpenStack之swift安装笔记,openstackswift
    • 观点 | 为什么说云主机比物理机故障率更低?,云主机
    • HDFS概述---namenode的设计详解,hdfs概述---namenode
    • hbase遇到问题及解决方法,hbase遇到问题
    • MemStore刷写线程—MemStoreFlusher源代码分析,hbasememstore
    • logstash 学习小记,logstash小记

关于我们 - 联系我们 - 免责声明 - 网站地图

©2020-2025 All Rights Reserved. linkedu.com 版权所有