`
dacoolbaby
  • 浏览: 1264738 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

Hive调用Python脚本异常

    博客分类:
  • Hive
阅读更多

我使用的是Hive 0.10和Hadoop 1.1.1。

在家里的环境是Hive 0.9和Hadoop 1.0.4.

 

Hive可以使用Python脚本大大地提高数据处理的开发效率,使用MapReduce的方式将数据处理成想要的结果。

 

我们使用ADD FILE 为Hive增加一个脚本,或者Jar包。

有两种方式:

ADD FILE {env:HOME}/your_file/your_script.py

ADD FILE /home/your_name/your_file/your_script.py

 

在调用的时候,过去的版本可以使用:

FROM u_data
SELECT
  TRANSFORM (userid, movieid, rating)
  USING 'python /home/dacoolbaby/test_data_mapper3.py'
  AS str
;

 

但是在Hive 0.10貌似不支持这样弄。

FROM u_data
SELECT
  TRANSFORM (userid, movieid, rating)
  USING 'python test_data_mapper3.py'
  AS str
;

 

后面的是脚本的名称,而不是整个的路径名。

以后在Hive下面使用Hadoop Distributed Cache要注意这个问题。

1
3
分享到:
评论

相关推荐

    如何在python中写hive脚本

    在Python中编写Hive脚本主要是为了方便地与Hadoop HIVE数据仓库进行交互,这样可以在数据分析和机器学习流程中无缝地集成大数据处理步骤。以下将详细介绍如何在Python环境中执行Hive查询和管理Hive脚本。 1. **直接...

    捕获hive脚本异常: echo $?

    首先,我们来看标题“捕获hive脚本异常:echo $?”。在Linux或Unix系统中,"echo $"命令用于输出上一个命令的退出状态,这是一个整数值,表示命令执行的成功与否。当命令成功执行时,通常返回0,而任何非零值表示...

    使用shell脚本执行hive、sqoop命令的方法

    ### 使用Shell脚本执行Hive与Sqoop命令详解 在大数据处理领域,Hive和Sqoop都是非常重要的工具。Hive可以用于数据汇总分析,而Sqoop则被用来在Hive和关系型数据库之间进行高效的数据迁移。为了提高工作效率,简化...

    shell中循环调用hive sql 脚本的方法

    本文将详细介绍如何在Shell脚本中循环调用Hive SQL语句,以便实现批量处理数据或者执行一系列相关的查询操作。 首先,我们要理解Shell脚本的基本结构和Hive SQL的功能。Shell脚本是一种解释型的编程语言,主要用于...

    大数据采集与处理技术相关shell脚本

    根据提供的文件信息,我们可以归纳出三个主要的大数据采集与处理技术相关的Shell脚本知识点:自动创建文件、自动采集以及分区。 ### 自动创建文件 此脚本的主要功能是基于两个给定日期(`beg_date` 和 `end_date`...

    关于【python】【UDF】【HIVE】读取外部资源文件和第三方库的问题解决方案

    python脚本中调用了本地的资源文件 解决方案: 1.首先外部资源要在运行之前添加,使用命令add jar [jar file]或者add file [file]在hive中进行临时注册。 2.UDF中内部调用的文件地址直接用本地文件地址表示。例如: ...

    apache-hive-2.1.1-bin.tar.gz下的bin文件夹,包含hive.cmd

    `hive.cmd`是Windows环境下执行Hive的命令脚本,它是一个批处理文件,用于启动Hive的交互式Shell。当用户在Windows系统上输入`hive`命令时,实际上就是在运行这个`hive.cmd`脚本。脚本内部会设置环境变量,如HADOOP_...

    Hive用户指南 Hive user guide 中文版

    - **调用外部脚本**:Hive支持通过脚本扩展其功能,例如调用Python或Shell脚本。 **2.8 删除表** - 使用`DROP TABLE table_name [PURGE]`来删除表及其所有数据。 **2.9 其他操作** - **LIMIT**:`SELECT ... ...

    Hive用户手册中文版.pdf

    Hive还支持调用Python、Shell等外部脚本语言,从而实现复杂的外部数据处理逻辑。 Hive的优化与技巧包括如何选择合适的Map和Reduce操作的数量,如何处理大表之间的JOIN操作以避免数据偏斜,如何合并小文件以提高数据...

    Hive数据分析和定时任务调度,也是Flask-Hive项目的大数据处理部分.zip

    - **Beeline**:另一种连接Hive的方式,是Hive提供的一个命令行工具,也可用Python的subprocess模块调用来执行Hive查询。 3. **Flask-Hive**: - **Flask**:轻量级的Python Web框架,用于快速开发Web应用。在本...

    EDI shell脚本职责清单1

    在这个场景中,我们看到一系列shell脚本被用来自动化处理数据处理流程,主要涉及Hadoop、Hive、MySQL和NLP(自然语言处理)的任务。以下是这些脚本的主要职责和涉及的技术点: 1. `/opt/running/edi/edi_new_in_...

    python 操作hive pyhs2方式

    安装完成后,就可以通过Python脚本与Hive进行交互了。 PyHs2库支持使用Kerberos认证机制,这对于安全性要求较高的Hadoop集群环境尤为重要。在配置Kerberos认证时,需要指定Kerberos服务名称(`krb_service`)、...

    Hive用户指南(Hive_user_guide)_中文版.pdf

    Hive还提供了命令行选项和交互式shell命令,以及调用Python、Shell等语言的支持。 Hive支持的Map/Reduce操作包括: - JOIN - GROUPBY - DISTINCT 使用Hive时需要注意的点包括字符集、数据压缩、数据的count...

    hiveenginewitness:帮助部署和维护Hive Engine见证的脚本

    这些Shell脚本通常会调用Hive Engine的API或CLI命令来完成相关任务。例如,`deploy.sh`可能包含了安装依赖、创建数据库连接、设置权限等步骤;`monitor.sh`可能使用curl或wget命令检查HTTP端点来获取节点状态;`...

    hive开发指南 -1.0.pdf

    此外,用户还可以在Hive中调用Python、Shell等外部脚本语言执行复杂的任务。 在数据查询方面,Hive提供了丰富的查询功能,包括SELECT、LIMIT、TOP-K、正则表达式列指定、分组(GROUP BY)、排序(ORDER BY、SORT BY...

    PyPI 官网下载 | hive_builder-1.1.3.tar.gz

    标题中的“PyPI官网下载 | hive_builder-1.1.3.tar.gz”表明这是一个在Python Package Index(PyPI)上发布的开源项目,名为`hive_builder`,版本为1.1.3,且以tar.gz格式打包。PyPI是Python开发者发布和分享自己...

    PyPI 官网下载 | soda-sql-hive-2.1.0b5.tar.gz

    4. **API和CLI**:库中可能包含Python API接口,允许开发者在代码中直接调用Soda SQL的功能。此外,还可能提供命令行界面(CLI),使得非开发人员也能方便地执行数据质量检查。 5. **测试套件**:为了确保库的正确...

    14-Hive查询1

    3. **使用 Shell 脚本查看 Hive 表**:通过编写简单的 Shell 脚本自动化执行 Hive 命令,查看表的信息或数据。 **总结** Hive 提供了一个便捷的接口,允许非专业程序员处理大数据。通过编译和优化过程,Hive 可以...

    使用Python构造hive insert语句说明

    因此,你可能需要从Hive中查询数据,然后用Python脚本自动化生成这些语句。例如,你可以通过Hive的Beeline客户端或者Python的impyla库获取数据,然后对每一行应用`transformString`函数,最后批量生成INSERT语句。 ...

Global site tag (gtag.js) - Google Analytics