我对Spark是个新手。我对spark加载输入数据的方式感到有点困惑。例如:假设我有一个1TB的文件,我有一个spark集群,每个集群有3个节点(4cpu、8 TB ram和10 TB磁盘空间)。那么spark是如何在这些节点之间划分数据的呢?它是只加载文件的元数据,还是尝试加载足够的元数据以适应集群并在迭代中处理文件?
发布于 2018-02-25 04:23:11
文件存储在HDFS中,而不是spark中。
如果复制系数为3,您将需要3 TB的Hardisk。
请单击该链接以更好地了解http://bytepadding.com/big-data/spark/understanding-spark-through-map-reduce/
https://stackoverflow.com/questions/48967063
复制相似问题