草庐IT

KEY_NAME

全部标签

scala - Hadoop 端口 : fs. default.name

我有点懵。我看到的几乎所有Hadoop安装“如何”指定的core-site.xml都将fs.default.name设置为9000fs.default.namehdfs://192.168.0.141:9000但是,下面的代码valconf=neworg.apache.hadoop.conf.Configuration()valfs=org.apache.hadoop.fs.FileSystem.get(newjava.net.URI("hdfs://192.168.0.141/"),conf)给我一​​个java.net.ConnectException:指定无法连接到端口8020。

Hadoop MapReduce : Two values as key in Mapper-Reducer

如何使用两个组件构建key?这样做的原因是我有一个无向图。如果A和B通过通信关联(方向无关),则两个节点A和B之间存在边。此通信有一个数字参数。所以我想实现的是有一个将A和B组合在一起作为一个集合的key,这样A到B和B到A的通信就可以被认为是等价的,并且可以被加起来得到统计数据说:AB5BA10键在语义上应该是“A或B在一起”,这样包含A和B作为键的集合的值应该是5+10=15。wordcount示例将特定单词作为关键字。就我而言,我想将包含两个组件的集合作为关键。在map和reduce阶段,只要满足AtoB或BtoA就求和。谢谢! 最佳答案

php - HBase - 如何根据key-timestamp-id查询?

全部-HBase的新手,我终于能够实际获取我曾经存储在MySQL中的数据(大约5000万行)并将其插入到我的HBase表中。我现在正尝试根据键查询此数据,但遇到了一些问题。基本上我有一个构造如下的key:objectname-createdtime-customerid现在我需要根据对象名称和创建时间的范围进行查询,有人知道我该怎么做吗?(我正在使用PHP/Thrift,但我不需要它作为对此的具体答案)我可以查询是否知道确切的行/键,我现在只需要知道如何为中间属性指定一个范围。提前致谢! 最佳答案 使用开始行是键为objectnam

在没有 key 的情况下加入两个相等的数据集

我想使用Hadoop连接两个具有相同记录数但不带行号的文件。例如A.txtaxxbycz和B.txt1r2s3d加入后我需要拥有axx1rby2s3dcz这是IOW完美的并排连接。我不知道如何在Hadoop中执行此操作,我相信我需要对两个文件进行初始传递以附加行号?利用Pig和/或map/reduce技巧的各种组合的答案都很好。 最佳答案 这篇文章给了你一个提示:SOPOSTaboutspecialinputformat输入格式可以生成行号作为键,而不是给出字节偏移量。这样你就可以简单地使用一个单元映射器(只发出键值)并在reduc

【读点论文】PICK Processing Key Information Extraction from Documents...实体关系抽取,从图像数据抽取具有自然语义信息的结构化数据

PICK:ProcessingKeyInformationExtractionfromDocumentsusingImprovedGraphLearning-ConvolutionalNetworks研究问题定义关键信息抽取(KeyInformationExtraction,KIE)指的是是从文本或者图像中,抽取出关键的信息。针对文档图像的关键信息抽取任务作为OCR的下游任务,存在非常多的实际应用场景,如表单识别、车票信息抽取、身份证信息抽取等。然而,使用人力从这些文档图像中提取或者收集关键信息耗时费力,怎样自动化融合图像中的视觉、布局、文字等特征并完成关键信息抽取是一个价值与挑战并存的问题。

hadoop - 即使使用 Hadoop 自定义分区程序,不同的 key 也会进入 1 个文件

我的一期快用完了。我正在尝试从Reducer获取不同key的不同文件。分区器publicclasscustomPartitionerextendsPartitionerimplementsConfigurable{privateConfigurationconfiguration;@OverridepublicConfigurationgetConf(){returnconfiguration;}publicintgetPartition(Textkey,NullWritablevalue,intnumPartitions){returnMath.abs(key.hashCode())

hadoop - MapReduce 与 Hadoop : Type mismatch in key from map

我正在运行一个简单的wordcount程序,但出现以下错误:Typemismatchinkeyfrommap:expectedorg.apache.hadoop.io.Text,receivedorg.apache.hadoop.io.LongWritable这是什么意思,我该如何纠正? 最佳答案 您可以在主函数中使用以下任一行:conf.setMapOutputKeyClass(Text.class);conf.setMapOutputValueClass(IntWritable.class);假设您正在使用JobConfconf

hadoop - Hive 没有完全遵守 core-site.xml 中的 fs.default.name/fs.defaultFS 值

我在一台名为hadoop的机器上安装了NameNode服务。core-site.xml文件的fs.defaultFS(等同于fs.default.name)设置如下:fs.defaultFShdfs://hadoop:8020我有一个名为test_table的非常简单的表,它当前存在于HDFS上的Hive服务器中。即存放在/user/hive/warehouse/test_table下。它是在Hive中使用一个非常简单的命令创建的:CREATETABLEnew_table(record_idINT);如果我尝试将数据加载到本地表中(即使用LOADDATALOCAL),一切都会按预期进行

amazon-ec2 - 使用 s3 作为 fs.default.name 或 HDFS?

我正在EC2上设置Hadoop集群,我想知道如何进行DFS。我所有的数据目前都在s3中,所有map/reduce应用程序都使用s3文件路径来访问数据。现在我一直在研究Amazon的EMR是如何设置的,它似乎为每个作业流设置了一个名称节点和数据节点。现在我想知道我是否真的需要那样做,或者我是否可以只使用s3(n)作为DFS?如果这样做,有什么缺点吗?谢谢! 最佳答案 为了使用S3而不是HDFS,core-site.xml中的fs.name.default需要指向您的存储桶:fs.default.names3n://your-bucke

hadoop - 使用更新 key 的 Sqoop 导出

我必须将HDFS文件导出到MySql。假设我的HDFS文件是:1,abcd,232,efgh,243,ijkl,254,mnop,265,qrst,27然后说我的Mysql数据库模式是:+-----+-----+-------------+|ID|AGE|NAME|+-----+-----+-------------+||||+-----+-----+-------------+当我使用以下Sqoop命令插入时:sqoopexport\--connectjdbc:mysql://localhost/DBNAME\--usernameroot\--passwordroot\--expor