Insert into as select from array和HIVE中的结构表
Insert into as select from array是一种在HIVE中使用的SQL语句，用于将数组中的数据插入到表中。
在HIVE中，结构表是一种特殊类型的表，它的列可以包含复杂的数据类型，如数组、结构体等。结构表可以用于存储具有层次结构的数据，例如JSON数据。
Insert into as select from array语句的作用是将数组中的数据插入到结构表中。具体步骤如下：
- 创建一个结构表，定义表的列和数据类型。
- 准备一个包含数据的数组。
- 使用Insert into as select from array语句，将数组中的数据插入到结构表中。
这个语句的执行过程如下：
- 将数组中的数据按照结构表的列顺序进行匹配。
- 将匹配的数据插入到结构表的对应列中。
- 如果数组中的数据数量与结构表的列数量不匹配，将会抛出错误。
Insert into as select from array语句的优势是可以方便地将数组中的数据插入到结构表中，实现数据的批量插入。它适用于需要将数组数据导入到HIVE结构表中的场景，例如处理JSON数据。
在腾讯云的产品中，可以使用TencentDB for Hive来创建和管理HIVE结构表，详情请参考：https://cloud.tencent.com/product/thive
注意：本答案中没有提及亚马逊AWS、Azure、阿里云、华为云、天翼云、GoDaddy、Namecheap、Google等流行的云计算品牌商，如需了解相关产品和服务，请参考官方文档或咨询相关厂商。
相关·内容
1回答
在Hive中，我可以使用explode函数，但是如何在Impala中这样做呢？
我读过这篇文章，但仍然毫无头绪：
我是这样在Hive中创建表的：
create table tb (arr_col array<string>)
insert into tb select array ('A','B') from (select 'temp') x
我的查询会出现错误：
select tb.arr_col from tb
..in select list returns a complex type 'ARRAY<ST
浏览 0提问于2018-05-22得票数 3
回答已采纳
我在Hive db中有一个表，其中包含数组类型的列，我想将它与内容一起复制到Vertica db。Vertica db的版本是v9.0.1-0，我不能创建数组类型的表。为了复制表，我尝试使用 COPY vertica_schema.destination FROM hive_table_path ON ANY NODE ORC; 但是有一张空桌子。你能帮我把table和covert Hive数组int类型复制到Vertica varchar类型吗？例如，Vertica varchar的值可以是：[1, 1, 1]或{1, 1, 1}。 Vertica目标表init： CREATE TABLE
浏览 9提问于2020-04-17得票数 3
1回答
我有一个旧版本的hive，低于hive 2.0，在这个hive版本中，我创建了一个表：
create table test (int id, string name, values array<string>)
当我添加数据时，我使用这个查询：
insert into table test select 1, 'Sam', array('sql', 'c++', 'c#', 'java')
它可以工作，但我需要在表中加载多个行，例如：
insert into table select (1, '
浏览 1提问于2017-11-09得票数 0
1回答
无法运行配置单元查询
、、、、
我在Cloudera中使用HIVE query创建了一个table，下面是我用来创建名为incremental_tweets的表的DDL。
CREATE EXTERNAL TABLE incremental_tweets (
id BIGINT,
created_at STRING,
source STRING,
favorited BOOLEAN,
retweet_count INT,
retweeted_status STRUCT<
text:STRING,
user:STRUCT<screen_name:STRING,name:STRING>>,
enti
浏览 3提问于2018-05-05得票数 1
5回答
使用Cygwin发行版，我已经安装了Hadoop 0.20.3和Hive 0.11.0。
首先，我不知道如何使用Hive CLI：
hive> show tables;
然后进入，什么也不会发生。我可以使用hive -e/-f.执行查询
然后，我创建了一个表：
CREATE TABLE tweet_table(
tweet STRING
)
COMMENT 'Table of string'
但是如何将数据插入到这个表中呢？我看到了一些INSERT INTO示例，但当我尝试时：
INSERT INTO TABLE tweet_table (tweet) VALUES (&
浏览 3提问于2013-06-07得票数 15
回答已采纳
尽管Impala比Hive快得多，但我们使用Hive是因为它支持复杂(嵌套)数据类型，如数组和映射。
我注意到，像一样，Impala现在支持复杂的数据类型。因为在Impala上运行Hive也是可能的，所以我们可以在Impala上做我们想做的任何事情，但是速度要快得多。这是个好消息！
当我扫描文档时，我看到Impala期望以Parquet格式存储数据。我的数据，以其原始形式，恰好是一个两列CSV，其中第一列是ID，第二列是由管道分隔的字符串数组，例如：
123,ASDFG|SDFGH|DFGHJ|FGHJK
234,QWERT|WERTY|ERTYU
创建了一个Hive表：
CREATE TAB
浏览 1提问于2016-05-15得票数 3
回答已采纳
我将Spark 2.4与Hive Warehouse Connector和Scala 2.11结合使用。目前由Hortonworks提供的蜂巢仓库连接器与Spark2.4不兼容。因此，我从编译了jar文件，这使得它与Spark2.4兼容。
我的Spark应用程序从Kafka输入流读取，并使用Hive Warehouse连接器提供的Hive输出流写入Hive表(ORC格式)。
这是我的火花代码(Scala)：
package example
import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.function
浏览 1提问于2020-04-01得票数 3
3回答
我正在尝试在Hive中创建一个外部表，并在BigQuery中创建另一个表，使用与Spark编写的Avro格式存储在Google Storage中的相同数据。
我使用的是带有Spark 2.2.0、Spark-avro 4.0.0和Hive 2.1.1的Dataproc集群
Avro版本/包之间有相同的差异，但如果我使用Hive创建表，然后使用Spark编写文件，我可以在Hive中看到它们。
但对于BigQuery是不同的，它可以读取Hive Avro文件，但不能读取Spark Avro文件。
错误：
The Apache Avro library failed to parse the hea
浏览 30提问于2017-12-18得票数 1
我在postgresql中创建了一个表：
create table retail_fact( id serial not null, name text);
我有客户表在hive和MySQL中，我想从他们加载数据到PostgreSQL retail_fact表使用Pentaho pdi (通过presto连接)。
另外，当我用Hive和MySQL中的数据加载表时，o希望id在Postgres中自动递增(用更简单的术语。我需要一个sql查询来做同样的事情)。
查询类似于以下内容：
insert into postgresql.rpt.order_fact(
select name from h
浏览 0提问于2017-11-17得票数 1
1回答
配置单元插入重写表
、、、
我是Hive的新手，我想知道insert覆盖是否会覆盖我创建的现有表。我想过滤一个已经创建的表，我们称它为TableA，以便只选择年龄大于18的行。我可以使用insert overwrite table吗？
我正在考虑写一些类似这样的东西：
INSERT OVERWRITE TABLE TableA SELECT a.Age FROM TableA WHERE a.Age > = 18
在我创建的表中有NA条目，但是我假设在我过滤这个表之后，Age列中不会有NAs，对吗？
浏览 3提问于2014-10-03得票数 20
回答已采纳
1回答
假设我有一个hive表，它只有一个类型为array<int>的列。 我可以通过以下方式插入到该表中 INSERT INTO TABLE tablename SELECT array(1); 但是，如果我想在该列中插入一个空的int数组，该怎么办？没弄明白。尝试使用array()、[]、array<int>和array<int>()
浏览 15提问于2019-04-11得票数 1
回答已采纳
我正在编写一个shell脚本，将数据从hive表加载到Apache模式中。
SRC=$1
TGT=$2
SOLR_COLLECTION=$3
SCHEMA=$(python schemaFetch.py ${SRC})
hive -e "ADD JAR /hadoopfs/fs1/dev/solr-hive-serde-3.0.0.jar;
create external table if not exists ${TGT}${SCHEMA}
row format delimited
fields terminated b
浏览 0提问于2018-12-28得票数 4
1回答
我试图将数据从表a插入到表b(两者都是外部表)，基本上依赖于环境的append特性。我也尝试过对托管表执行相同的操作，但其行为是相同的。
不知怎么的，追加对我来说不起作用。另一方面，覆盖功能工作得很好。
例如，以下代码失败
hive> insert table page_view select viewtime, userid, page_url, country from page_view1;
FAILED: Parse Error: line 1:0 cannot recognize input near 'insert' 'table' '
浏览 0提问于2012-06-15得票数 2
回答已采纳
我正在分析自己的tweet，并使用将数据插入到Hive表中。我想找出我的推特上所有两个单词短语的频率作为一个表。输出应该类似于：
phrase frequency
["the","room"] 1248.0
["a","boy"] 1039.0
["rt","to"] 1032.0
["to","ct"] 986.0
现在，我可以对所有的单字短语这样做，我得到的输出如下：
phrase
浏览 3提问于2015-06-28得票数 0
回答已采纳
我在HIVE中有一个主表和暂存表，如下所示
我们有两张分期表，比方说每10分钟就有一张记录。
第一次使用以下语句将暂存表中的数据推送到主表。
select * from Staging table-1
union all
select * from Staging table-2
从下一次开始，只有当主表中显示的timestamp_在暂存过程中小于timestamp_ (即最新记录)时，才应该将其添加到主表中，否则不添加。
也就是说，应该对timestamp_进行比较，只有在最新的情况下才应该添加，否则不会。
所有这些表都是使用Create外部语句和Insert语句创建的。
在如何
浏览 5提问于2021-11-28得票数 0
我运行了一个简单的Spark程序来获取数据从Hive到session使用spark。
scala> spark.sql("select count(1) from firsthivestreamtable").show(100,false)
+--------+
|count(1)|
+--------+
|36 |
+--------+
运行insert语句在Hive表中插入9条新记录(直接在Hive控制台上)。验证Hive表有正确插入的其他行。
hive> select count(1) aa from firsthivestreamtable;
To
浏览 4提问于2019-05-24得票数 1
回答已采纳
3回答
我是Hadoop和Big Data的新手。现在，我在Hive版本Hive 1.1.0-cdh5.4.0 .Facing中遇到了在HIVE表中创建复杂数据类型的一些基本问题。我有一个customer表，它创建为：
create external table if not exists customer_details1 (customerId string, mobileNumber string, address ARRAY <STRUCT<houseNo:string,street1:string>>);
我想使用push data进入这个表，使用INSERT st
浏览 5提问于2015-07-27得票数 0
回答已采纳
1回答
蜂箱抽样问题
、、、
"all_members“是一个蜂窝表，有10m行和1列："membership_nbr”。我想试3000行。这就是我所做的：
hive>create table sample_members as select * from all_members limit 1;
hive>insert overwrite table sample_members select membership_nbr from all_members tablesample(3000 rows);
hive>select count(*) from sample_members;
浏览 3提问于2015-09-30得票数 0
回答已采纳
使用以下命令：
insert overwrite local directory '/my/local/filesystem/directory/path'
select * from Emp;
用Emp的数据覆盖/my/local/filesystem/directory/path中已经存在的全部数据。
我想要的是只是把的数据复制到/my/loca/filesystem/directory/path和上，而不是覆盖，怎么做呢？
以下是我失败的试验：
hive> insert into local directory '/home/cloudera/Desktop
浏览 3提问于2014-03-09得票数 4
1回答
是否可以在Hive中生成无序对(类似于Pig无序对函数？)这个函数是否存在于任何地方？
理想情况下，我希望能够传入一个表，例如：
select * from mytable
array_1
["A","B","C"]
然后回来
select unorderedPairs(array_1) from mytable
["A",B"]
["B","C"]
["C","A"]
浏览 5提问于2014-12-04得票数 1
1回答
根据Hive的文档，如果表T1和T2按相同的列进行存储和排序，那么当我们这样做时
insert overwrite table T2 select * from T1;
不应该创建任何缩减程序，而应该只创建映射器。
但是，我的情况略有不同。我在T1中有列C1和C2，在T2中有C1和C3。
我想做这样的事情：
insert overwrite table T2 select C1, transform(C2) as C3 using app
但是，由于在使用transform时不能使用任何其他列，因此我将代码更改为
insert overwrite table T2 select transfo
浏览 4提问于2017-07-29得票数 1
我试图将数据插入到表中，我得到了以下错误：
hive>CREATE EXTERNAL TABLE IF NOT EXISTS employee
(
EMP_ID BIGINT,
EMP_DESG STRING,
EMP_ADD ARRAY<STRUCT<DNO: STRING,STATE:STRING,CITY:STRING,ZIPCODE:BIGINT>>
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '\t'
stored as textfile;
;
hive>insert overw
浏览 2提问于2013-12-30得票数 0
4回答
我对蜂巢和堆栈溢出完全陌生。我正在尝试创建一个具有复杂数据类型"STRUCT“的表，然后使用Hive中的INSERT INTO TABLE填充它。
我使用以下代码：
CREATE TABLE struct_test
(
address STRUCT<
houseno: STRING
,streetname: STRING
,town: STRING
,postcode: STRING
>
);
IN
浏览 6提问于2016-09-08得票数 8
回答已采纳
我有一个蜂箱桌。
id int
name char(30)
city char(30)
thisday string
# Partition Informatio
浏览 4提问于2017-03-30得票数 2
回答已采纳
我有一个带有结构数组的表：
CREATE TABLE test1(
key_value array<struct<
key:string, string_value:string
>>
);
填充它：
INSERT OVERWRITE TABLE test1
SELECT array(
named_struct('key','key0', 'string_value','some string 0'),
named_struct('key','key1&
浏览 2提问于2016-11-01得票数 1
1回答
我试图使用insert overwrite语句将数据插入到表中，但出现以下错误。 org.apache.spark.sql.AnalysisException: Cannot overwrite a path that is also being read from.; 命令如下 spark.sql("INSERT OVERWRITE TABLE edm_hive SELECT run_number+1 from edm_hive") 我正在尝试使用临时表，存储结果，然后在最终的表中更新，但这也不起作用。 此外，我试图插入记录到表中使用一些变量，但也不起作用。例如： spar
浏览 646提问于2021-04-23得票数 0
1回答
我需要将数据插入到给定的外部表中，该表应该按插入的日期进行分区。我的问题是，Hive是如何处理时间戳生成的？当我像这样为所有插入的记录选择时间戳时： WITH delta_insert AS (
SELECT trg.*, from_unixtime(unix_timestamp()) AS generic_timestamp
FROM target_table trg
)
SELECT *
FROM delta_insert; 对于所有记录，时间戳是否总是相同的，即使查询需要很长时间才能取消？ 或者我应该只选择一个实际的时间戳，然后将它与后来
浏览 65提问于2019-09-24得票数 1
回答已采纳
我有下面3张相同结构的蜂窝表。
drop table default.test1;
CREATE EXTERNAL TABLE `default.test1`(
`c1` string,
浏览 0提问于2017-10-12得票数 1
我试图在spark (scala)中创建一个表，然后从两个现有的数据帧中插入值，但我得到了以下经验： Exception in thread "main" org.apache.spark.sql.AnalysisException: Hive support is required to CREATE Hive TABLE (AS SELECT);;
'CreateTable `stat_type_predicate_percentage`, ErrorIfExists 代码如下： case class stat_type_predicate_percentage
浏览 9提问于2019-03-03得票数 1
我正在使用hive和spark开发一个AWS集群。前一天，当我在hive中的外部表上运行一些ETL pyspark脚本时，我遇到了一个奇怪的情况。 我们有一个控制表，它有一个提取日期列。我们正在根据提取日期过滤来自临时表( hive中的托管表，但位置是s3存储桶)的数据，并将其加载到目标表，该目标表是包含位于s3存储桶中的数据的外部表。我们正在装入如下表格 spark.sql("INSERT OVERWRITE target_table select * from DF_made_from_stage_table") 现在，当我通过spark和直接配置单元CLI检查了目标表的
浏览 20提问于2019-04-28得票数 0
我正在尝试执行包含配置单元查询的bashcript。但是，当我执行脚本时，它显示找不到raw_data和central表。我已经把这些桌子放在蜂巢里了。下面是bash脚本。请告诉我哪里出了问题。
#!/bin/bash
hive -e
"CREATE TEMPORARY FUNCTION rowSequence AS 'com.hive.udf.UDFRowSequence'; "
hive -e "
create table staging (id String,speed String,time String,tim
浏览 2提问于2014-03-14得票数 0
2回答
我正试图在表中插入一个行号。row_number()函数在执行select查询时工作，但当我将它用作INSERT INSERT表查询的一部分时，查询不起作用。我也尝试通过创建表作为选择，但我得到了相同的似乎通用错误。
FAILED: Execution Error, return code 2 from org.apache.hadoop.hive.ql.exec.mr.MapRedTask (state=08S01,code=2)
这是行不通的。
INSERT INTO TABLE tablea
SELECT
column1,
column2,
row_number() over (orde
浏览 1提问于2016-08-24得票数 2
回答已采纳
1回答
我试图在星星之火上在Hive中创建一个分区表，并将其加载到Hive中的其他表中。在加载数据时，我会得到以下错误：
错误: org.apache.hadoop.hive.ql.metadata.Table.ValidationFailureSemanticException:分区规范{cardsuit=，cardcolor=，cardSuit=SPA，cardColor=BLA}包含非分区列；
以下是用于执行任务的命令：
create table if not exists hive_tutorial.hive_table(color string, suit string,value
浏览 0提问于2018-03-29得票数 1
1回答
如何在蜂巢中创建结构的空数组？
、、、、
我在Hive 1.1.0中有一个视图，根据一个条件，它应该返回一个空数组或一个struct<name: string, jobslots: int>数组
这是我的代码：
select
case when <condition>
then array()
else array(struct(t1.name, t1.jobslots))
end
from table t1;
这里的问题是，空数组array()是array<string>类型的。所以当我试图将它插入到一个表中时，它会抛出一
浏览 0提问于2019-05-07得票数 10
1回答
我的表employee_1中有属性id和名称(包含数据)，还有另一个具有相同属性的表employee_2，我希望通过使用+1增加id值来加载数据。
我的With条款如下：
WITH EXP AS (SELECT ALIASNAME.ID+1 ID, ALIASNAME.NAME NAME FROM employee_1 ALIASNAME)
INSERT INTO TABLE employee_2 SELECT * FROM EXP;
执行步骤：
我在HDFS位置有一个文件(带有数据)。
基于hdfs位置创建RDD。
RDD到Hive temp表
从临时表到Hive (empl
浏览 2提问于2017-05-15得票数 7
回答已采纳
我有一个蜂窝表emp_test，如下所示：
'name' as string <br>
'testing' as array< struct < code:string,tests:array < struct < testtype:string,errorline:string>>>>
并具有列值:"name“为"JOHN”，"testing“为
[{"code":"cod1234","tests":[{"testtype
浏览 0提问于2016-09-26得票数 3
1回答
我可以使用下面的查询创建一个配置单元表
CREATE TABLE hbtable(key int, value string)
STORED BY 'org.apache.hadoop.hive.hbase.HBaseStorageHandler'
WITH SERDEPROPERTIES ("hbase.columns.mapping" = ":key,cf1:val")
TBLPROPERTIES ("hbase.table.name" = "xyz");
我使用这个查询将数据插入到表中，但它不起作用，
in
浏览 1提问于2013-06-17得票数 1
3回答
如何在spark中读取orc事务单元表？
我在读取ORC事务性表时遇到了问题，通过spark我得到了hive表的架构，但无法读取实际数据。
请参阅完整的场景：
hive> create table default.Hello(id int,name string) clustered by
(id) into 2 buckets STORED AS ORC TBLPROPERTIES
('transactional'='true');
hive> insert into default.hello values(10,'abc'
浏览 0提问于2018-05-09得票数 4
试图找出一种方法来回填ds分区Hive表的分区。
我知道如何从CLI运行Hive命令。
$HIVE_HOME/bin/hive -e 'select a.col from tab1 a'
我想做的是提供一个不同DS的.txt文件，并为每个DS运行一个新的作业。
$HIVE_HOME/bin/hive -e 'INSERT OVERWRITE PARTITION ds = $DS_VARIABLE_HERE
select a.col from tab1 a where ds = $DS_VARIABLE_H
浏览 1提问于2016-06-27得票数 0
回答已采纳
1回答
我尝试了一些蜂箱优化特性，并遇到了这样的问题:我不能在hive0.12中使用桶映射连接。在我尝试了下面的所有设置之后，只生成了一个哈希表文件，并且这个连接结果只是映射连接。
我有两个表，它们都是rcfile格式的，它们都被扣入10个桶中，它们被创建并填充如下(起源数据是从TPC生成的)：
hive> create table lsm (l_orderkey int, l_partkey int, l_suppkey int, l_linenumber int, l_quantity double, l_extendedprice double, l_discount double, l
浏览 2提问于2014-03-24得票数 0
回答已采纳
我有一个类型的字段
array<struct<id:string>>
在一个在蜂巢中创建的分隔的拼花表中。当我更改该列的类型以在结构部分中添加字段时，当在特定的选择中爆炸数组时，会出现一个错误。以下是详细信息：
创建表语句
CREATE EXTERNAL TABLE `test_table`(
`my_array` array<struct<id:string>>)
PARTITIONED BY (
`ymd` int)
ROW FORMAT SERDE
'org.apache.hadoop.hive.ql.io.
浏览 1提问于2017-05-07得票数 1
回答已采纳
1回答
配置单元外部分区表
、、、
首先，我创建了按代码和日期分区的配置单元外部表
CREATE EXTERNAL TABLE IF NOT EXISTS XYZ
(
ID STRING,
SAL BIGINT,
NAME STRING,
)
PARTITIONED BY (CODE INT,DATE STRING)
ROW FORMAT SERDE 'parquet.hive.serde.ParquetHiveSerDe'
STORED AS
INPUTFORMAT "parquet.hive.DeprecatedParquetInputFormat"
OUTPUTFORMAT "p
浏览 2提问于2014-11-03得票数 6
回答已采纳
1回答
我有一个带有avro模式的表，其中定期插入tweet。
CREATE TABLE tweets
ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.avro.AvroSerDe'
STORED as INPUTFORMAT 'org.apache.hadoop.hive.ql.io.avro.AvroContainerInputFormat'
OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.avro.AvroContainerOutputFormat'
TBLPRO
浏览 4提问于2014-06-11得票数 0
回答已采纳
我有一个Apache Spark(v2.4.2) dataframe，我想把这个dataframe插入一个hive表中。 df = spark.sparkContext.parallelize([["c1",21, 3], ["c1",32,4], ["c2",4,40089], ["c2",439,6889]]).toDF(["c", "n", "v"])
df.createOrReplaceTempView("df") 我创建了一个蜂窝表： spark.sql
浏览 23提问于2019-12-25得票数 2
1回答
我们生产Hadoop集群上的大多数数据集目前都以AVRO + SNAPPY格式存储。我听说了很多关于Parquet的好东西，我想试一试。
我跟随，改变我们的一个ETL来生成Parquet文件，而不是Avro，作为我们减速器的输出。我使用Parquet + Avro模式来生成最终的输出数据，以及snappy编解码器。一切都很好。因此，最终的输出拼板文件应该有与我们原来的Avro文件相同的模式。
现在，我尝试为这些Parquet文件创建一个Hive表。目前，我们使用的IBMParque3.0包含了BigInsight 12和Parquet 1.3.2。基于我们的Avro模式文件，我得出了以下Hiv
浏览 2提问于2015-03-01得票数 0
1回答
我正在用Big创建一个表(比如table1)，并将数据从HDFS加载到table1中。现在，从这个table1中，我需要将数据加载到另一个表中，比如table2，根据特定的条件并在每天的基础上将更多数据附加到这个table2中。每天新的数据将被加载到table1中，相应地，新的数据也应该被加载到table2中。
我尝试过以下方法
First
insert append into table table2 as select uri,localtimestamp,count(*) from table1 group by uri order by uri LIMIT 100;
遇到的SQL异常
浏览 1提问于2015-04-20得票数 0
我可以使用如下所示的HiveContext将数据从我的spark代码插入到Hive表中
val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc)
sqlContext.sql("CREATE TABLE IF NOT EXISTS e360_models.employee(id INT, name STRING, age INT) ROW FORMAT DELIMITED FIELDS TERMINATED BY ',' LINES TERMINATED BY '\n'
浏览 2提问于2016-06-02得票数 4
1回答
我有两个hive表，其中一个表由Java API团队每小时更新一次basic (他们正在调用并将其存储到hive table1中)。现在，我必须聚合最新的数据并将其存储到另一个名为table2的表中(新加载的数据，因为旧数据已聚合并存储)。为此，我使用了以下查询：
set maxtime = select max(lastactivitytimestamp) from table2;
insert into table2 select * from table1 where lastactivitytimestamp > unix_timestamp('${hivevar:max
浏览 1提问于2014-08-18得票数 0
我正在使用Elasticsearch for Hadoop插件，以便通过Hive在Elasticsearch中读取和索引文档。
我遵循了本页面中的文档：
为了使用Hadoop在Elasticsearch中索引文档，您需要在Hive中创建一个正确配置的表。在将数据插入该配置子表时，我遇到了一个问题。
这是我用来编写的表脚本：
CREATE EXTERNAL TABLE es_names_w
(
firstname string,
lastname string
)
STORED BY 'org.elasticsearch.hadoop.hive.EsStorageHandler
浏览 3提问于2015-07-16得票数 0
1回答
我使用以下命令创建了几个临时表
hive.executeUpdate("CREATE TEMPORARY TABLE AS SELECT ...")
在Spark的蜂巢里。我用来检查所有的表
hive.showTables().show()
在我稍后执行的每个查询(都像INSERT INTO ... SELECT ...)和临时表之间的会话中，临时表被不可预知地删除了。
这在HiveQL中不会发生。
有谁有类似的问题吗？
浏览 6提问于2020-04-30得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
