spark RegisterDriver 源码

spark RegisterDriver 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/mesos/RegisterDriver.java
阅读全文

spark UploadBlockStream 源码

spark UploadBlockStream 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/UploadBlockStream.java
阅读全文

spark UploadBlock 源码

spark UploadBlock 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/UploadBlock.java
阅读全文

spark StreamHandle 源码

spark StreamHandle 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/StreamHandle.java
阅读全文

spark RemoveBlocks 源码

spark RemoveBlocks 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/RemoveBlocks.java
阅读全文

spark RegisterExecutor 源码

spark RegisterExecutor 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/RegisterExecutor.java
阅读全文

spark PushBlockStream 源码

spark PushBlockStream 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/PushBlockStream.java
阅读全文

spark OpenBlocks 源码

spark OpenBlocks 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/OpenBlocks.java
阅读全文

spark MergeStatuses 源码

spark MergeStatuses 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/MergeStatuses.java
阅读全文

spark LocalDirsForExecutors 源码

spark LocalDirsForExecutors 代码 文件路径:/common/network-shuffle/src/main/java/org/apache/spark/network/shuffle/protocol/LocalDirsForExecutors.java
阅读全文