File tree Expand file tree Collapse file tree 4 files changed +12
-0
lines changed
network/shuffle/src/main/java/org/apache/spark/network/shuffle/protocol Expand file tree Collapse file tree 4 files changed +12
-0
lines changed Original file line number Diff line number Diff line change 24
24
25
25
import org .apache .spark .network .protocol .Encoders ;
26
26
27
+ // Needed by ScalaDoc. See SPARK-7726
28
+ import static org .apache .spark .network .shuffle .protocol .BlockTransferMessage .Type ;
29
+
27
30
/** Request to read a set of blocks. Returns {@link StreamHandle}. */
28
31
public class OpenBlocks extends BlockTransferMessage {
29
32
public final String appId ;
Original file line number Diff line number Diff line change 22
22
23
23
import org .apache .spark .network .protocol .Encoders ;
24
24
25
+ // Needed by ScalaDoc. See SPARK-7726
26
+ import static org .apache .spark .network .shuffle .protocol .BlockTransferMessage .Type ;
27
+
25
28
/**
26
29
* Initial registration message between an executor and its local shuffle server.
27
30
* Returns nothing (empty bye array).
Original file line number Diff line number Diff line change 20
20
import com .google .common .base .Objects ;
21
21
import io .netty .buffer .ByteBuf ;
22
22
23
+ // Needed by ScalaDoc. See SPARK-7726
24
+ import static org .apache .spark .network .shuffle .protocol .BlockTransferMessage .Type ;
25
+
23
26
/**
24
27
* Identifier for a fixed number of chunks to read from a stream created by an "open blocks"
25
28
* message. This is used by {@link org.apache.spark.network.shuffle.OneForOneBlockFetcher}.
Original file line number Diff line number Diff line change 24
24
25
25
import org .apache .spark .network .protocol .Encoders ;
26
26
27
+ // Needed by ScalaDoc. See SPARK-7726
28
+ import static org .apache .spark .network .shuffle .protocol .BlockTransferMessage .Type ;
29
+
27
30
28
31
/** Request to upload a block with a certain StorageLevel. Returns nothing (empty byte array). */
29
32
public class UploadBlock extends BlockTransferMessage {
You can’t perform that action at this time.
0 commit comments