Hive是Hadoop的数据仓库系统，可以简化数据汇总，即席查询以及分析存储在Hadoop兼容的分布式文件系统中的大型数据集。 Hive提供了一种机制，用于将结构投影到此数据上，并使用类似SQL的语言HiveQL查询数据。
regexp_replace 替换字符串后面的第一个匹配项，并返回完整字符串
我有一个字符串，上面写着“不要替换此文本，而是替换最后一个文本<-- this one". I want to replace the first match from the back of the string, and return the full ...
我的字符串是[xxxxxxxx##yyyyyyyy##zzzzzz]。我想用双 ## 来分割它。 hive 中的 split(str, '##') 返回空。图案怎么样？
必须删除2023-03-26至2023-07-10之间的重复数据。 我尝试使用此命令从表中删除重复项，但出现错误。 命令： 设置 hive.exec.dynamic.partit...
ParseException 第 13:211 行无法识别表达式规范中 '(' 'SELECT' 'a' 附近的输入 (state=42000，code=40000)
我将 Vertica 查询转换为 HIVE 以在 hive 上创建视图。这是以下查询： 创建视图 db_metadata.vw_gensql_webmddev_staging AS 选择a.sql_order， 一个.sql， a.posn， ...
无法使用 Spark Shell 中的现有 Hive 表创建外部 Hive 表
我正在尝试使用 Spark shell 中的现有配置单元表创建外部表。 （这在 beeline/Hive shell 中工作正常，但无法在 Spark Shell 中执行） Spark.sql(“创建外部表...
我的文件夹结构如下 gs://bucket_name/data/db_name.db/table_name/color=red/txn_dt=2023-01-01/.bin_1 gs://bucket_name/data/db_name.db/table_name/color=red/txn_dt=2023-01-01/.bin_2 GS://
Apache Spark JAVA_9 通用语言版本上的 Apacher Hadoop 、Apacher Hive
尝试设置Hive使用Spark作为引擎。 经过长时间的配置后，出现超时错误。 应用程序日志文件纱线日志-applicationId 错误yarn.ApplicationMaster：用户类抛出异常...
HUE sql 脚本关键字搜索在 case 语句中返回错误值
嗨，我有一个脚本来查找关键字，但它似乎只有在关键字两侧都是数字时才有效。如何无论两边是什么都搜索关键字？ 例如，以下
我正在尝试将参数传递给我的 Hive 查询，如下所示： hive --hivevar prev_year_sixmnth_date='2023-01-01' -e '选择 ${hivevar:prev_year_sixmnth_date} 作为 prev_year_sixmnth_date' 我得到结果了...
我创建了一个新表： 像clickstream_v3一样创建表clickstream_v3_test； 然后填充数据： 插入表clickstream_v3_test 从 clickstream_v3 中选择 *，其中 导出日期='2023...
我有一个表，其中包含一些带有 Unix 时间戳的值。 数据的频率是可变的，但通常在每分钟一个数据点左右。 我想在没有
在 INSERT INTO 分区表中使用 hive conf 时遇到问题。 下面是我的代码 设置期间 = 202305； 设置 DAY=concat(substr(${hiveconf:PERIOD},1,4),'-',substr(${hiveconf:PERIOD},5,2),'-01'); ...
使用 Pyspark 的 HIVE JDBC 连接返回列名作为行值
我正在使用 Pyspark 连接到 HIVE 并获取一些数据。问题是它返回所有值为列名的行。它返回正确的列名。只有行值是
SQL Hive - 如何将 Unix 时间 GREGORIAN DATE 转换为 HIJRI DATE
我需要帮助将 unix 时间公历日期转换为回历日期。我找不到与 HIVE 一起工作的方法。 下面的查询是从 unix 时间列中查找公历日期： 从_unixtime 选择...
我正在做一个测试，我必须找出一个表的分区数并检查它是否正确。如果我使用 show partitions TableName 我会按名称获得所有分区，但我希望获得 ...
Presto + Spark 的 ThriftServer：null
我正在 Minio、Spark 和 Presto 之间构建 PoC 集成，但 Presto 并不真的想与 Spark 交谈，我在这里有点碰壁。 对于 Presto 中的连接器，我使用的是配置单元： 连接...
我正在使用配置单元 3.1.2 和 hadoop 3.3.5。我手动触发了次要压缩，但它停留在启动状态。我找不到任何关于如何为工人配置的文档。我在某处读到它是
如何使用 pyspark 编写 hive 分区表，并跳过相等的数据列？
在我的项目中，我使用带有pyspark的hadoop-hive。 我的表由此查询创建。 创建表 target_db.target_table( 标识字符串） 分区方式（ 用户名字符串， 类别 st...
我无法在此代码中重置旧过滤器。我正在使用 Hive 和 Flutter。即使我不把它们放在盒子里，过滤器也放在盒子里 我尝试了 setState、box.compact、Navigator.pop 和 reo...
创建外部表格部分（ p_partkey 十进制（5）， p_name 字符串， p_mfgr 字符串， p_brand 字符串， p_type 字符串， p_size 十进制（2），