草庐IT

joined_table

全部标签

hadoop - Apache 麒麟 : Intermediate table not found

我是麒麟的新手。安装后,我运行sample.sh,然后构建立方体,但得到错误消息:java.io.IOException:NoSuchObjectException(message:default.kylin_intermediate_kylin_sales_cube_desc_19700101000000_20160101000000_38b1539f_1f69_406d_89ed_96f3ca776841tablenotfound)atorg.apache.hive.hcatalog.mapreduce.HCatInputFormat.setInput(HCatInputForma

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

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

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.

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

hadoop - Hbase mapside join-其中一张表没有被读取?从 hbase 中读取正确的结果到 hbase

我正在尝试对位于Hbase中的两个表进行映射连接。我的目的是在hashmap中保留小表的记录并与大表进行比较,一旦匹配,再次将记录写入hbase中的表中。我使用Mapper和Reducer编写了类似的连接操作代码,它运行良好,两个表都在映射器类中被扫描。但是由于reducesidejoin根本没有效率,我只想在mapper端加入表。在下面的代码中,“commentedifblock”只是为了看到它总是返回false并且第一个表(小表)没有被读取。任何提示帮助表示赞赏。我正在使用HDP的沙箱。importjava.util.ArrayList;importjava.util.Arrays

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 - Hive 中的 JOIN 会触发 MapReduce 中的哪种类型的 JOIN?

如果我在hive中有一个使用JOIN的查询,假设在两个表上使用LEFTOUTERJOIN或INNERJOINON任何列,那么我如何知道它在后端MapReduce中转换为哪种类型的JOIN(即Map-sideJOIN或Reduce-sideJOIN)?谢谢。 最佳答案 使用explainselect...并检查计划。它解释了map和reduce究竟会做什么。此外,在执行期间,您可以检查作业跟踪器上的日志并查看映射器或缩减器进程正在做什么。例如下面一段explainplan说是map-sidejoin(注意plan中的MapJoinOp

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

java - Spark join/groupby 数据集需要很多时间

我有2个包含35kk+行的数据集(表)。我尝试通过一些ID来加入(或分组依据)这个数据集。(通常是一对一)但是这个操作需要很多时间:25+h。过滤器只能正常工作:~20分钟。环境:emr-5.3.1Hadoop分布:亚马逊应用:Ganglia3.7.2、Spark2.1.0、Zeppelin0.6.2实例类型:m3.xlarge代码(groupBy):Datasetdataset=.......groupBy("id").agg(functions.min("date")).withColumnRenamed("min(date)","minDate")代码(加入):....join(