草庐IT

hadoop_simple

全部标签

hadoop - 使用 cygwin 在 Windows 中安装 pig

我在windowsxp中使用cygwin安装pig-0.11.1。我提取了我的pig_home文件夹并将其放置在cygwin的用户目录中。当我尝试在提示符下命令./pighelp时,它显示以下错误。其中:(/usr/local/bin:/usr/bin:/cygdrive/c/ProgramFiles/Java/jdk1.6.0_31/bin:/home/sunil/pig-0.11.1/bin中没有hadoop)cygpath:无法创建C:\cygwin\home\sunil\pig-0.11.1\logs的短名称找不到pig.jar。做'antjar',然后再试一次我能得到一些关于

file - Avro hadoop随机访问文件

我想知道Avro是否支持随机访问或查询。例如,如果我创建一个名为B.avro的Avro文件,其中包含2个二进制文件X.png和Y.png,是否可以直接访问Y.png?无需遍历整个文件,如果有一种方法可以直接使用文件key访问文件内容,那就太好了。如果没有,是否有任何其他数据结构允许我在hadoop环境sequenceFiles,HAR中执行此操作?我基本上使用Avro作为处理hadoop中大量小文件的一种方式,但我也想查询这些文件,这使得将它们存储在更大的集合中变得困难。谢谢。 最佳答案 我不知道是否有任何OOTB特性可以让我们通过

hadoop - 如何设置首选项以在 Eclipse 中运行 PIG 脚本?

我在我的eclipse中下载并安装了pigpen插件,我按照thislink中的步骤操作)但是当我设置Pig的ConfigurationPath时有点困惑。谁能告诉我如何设置首选项以在eclipse中运行pig脚本。我很累,但没有正常工作。 最佳答案 您是否使用UnixBox来运行Eclipse?如果答案是肯定的,那么你可以让它工作。如果你在Windows上工作并使用SSH客户端连接到Unix框,恐怕它不会工作(至少按照你帖子中提到的链接) 关于hadoop-如何设置首选项以在Eclip

hadoop - 当多个查询需要从数据节点访问相同的数据时会发生什么?

当我们同时触发多个查询并且2个查询需要访问相同的数据时。MapReduce中发生了什么?假设一个节点中只有1个数据副本,并且2个查询需要从同一数据节点访问数据。发生什么了?其中一个查询是在队列中等待还是同时处理? 最佳答案 查询会被同时处理,当一个队列到来时,会启动一个新的线程来处理,可以看源码here. 关于hadoop-当多个查询需要从数据节点访问相同的数据时会发生什么?,我们在StackOverflow上找到一个类似的问题: https://stacko

ubuntu - 安装配置单元后的 Hadoop(本地和主机目标不匹配)

我在我的笔记本电脑上安装了Hadoop2.2作为单节点集群运行ubuntu并运行字数统计示例。之后我安装了Hive并且Hadoop开始出现错误,即hdfsdfs-lsthrowsIOException:localhostis"utbuntu/127.0.1.1anddestinationhostislocalhost:9000"我在我的主机文件中找到了以下两个条目127.0.0.1localhost127.0.1.1ubuntu#andsomeIPv6entries...我的问题是为什么配置hive后报错,解决方法是什么?非常感谢任何帮助。谢谢! 最佳答案

java - HBase on Tomcat7 安装错误: Could not initialize class org. apache.hadoop.security.ShellBasedUnixGroupsMapping

我正在尝试通过tomcatservlet访问AWSEMR主节点上的HBase。我在tomcatservletget请求上有这段代码:Configurationconf=HBaseConfiguration.create();conf.setInt("timeout",120000);conf.set("hbase.master","*"+hbaseHost+":9000*");conf.set(HBASE_CONFIGURATION_ZOOKEEPER_QUORUM,hbaseZookeeperQuorum);conf.set(HBASE_CONFIGURATION_ZOOKEEPER

Hadoop:多用户伪分布式模式

在此先感谢您的帮助。我使用根用户凭据在伪分布式模式下设置了Hadoop。我想为多个用户提供访问权限(比如hadoop1、hadoop2等),以便能够在此集群上提交和运行MapReduce作业。我们如何完成这项工作?到目前为止我做了什么?>-SetupHadooptoruninPseudo-distributedmode>-Used"root"usercredentialstosetthisup.>-Addedusershadoop1andhadoop2toagroupcalled"hadoop".>-Addedrootalsotobepartofthegroup"hadoop".>-C

hadoop序列文件集合

reducer(带有一个Text键和一个IterableMapWritable值)如何将其所有Map输出到一个序列文件,以便保留其键上的分组?例如,假设映射器将记录发送到缩减器,如下所示:,,}>,,,}>,,}>我希望序列文件写成:key="dog"value={{,,},{,,}}key="cat"value={{,,,}}我猜想我需要创建一个实现可写的自定义值输出类,但我不确定该怎么做,因为据我所知,集合并不真正处理序列文件。我想这样做,以便下一个map/reduce阶段将作为一个单元读入与每个键关联的所有Map。TIA, 最佳答案

hadoop - 如何使用 PIG 在 Hadoop 中给定阈值进行连接

假设我有一个具有以下架构的数据集:ItemName(String),Length(long)我需要根据长度找到重复项。这在PIG中很容易做到:raw_data=LOAD...datasetgrouped=GROUPraw_databylengthitems=FOREACHgroupedGENERATECOUNT(raw_data)ascount,raw_data.name;dups=FILTERitemsBYcount>1;STOREdups....上面找到了完全相同的重复项。给定以下设置:一、100二、105三、100它会输出2,(a,c)现在我需要使用阈值查找重复项。例如,如果项目

java - 在 hadoop 的提示符下创建和运行可运行的 jar

我想尝试一下Hadoop包中提供的示例WordCount程序。因此,我在eclipse中创建了一个自定义项目,并将整个wordcount代码复制到我的自定义类中。我还在项目的构建路径中包含了所有外部Hadoopjar。最后,尝试创建一个可运行的JAR:文件->导出->Java选项卡->可运行的JAR。但是,我在创建jar时遇到错误:Exportedwithcompilewarnings:custom_project/src/custom_package/CustomWordCount.java尽管代码没有错误,但jar的创建给我带来了问题。如何解决这个问题?