Hive Metastore 中是否还有其他包含列的表?
有 30 个字段 describe my_table; 我在beeline 中 。同时,如果我访问 Hive Metastore,我会在 COLUMNS_V2 中看到 24 列,在 PARTITION_KEYS 中看到 2…
如何在 Hive 中编写非等值连接
我的表包括 3 个日期列: dateA 、 dateB 和 dateC 我的要求: JOIN ON dateA between dateB and dateC JOIN 在 Teradata 中运行得很好,但在 Hive 中…
我如何使用 pyspark 显示配置单元表
你好,我在 azure 上创建了一个 Spark HD Insight 集群,我正在尝试使用 pyspark 读取配置单元表,但问题是它只向我显示默认数据库 有人知道吗?…
缺少的转换是 FlinkLogicalJoin: LOGICAL -> STREAM_PHYSICAL
运行flink+hive程序时遇到如下异常: 没有足够的规则来生成具有所需属性的节点 缺少的转换是 FlinkLogicalJoin: LOGICAL -> STREAM_PHYSICAL 我认为这…
Python 中的自定义数组值 Hive UDF?
有没有办法在 Python 中创建数组值 Hive UDF?我感兴趣的 UDF 将采用 3 个值:初始值、最终值和步骤,并将返回中间值的数组。谢谢。杰森还好。 Java …
无法在 hive 服务器上运行 UDF
我在节俭服务器模式下运行配置单元。我在 jar 文件中有一个 UDF,我尝试通过运行来使用它 add jar create temporary function func_name as 'com.test…
Hive 中的 Unicode 字符
我尝试在 hive 中按 unicode 文本与 unicode 字符进行分组,但减速器惨败。 Hive 面临运行时异常。 hive 是否支持 unicode 字符? 引起原因:org.apac…
如何为 PIG 或 HIVE 中的行添加行号?
我在使用 Apache Pig 添加行号时遇到问题。 问题是我有一个 STR_ID 列,我想为 STR_ID 中的数据添加一个 ROW_NUM 列,即 STR_ID 的行号。 例如,以下…
如何在iReport中连接Hive?
我正在使用 Hadoop-0.20.0 和 Hive-0.8.0。现在我已将数据存入 Hive 表中,我想从中生成报告。为此,我使用iReport-4.5.0。为此,我还在 iReport 中下…
Hive 中的 4 小时报告
我有一个带有列的配置单元表 -> date, hr, count 其中 date, hr 是分区。考虑到我手头有数据和时间,我想查询表中的4小时汇总数据。 示例->如果我的日…
在 Hive 中导入表后显示错误计数
我已经从 MS SQL Server 导入了 Hive 中的近 10 个表。 但是,当我尝试交叉检查 Hive 中某个表中的记录时,我在运行查询时发现了更多记录(select cou…
hive serde 中访问登录的正则表达式
我想从访问日志中提取(ip、requestUrl、timeStamp)以加载到 hive 数据库。访问日志中的一行如下。 66.249.68.6 - - [14/Jan/2012:06:25:03 -0800] "…