草庐IT

hadoop-annotations

全部标签

java - Hadoop 将输出写入一个 txt 文件

我在考虑如何将Hadoop的输出写入txt文件,而不是写入HDFS。比如我放了下面的代码://CreatethejobspecificationobjectJobjob1=newJob();job1.setJarByClass(Main.class);job1.setJobName("DayMeasurment");//SetupinputandoutputpathsFileInputFormat.addInputPath(job1,newPath(args[0]));FileOutputFormat.setOutputPath(job1,newPath(args[1]));//Set

hadoop - 如何在 Cascading 中读写二进制文件?

我想加载一些二进制格式的文件(例如jpeg,但可以是任何二进制格式),以某种方式对其进行操作并将其写回。我想在hadoop上做那件事,我想在Cascading框架上写它。是否有可用于二进制格式文件的二进制接收器/选项卡?还有其他方法吗?我找不到任何东西。我能想到的唯一选择是也许我应该实现我自己的hadoopInputFormat,它将文件读取为字节数组或javaByteBuffer,但我发现没有内置解决方案很奇怪(因为我确定我我不是第一个遇到这个问题的人)。如果有人有任何指点,将不胜感激 最佳答案 您必须编写自己的HadoopInp

hadoop - 使用flume将数据存储到linux本地目录

是否可以使用flume从oracle获取数据并将其存储在Linux本地文件夹中,而不是hdfs中? 最佳答案 使用“FileRollSink”,您可以将流式数据存储到本地系统。但是Flume不能用于从任何RDMS工具中摄取数据。 关于hadoop-使用flume将数据存储到linux本地目录,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/questions/17718778/

algorithm - 使用 Hadoop 记录关联/聚类

我们的Hadoop集群每天摄取数TB的网络日志。每条日志记录都包含用户IP地址、cookieID等信息。但是,不同的IP地址和cookieID可以对应一个物理用户(家庭/工作计算机等)。我们设计了一个函数来计算任何一对记录的匹配分数,分数越高意味着两条记录对应一个物理用户的概率越高。目标是使用评分函数将所有记录分成可能对应于一个物理用户的组,并通过唯一的组ID(即物理用户ID)标记组中的所有记录。使用Hadoop/Mahout实现此逻辑的最佳方法是什么? 最佳答案 首先,我假设您知道如何链接MapReduce作业。如果没有,请参阅h

hadoop - 亚马逊弹性 map 减少 : Command Line Tools installation Issue?

我是Amazon网络服务的新手,我正在尝试使用命令行界面工具在Amazonelasticmapreduce作业上运行作业流。我遵循了这个developerguide的亚马逊开发者指南中的步骤来自aws。但我还不清楚。如果我执行命令来列出作业流程。显示以下错误。:~/Applications/elastic-mapreduce-ruby$elastic-mapreduce--listError:Requesthasexpired.Timestampdate:2013-07-09T01:13:42-07:00在此先感谢,任何人都可以告诉我为什么我在列出工作流程时遇到上述错误。

Hadoop命令行解释

谁能给我解释一下这个语法,bin/hadoopjarhadoop*examples*.jarwordcount/user/hpuser/testHadoop/user/hpuser/testHadoop-output为什么我们在bin/hadoop之后很快就使用jarhadoop*examples*.jar是什么意思..?wordcount是工作的名称,还是我们要求hadoop计算单词数..?http://www.michael-noll.com/tutorials/running-hadoop-on-ubuntu-linux-single-node-cluster/

hadoop - 为什么 "hadoop -jar"命令只启动本地作业?

我在提交作业时错误地使用了“hadoop-jar”而不是“hadoopjar”。在这种情况下,我的jar包不能提交到集群,只会启动“localjobrunner”,这让我很纳闷。有谁知道原因吗?或者“hadoopjar”和“hadoop-jar”命令之间的区别?谢谢! 最佳答案 /usr/bin/hadoopjar是您的Hadoop的$HADOOP_HOME/bin/hadoop脚本需要作为参数的内容,其中$HADOOP_HOME是您保存hadoop相关文件的位置。hadoop脚本摘录elif["$COMMAND"="jar"];t

hadoop - 在 Hive 中只显示一次 [优雅的方式]

如何使用内置的DateandTimefunctions只显示一次日期在mysql中我们可以做selectcurdate();得到+------------+|curdate()|+------------+|2013-07-23|+------------+尝试selectunixtime();在Hive中给我FAILED:ParseExceptionline1:17mismatchedinput''expectingFROMnear')'infromclause正在做,selectfrom_unixtime(unix_timestamp(),"yyyy-MM-hh")fromabc.

hadoop - 要求澄清一些 HDFS 概念

我不确定这个问题是否属于这里。如果没有,那我道歉。我正在阅读HDFS论文,发现很难理解一些术语。请在下面找到我的问题。1)根据该论文,“HDFS命名空间是文件和目录的层次结构。文件和目录在NameNode上由inode表示,它记录权限、修改和访问时间、命名空间和磁盘空间配额等属性。“inode中的命名空间信息到底是什么意思?是指文件的完整路径吗?因为,前面的语句说“HDFS命名空间是文件和目录的层次结构”。2)根据论文“NameNode维护命名空间树和文件block到DataNode的映射(文件数据的物理位置)。”namespacetree和namespace一样吗?关于namespa

java - Hadoop Map/Reduce WARN mapred.LocalJobRunner : job_local_0001 java. io.EOFException?

在Eclipse6.91中运行Hadoop0.20.2M/R应用。我在执行后收到这些错误和警告:13/07/2416:52:52INFOjvm.JvmMetrics:InitializingJVMMetricswithprocessName=JobTracker,sessionId=13/07/2416:52:52WARNmapred.JobClient:UseGenericOptionsParserforparsingthearguments.ApplicationsshouldimplementToolforthesame.13/07/2416:52:52WARNmapred.Jo