textFile:
defaultParallelism=max(totalCoreCount,2)
min(defaultParallelism,2)
parallelize:
max(totalCoreCount,2)
假设是4核的,那么:
对于textFile:
defaultParallelism=max(4,2)=4
分区数=min(defaultParallelism,2)=2
对于parallelize:
分区数=max(4,2)=4
本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。
我来说两句