0001
0002
0003
0004
0005
0006
0007
0008
0009
0010
0011
0012
0013
0014
0015
0016
0017
0018 package org.apache.spark.network.shuffle.protocol.mesos;
0019
0020 import io.netty.buffer.ByteBuf;
0021 import org.apache.spark.network.protocol.Encoders;
0022 import org.apache.spark.network.shuffle.protocol.BlockTransferMessage;
0023
0024
0025 import static org.apache.spark.network.shuffle.protocol.BlockTransferMessage.Type;
0026
0027
0028
0029
0030 public class ShuffleServiceHeartbeat extends BlockTransferMessage {
0031 private final String appId;
0032
0033 public ShuffleServiceHeartbeat(String appId) {
0034 this.appId = appId;
0035 }
0036
0037 public String getAppId() { return appId; }
0038
0039 @Override
0040 protected Type type() { return Type.HEARTBEAT; }
0041
0042 @Override
0043 public int encodedLength() { return Encoders.Strings.encodedLength(appId); }
0044
0045 @Override
0046 public void encode(ByteBuf buf) {
0047 Encoders.Strings.encode(buf, appId);
0048 }
0049
0050 public static ShuffleServiceHeartbeat decode(ByteBuf buf) {
0051 return new ShuffleServiceHeartbeat(Encoders.Strings.decode(buf));
0052 }
0053 }