我正在尝试在Hbase上(在指定的集群上)创建一个表，我尝试了以下代码:importorg.apache.hadoop.hbase.client.{HTable,Put,HBaseAdmin}importorg.apache.hadoop.hbase.util.Bytesimportorg.apache.hadoop.hbase.mapreduce.TableInputFormatimportorg.apache.hadoop.hbase.{HBaseConfiguration,HTableDescriptor,HColumnDescriptor}objectImportData{va
我正在运行Hadoop2.8.1和Hive2.3.0我正在尝试从Hive中创建的表中读取值当前的异常是java.lang.ClassNotFoundException:org.apache.hadoop.tracing.SpanReceiverHostatjava.net.URLClassLoader.findClass(URLClassLoader.java:381)atjava.lang.ClassLoader.loadClass(ClassLoader.java:424)atsun.misc.Launcher$AppClassLoader.loadClass(Launcher.j
我正在尝试使用HiveUDF和UDAF，到目前为止，我在VM上使用命令行中的maven已经很好地做到了这一点，该VM基本上是由知识渊博的人设置得很好。我是Java的新手(项目，与其说是语言)，但我至少可以看到我当前的问题是什么。我不知道它为什么会发生以及如何解决它。所以...我的问题是无论出于何种原因，在运行时mvninstall编译器找不到任何过去的类/org/apache/hadoop/hive/ql/exec它可以找到“exec”文件夹中的所有类，但在“exec”中嵌套的任何子文件夹中找不到任何类。我不明白为什么会这样。这是我的POM文件。org.apache.maven.plu
我下面的代码是使用spark从配置单元表中读取数据。该表中有1亿条记录。当我在我的Rdd中选择这么多记录并尝试执行result.show()时，它给出了严重的问题异常。我基本上想通过从该表中为1亿条记录集选择几列来在其他表中插入记录。这是我的代码:importorg.apache.spark.sql.functions._importorg.apache.spark.sql._valsqlContext=neworg.apache.spark.sql.SQLContext(sc)valhiveContext=neworg.apache.spark.sql.hive.HiveContex
我是Hadoop/Giraph和Java的新手。作为任务的一部分，我在其上下载了ClouderaQuickstartVM和Giraph。我正在使用这本书，名为“使用ApacheGiraph进行实用图形分析；作者:Shaposhnik、Roman、Martella、Claudio、Logothetis、Dionysios”，我尝试从中运行第111页上的第一个示例(TwitterFollowershipGraph)。尝试在集群2.6.0-mr1-cdh5.12.0上使用hadoop版本运行更改后的pom.xml文件时，请发现以下错误`[cloudera@quickstartfirst]$m
我想在Hive表的特定位置添加一个新列。当我添加新列时，它会转到最后一个位置。 最佳答案 您需要重新创建表。如果表是外部表并且数据已经包含新列，则发出drop和createtable语句。一般的解决方案是:1.createnew_table...;2.insertoverwritenew_tableselectfromold_table;3.dropold_table;4.alternew_tablerenametoold_table;此外，如果数据文件已经在某个位置包含新列，您可以1.Altertableaddcolumn使用此示
我有一个Hortonworks沙盒。我运行了一个Atlas应用程序。已经有来自Hive的所有数据库、表和列。我在Hive中添加了一个新表，但它没有自动出现在Atlas中。如何更新Atlas元数据？Atlas是否有任何好的教程显示如何开始，例如如何从现有集群导入数据？问候帕维尔 最佳答案 所有元数据都会自动报告给Atlas。Hive应该与负责此类报告的atlashook一起运行。如果您将hive作为hortonworks平台的一部分安装，它应该在那里，否则ApacheAtlas文档中有关于如何安装HiveHook的明确说明(这是一种额
我在cloudera上安装apachephoenix时遇到问题。我提到了http://crazyadmins.com/install-and-configure-apache-phoenix-on-cloudera-hadoop-cdh5/和许多其他采用相同方法的人。我的cloudera版本是5.5。我在运行命令时遇到错误:./psql.py:2181../examples/WEB_STAT.sql../examples/WEB_STAT.csv../examples/WEB_STAT_QUERIES.sqlorg.apache.phoenix.exception.PhoenixIOE
我是zeppelin的新手，正在尝试在我的系统上设置zeppelin。到目前为止，我已经完成了以下步骤:从here下载飞艇在我的系统环境变量中设置JAVA_HOME。转到zeppelin-0.7.3-bin-all\bin并运行zeppelin.cmd能够在http://localhost:8090看到zeppelin-ui当我尝试运行zeppelintutotial->BasicFeatures(spark)中提到的loaddataintotable程序时，它抛出以下错误java.lang.NullPointerExceptionatorg.apache.zeppelin.spark
我想了解Apachespark中的惰性求值。我的理解是:假设我在hardrive中有文本文件。步骤:1)首先我将创建RDD1，它现在只是一个数据定义。(现在没有数据加载到内存中)2)我在RDD1上应用了一些转换逻辑并创建了RDD2，这里RDD2仍然是数据定义(仍然没有数据加载到内存中)3)然后我在RDD2上应用过滤器并创建RDD3(仍然没有数据加载到内存中，RDD3也是一个数据定义)4)我执行了一个操作，以便我可以在文本文件中获得RDD3输出。因此，当我执行此操作时，我期望从内存中输出一些内容，然后spark将数据加载到内存中，创建RDD1、2和3并产生输出。所以spark中RDD的惰
