草庐IT

import-all-table

全部标签

hadoop - 如何在 S3 上指定 Hive EXTERNAL TABLE 数据的文件大小

我可以在Hive中创建一个EXTERNALTABLE,其中数据以Gzip格式存储在S3存储桶中。但是,这些文件非常大(每个超过6GB)。能否配置Hive使EXTERNALTABLE中的文件具有特定大小,比如512MB? 最佳答案 这对我来说听起来很奇怪,默认情况下,我的外部表通常有大约300MB的文件大小。无论如何,最简单的调整方法是使用PARTITIONBY键(可能是基于时间戳的东西),这将强制文件变小,并且具有使数据更容易的附加优势查询。此外,您应该考虑使用像Parquet这样的可拆分格式,因为这样文件大小就不再重要了。

Hadoop MapReduce : How to ensure multiple tasks are executed in parallel among all nodes

我在HDFS中有一个任务列表文件,任务列表受CPU限制,将在带有HadoopMapReduce(仅限Map)的小型5节点集群中执行。例如,任务列表文件包含10行,每行对应一个任务命令。每个任务的执行都需要很长时间,所以在所有5个节点上并行执行列出的10个任务肯定更高效。但是由于任务列表文件很小,这个数据block很可能只位于一个节点上,所以根据数据局部性原则,只有该节点会执行所有这10个任务。有什么解决方案可以确保所有10个任务在所有5个节点上并行执行? 最佳答案 默认情况下,mapreduce将在每次拆分时运行一个映射器。拆分是一

hadoop - 配置单元 hadoop : selecting data from table getting error

我在Hive中创建了一个外部表后,我想知道推文的数量,所以我写了下面的查询,但是我得到了这个错误,请问如何解决这个问题,这是mapred-site.xml的配置mapred.job.trackerlocalhost:8021hive>selectcount(*)fromtweet;TotalMapReducejobs=1LaunchingJob1outof1Numberofreducetasksdeterminedatcompiletime:1Inordertochangetheaverageloadforareducer(inbytes):sethive.exec.reducers.

sql - Hive 必须使用 UNION ALL 指定实际数据源(FROM)

我对HiveUNIONALL规范有疑问。此查询是一个有效的Hive查询。SELECT1asid,'Tom'asname此作业按预期返回正确的一条记录结果。+----------+----------------+|id|name|+----------+----------------+|1|Tom|+----------+----------------+但是当使用UNIONALL提交此查询时,我遇到了一个问题。SELECTid,nameFROMmembersUNIONALLSELECT1asid,'Tom'asname,此SQL产生Error:java.lang.IllegalAr

hadoop - 如何在 hive create table "TBLPROPERTIES"中引用 HBase 命名空间

我正在尝试使用HBase表('test_table)作为源创建Hive外部表。HBase表是在HBase命名空间“test_namespace”下创建的。在应用程序的其他部分,我使用以下语法访问表test_namespace:test_table或hbase://test_namespace:test_table按照同样的方法我创建了一个配置单元脚本CREATEEXTERNALTABLEIFNOTEXISTSTEST_INDIVIDUAL(keystring,teststring,photostring,locationstring)STOREDBY'org.apache.hadoop

oracle - Sqoop Oracle Import 不创建表

我想使用Sqoop将数据从Oracle数据库导入到Hive。我希望Sqoop将表创建到目标Hive数据库中。我把OracleJDBC(ojdbc6.jar)放到了Sqooplib目录下。我尝试了这两种方法,但都不起作用。sqoopimport\--connectjdbc:oracle:thin:@${DB_HOST}:${DB_PORT}:${DB_NAME}\--username${DB_USER}\--password${DB_PWD}\--table${INPUT_TABLE}\--hcatalog-home/usr/hdp/current/hive-webhcat\--hcat

sql - 如何正确格式化 "select top 1000 * from schema.table_name;"以在 Toad 4 Apache Hadoop 中工作?

尝试在Toad4ApacheHadoop(Hive)中运行它,它无法识别top函数。我该如何重新格式化?selecttop1000*fromFinance.ACCT_LIST 最佳答案 您可以使用LIMIT:select*fromFinance.ACCT_LISTorderbysomecolumnlimit1000如果你想得到一组一致的行,你应该添加一个orderby子句。 关于sql-如何正确格式化"selecttop1000*fromschema.table_name;"以在Toad

hadoop - Sqoop如何导入表table1, table2, table3?

一位雇主问如何在单数据库和多数据库中导入表1和表2、表3? 最佳答案 你可以试试:多个表:尝试使用“import-all-tables”和逗号分隔的“exclude-tables”选项:sqoopimport-all-tables--connectjdbc:mysql://localhost/sqoop--usernameroot--passwordhadoop--target-dir'/sqoop'--exclude-tablestable1,table2多表:在Sqoop1.99中有一个用于执行自定义SQL查询的选项-您可以检查

hadoop - SAP 沃拉 : Not able to add Vora table as Virtual table via Smart Data Access in HANA Studio

我正在使用带有HANAExpress2SP01的虚拟机。在一个小型测试集群上,我安装了HortonworksDataPlatform2.6和Spark1.6.3,还添加了HANAVora1.4和SparkController2.1。我遵循了SAPVora安装和管理指南:https://help.sap.com/http.svc/rc/f09ec811fe634f588647c342cac84c38/1.4/en-US/SAP_Vora_Installation_Admin_Guide_1.4_en.pdf直到第2.9章。一切正常,但Zeppelin部分与%jdbc解释器:%jdbcse

mysql - sqoop import 为正确的 sql 查询提供了错误的结果

我在MySQL中使用如下查询。我得到了我想要的结果。selectTABLE_NAME,count(column_name)asno_of_columnsfrominformation_schema.columnswhereTABLE_SCHEMA='testing'andTABLE_NAMENOTREGEXP'temp|bkup|RemoveMe|test'groupbyTABLE_NAME当我在sqoop导入语句中使用相同的查询时,结果不同。sqoop导入语句如下。sqoopimport--connectjdbc:mysql://xxxxxx:3306/information_sch