草庐IT

hdfs-agent

全部标签

hadoop - 从 hdfs 中删除文件是否会删除相应的配置单元外部表分区?

我有一个每天动态创建分区的配置单元外部表。为了释放内存空间,我打算从hdfs中删除一些文件。从hdfs中删除文件是否也会删除相应hive表的分区?(或)我们是否需要明确删除配置单元表的分区? 最佳答案 您必须单独删除分区。我建议先使用hive命令删除分区,然后再删除文件。 关于hadoop-从hdfs中删除文件是否会删除相应的配置单元外部表分区?,我们在StackOverflow上找到一个类似的问题: https://stackoverflow.com/que

java - hdfs 显示本地文件列表

我在OSX中安装了Hadoop,运行良好。我的经验是最近的,我正在努力学习更多关于使用Hadoop进行应用程序开发的知识。昨天,当我需要在Hadoop中查找目录和/或文件列表时,我只需键入$hadoopfs-ls而且,它会向我显示集群中的所有内容。今天,它显示了文件系统中的所有本地内容。我必须提供hdfs的确切地址才能获取内容列表,$hadoopfs-lshdfs://localhost:8020/user/myName我的core-site.xml文件和之前一样,hadoop.tmp.dir/usr/local/Cellar/hadoop/hdfs/tmpAbaseforothert

hadoop - 如何设置hdfs中文件的行组大小?

我正在对hdfs中的block大小(dfs.block.size)和行组大小(parquet.block.size)进行一些实验。我在hdfs中有大量数据,我想复制各种block大小和行组大小的数据进行测试。我能够使用不同的block大小复制数据:hdfsdfs-Ddfs.block.size=67108864-Dparquet.block.size=67108864-cp/new_sample_parquet/new_sample_parquet_64M但是只有dfs.block.size被改变了。我正在使用hdfsdfs-stat验证block大小,并使用parquet-tools

bash - 从 HDFS 获取前两个文件

有没有办法使用命令行从HDFS获取前两个文件?我的hadoop版本是2.7.3我在HDFS中有一个包含多个文件的文件夹,另一个应用程序将它们放在那里:/user/Lab01/inpu/ingestionFile1.json/user/Lab01/inpu/ingestionFile2.json/user/Lab01/inpu/ingestionFile3.json/user/Lab01/inpu/ingestionFile4.json我只需要根据时间处理前两个文件,所以如果使用以下内容列出内容:$hdfsdfs-ls-R/user/Lab01/input-rw-------3huser

hadoop - 实时数据集成 Kafka、Hadoop、Avro、HDFS是如何组合在一起的,数据集成有哪些架构

我正在尝试了解实时数据集成的架构以及所有部分如何组合在一起。我尝试在互联网上进行研究,但找不到好的资源。谁能解释一下如何使用例如hadoopkafka和其他组件进行实时数据集成。如果可能,您能否提供使用实时数据集成的位置。任何用例。如果您知道任何资源/教程,如果您分享它们,我将非常高兴提前致谢 最佳答案 如果我可以谦虚地提供我在这方面所做的两次谈话。从概念上讲,关于实时集成我们可以做些什么以及为什么这样做:https://talks.rmoff.net/said0W/the-changing-face-of-etl-event-dr

apache-spark - HDFS 批量分析

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭3年前。Improvethisquestion我通常使用SparkStructuredStreaming、Kafka、HBase等进行实时分析。我没有开发任何批处理分析作业/系统。我想学习批量分析设计和开发。为此,我尝试了解lambda架构但我不知道一些事情。让我们回顾一下假设。我正在实时获取点击流数据。所有数据都发送到Kafka进行摄取。速度层:我们可以使用SparkStreaming/Flink等实时分析点击流数据中的session。然后我们可以

configuration - Hadoop:从 HDFS 映射/归约

我可能错了,但我见过的所有(?)ApacheHadoop示例都将存储在本地文件系统上的文件作为输入(例如org.apache.hadoop.examples.Grep)有没有办法在Hadoop文件系统(HDFS)上加载和保存数据?例如,我使用hadoop-0.19.1/bin/hadoopdfs-put~/local.xlsstored.xls在HDFS上放置了一个名为“stored.xls”的制表符分隔文件。我应该如何配置JobConf来读取它?谢谢。 最佳答案 JobConfconf=newJobConf(getConf(),.

hadoop - 如何告诉 Hadoop 在任务被终止时不要从 HDFS 中删除临时目录?

默认情况下,hadoopmap任务将处理过的记录写入位于${mapred.output.dir}/_temporary/_${taskid}的临时目录中的文件中。这些文件一直放在这里,直到FileCommiter将它们移动到${mapred.output.dir}(任务成功完成后)。我有这样的情况,在maptask的setup()中,我需要在上面提供的临时目录下创建文件,在那里我写了一些稍后在其他地方使用的过程相关数据。但是,当hadoop任务被终止时,临时目录将从HDFS中删除。任何人都知道是否可以告诉Hadoop在任务被终止后不删除该目录,以及如何实现?我想应该提供一些我可以配置的

HDFS 0.22.0 中的 java.io.EOFException

我正在使用以下方法从文件中读取字节:FileSystemfs=config.getHDFS();try{Pathpath=newPath(dirName+'/'+fileName);byte[]bytes=newbyte[(int)fs.getFileStatus(path).getLen()];in=fs.open(path);in.read(bytes);result=newDataInputStream(newByteArrayInputStream(bytes));}catch(Exceptione){e.printStackTrace();if(in!=null){try{i

hadoop/HDFS : Is it possible to write from several processes to the same file?

f.e.创建文件20bytes.第一个进程将从0写入4第二个从5到9等等我需要它来使用我的MapReduce并行创建一个大文件。谢谢。附言也许它还没有实现,但总的来说是可能的——请指出我应该挖掘的地方。 最佳答案 您能否解释一下您计划在创建此文件后对其执行的操作。如果您需要将它从HDFS中取出然后使用它,那么您可以让HadoopM/R创建单独的文件,然后使用像hadoopfs-cat/path/to/output/part*>这样的命令localfile将各个部分组合成一个文件并保存到本地文件系统。否则,您无法让多个写入器打开同一个