草庐IT

multiple-tables

全部标签

hadoop - HIVE 中 ALTER TABLE 命令中的 CONCATENATE 如何工作

我想了解HIVE中的ALTERTABLECONCATENATE究竟是如何工作的。我看到了这个链接HowdoesHive'altertableconcatenate'work?但我从这个链接得到的只是对于ORC文件,合并发生在strip级别。我正在寻找有关CONCATENATE工作原理的详细说明。例如,我最初在HDFS中有500个小的ORC文件。我运行了HiveALTERTABLECONCATENATE并将文件合并为27个更大的文件。随后运行的CONCATENATE将文件数量减少到16个,最后我得到了两个大文件。(使用版本Hive0.12)所以我想了解CONCATENATE的具体工作原理

sql - Hive-我如何使用原始表中的分区 "create table as select.."?

我需要从我们的配置单元dlk创建一个“工作表”。虽然我可以使用:createtablemy_tableasselect*fromdlk.big_table很好,我在从原始“big_table”继承分区(属性day、month和year)或只是创建来自这些属性的新属性。搜索网络并没有真正帮助我回答这个问题-所有“教程”或解决方案都涉及createasselect或创建分区,而不是两者。这里有人可以帮忙吗? 最佳答案 不支持创建分区表作为选择。您可以分两步完成:像dlk.big_table一样创建表my_table;这将创建具有相同架构

java - 带有 Java 的 Apache Spark : Launching multiple app requests simultaneously

我们将spark与java结合使用,并创建了JavaRESTapi来调用我们的spark代码。在调用RESTurl时,我的java方法将创建SparkSession和Context以继续计算。这对于单个请求工作正常,但同时对于多个请求,我们收到与SparkContexts相关的问题:同一驱动程序JVM中的多个SparkContexts还尝试使用:conf.set("spark.driver.allowMultipleContexts","true");请建议如何管理同步spark请求的Spark上下文。或者任何其他处理这种情况的方法? 最佳答案

Hadoop 配置单元 SQL : Create External Table from an oddly formatted file

目前我有一个初始系统在工作,它读取一个文件,每行格式如下所示:REVISION1230364918Anarchism2005-12-06T17:44:47ZRJII141644使用此代码:CREATEEXTERNALTABLEmytable(typeSTRING,aidBIGINT,ridBIGINT,titleSTRING,tsSTRING,unameSTRING,uidSTRING)ROWFORMATDELIMITEDFIELDSTERMINATEDBY''STOREDASTEXTFILELOCATION'/my/local/path/to/file';但是现在我有一个文件,每一行

hadoop - 在 Cassandra 中将一张大 table 分成多个小 table ?

来自MongoDB的背景,我们倾向于基于周将数据的摄取分成多个集合(其中包含相同类型的数据)。这完全取决于我们索引的性能。考虑在Cassandra中对同一概念建模,是否值得做同样的事情并根据时间段创建多个表?所以也许每周一次。是否有任何性能提升?由于我对Hadoop集成的研究,我也问这个问题,我可能只想映射/减少特定几周内有值(value)的数据,而不是所有数据,据我所知,这是最好的方法隔离我们要映射的数据。在此先感谢您对此的任何意见。 最佳答案 这不是必须的。但是,请务必注意,您不应在Cassandra中使用二级索引,您应该对数据

apache - Hbase 元数据错误 "tables no found"

我在hbase(hdfs)表中有一些数据,我将其复制到我的本地文件系统。然后在我的第二台机器上,我使用copyFromLocalhadoop命令将数据从本地复制到hdfs。现在,当我在hbase中(在第二台机器上)运行命令“list”时。显示没有表。我将表复制到hdfs中的一个目录中,该目录是hbase的数据目录,因此该表应该出现在hbase中。问题出在哪里?在两台机器上,hbase和hadoop的版本相同。如何将hbase表从一个集群复制到第二个集群? 最佳答案 已经有一些工具可用于管理此类任务(全部记录在此处:http://hb

hadoop - HDFS 联邦 : Submission of Map Reduce jobs among multiple Name nodes

根据HdfsFederation上的Apache文档,系统可通过多个名称节点的联合进行隔离扩展。多个名称节点/namespace为了横向扩展名称服务,联邦使用多个独立的名称节点/namespace。名称节点是联合的;Namenodes是独立的,不需要相互协调。Datanodes被所有Namenodes用作block的公共(public)存储。我唯一的疑问:我没有看到名称节点之间有任何中央协调器,因为所有节点都在运行隔离。对如何提交和处理作业感到困惑。1)如果我提交一个map-reduce作业,哪个名称节点将处理它?或者2)客户端是否应该知道必须为其提交作业的名称节点?如果客户端不知道哪

mysql - 插入导致异常 ParseException 行 1 :12 missing TABLE at 'table_name' near '<EOF>' 的 Select 命令

我刚接触hadoop和hive2天。所以,我的理解是非常基础的。我有一个可能很愚蠢的问题。问题:我有一个配置单元外部表ABC,并创建了一个类似于ABC_TEST表的示例测试表。我的目标是根据select子句将ABC的某些内容复制到ABC_TEST。所以我使用以下命令创建了ABC_TEST:CREATETABLEABC_TESTLIKEABC;问题是:1)此ABC_TEST不是外部表。2)使用Desc命令,ABC_TEST的LOCATION内容类似于hdfs://somepath/somdbname.db/ABC_TEST-->Oncommand"hadoopfs-lshdfs://so

hadoop - 谷歌大查询 : Incompatible table partitioning specification

从未分区的临时表向按天分区的最终表提交复制作业时,我收到了cause:java.io.IOException:ErrorMessage:Incompatibletablepartitioningspecification.Expectspartitioningspecificationinterval(type:day),butinputpartitioningspecificationisnone;那么复制作业到分区表的输入表是否有任何限制,如何克服这些限制?使用Load作业在hadoopbigquery-connector类中创建临时表。而JobConfigurationLoad根

sql-server - Sqoop import-all-tables 命令的问题

我正在尝试使用Sqoop将多个SQLServer数据库中的所有表导入HDFS。我正在使用ClouderaCDH5.7。所以我输入以下命令:sqoopimport-all-tables--connect"jdbc:sqlserver://X.X.X.X:1433;database=FEPDB"--usernameXXXXX--passwordXXXXX--hive-import它运行成功,但“FEPDB”数据库中的所有表都没有被导入。我没有在HDFS的配置单元目录中找到它们,也没有在列出Hive中存在的所有表时找到它们。所以我尝试将所有表导入HDFS中的一个目录,然后创建hive表。我给