草庐IT

hadoop - 更新配置单元中新添加的列

我一直在尝试更新hive中的一个orc表,该表是分桶的,并且settransactional=true属性。正常更新效果很好,但只要我更改表格并添加一个新列,例如column_added_5,并尝试更新column_added_5语句执行但列未更新。感谢任何帮助/指导。 最佳答案 我认为一种方法是:CREATETABLEnew_table_nameASSELECTcolumn1,column2,column3,..."default_value"ascolumn_added_5FROMyour_table_name;DROPTABL

sql - 改变 hive 中的现有 map

我有一个配置单元表,其中一列为map数据类型。map>现在我想在结构值中添加一列,如下所示:map>任何人都知道如何实现这一目标。提前致谢。 最佳答案 https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-ChangeColumnName/Type/Position/Commentaltertabletchangecolumnmycolmycolmap>;请注意,默认情况下只有新分区会受到更改的影响。如果您希望它应用

sql - 排序行时优化 Hive GROUP BY

我有以下(非常简单的)Hive查询:selectuser_id,event_id,min(time)asstart,max(time)asend,count(*)astotal,count(interaction==1)asclicksfromevents_allgroupbyuser_id,event_id;表格结构如下:user_idevent_idtimeinteractionEx833Lli36nxTvGTA1DvjuCUv6EnkVundBHSBzQevw14304815302950Ex833Lli36nxTvGTA1DvjuCUv6EnkVundBHSBzQevw14304

sql - 错误 :Invalid table alias or column reference while using map in Hive

我正在执行以下配置单元查询:createorreplaceviewtest.hospasselectp.hosp_id,p.hosp_name,max(casewhen`p.my_map[1].id`isNULLthen1else0end)ashos_main_idfromarch.hospitalgroupbyp.hosp_id,p.hosp_name,p.my_map[1].id;Error:Invalidtablealiasorcolumnreference'p.my_map[1].id'.有map名称my_map>,那为什么我仍然收到错误消息:Error:Invalidtabl

csv - 将 csv 文件的全部内容加载到 Hive 表中的单个列中

在Hive相关问题上需要一些帮助。我正在尝试将整个csv文件加载到单列Hive表中。文件中的每个条目都应该是Hive表中的一行。我试图更改ROWFORMAT-特别是尝试更改为LINESTERMINATEDBY','而不是'\n'。但是,目前仅支持'\n'字符。目前这是一个JIRA问题(https://issues.apache.org/jira/browse/HIVE-11996)。我目前唯一的想法是通过linux命令用\n替换文件中的逗号,但是我想看看是否有人可以提出一些其他值得考虑的解决方案。提前致谢! 最佳答案 您可以在Hiv

hadoop - 具有 unix 时间戳的 Hive float 据类型

我正在使用float数据类型的hive外部表(错误地)来存储Unix纪元时间戳。当我在配置单元外部表上发出where子句时,它会返回一些奇怪的结果。举个例子。selectevent_timefromtbl_namewhereevent_time=1478649561limit10输出:1478649600任何人都可以帮助我理解这里有什么问题吗? 最佳答案 这与其说是Hive问题,不如说是浮点精度的一般问题。您将看到1478649561(整数类型)在浮点表示中被近似以适应32位Java浮点类型的效果。为了在Hive上下文之外以更简单的

hadoop - Hive修改分区表数据

问题:一列值为空。它应该是'ab'。不幸的是我写了''而不是'ab'。我的表是分区表。有什么办法可以改变吗?我找到了下面的方法。但它似乎效率低下。像我的表一样创建一个临时表使用插入覆盖。从我的旧表中读取数据并写入新表。我正在使用case语句将''更改为'ab'然后将我的临时表更改为原始表。我正在寻找类似更新分区和msck的解决方案。有什么办法吗? 最佳答案 您可以通过这种方式覆盖单个分区:sethive.exec.dynamic.partition=true;sethive.exec.dynamic.partition.mode=n

scala - Impala 正在将时间转换为 GMT 如何避免这种情况

当我查询它通过impala时间以GMT格式显示。不仅我创建的每个时间戳字段的列都转换为GMT格式。如何让它按原样显示时间?或者如何将其转换为est?请帮助进行sql查询或spark/scala代码,我试过这个HowtoconvertaDateStringfromUTCtoSpecificTimeZoneinHIVE?它对我有帮助。 最佳答案 将时间转换为UTC+00:00的不是Impala,而是Hive,但只有在将时间戳保存到Parquet中时才会这样做。这是Hive中的错误:HIVE-12767.当从Parquet文件中读取时间戳

hadoop - 错误 : while processing statement: FAILED: Hive Internal Error: hive. mapred.supports.subdirectories 必须为真

我遇到了一个错误Errorwhileprocessingstatement:FAILED:HiveInternalError:hive.mapred.supports.subdirectoriesmustbetrueifanyoneoffollowingistrue:hive.optimize.listbucketing,mapred.input.dir.recursiveandhive.optimize.union.remove.当我尝试从HDFS目录递归加载数据到hive表时发生此错误我尝试设置以下参数:SETmapred.input.dir.recursive=true;SETh

scala - 'new HiveContext' 需要 X11 显示? com.trend.iwss.jscan?

Spark1.6.2(yarn大师)包名:com.example.spark.Main基本的SparkSQL代码valconf=newSparkConf()conf.setAppName("SparkSQLw/Hive")valsc=newSparkContext(conf)valhiveContext=newHiveContext(sc)importhiveContext.implicits._//valrdd=valdf=rdd.toDF()df.write.saveAsTable("example")还有堆栈跟踪...NoX11DISPLAYvariablewasset,butt