package deploy.master.meta

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: ResourceRequest

• string appId = 1

• int64 time = 2

• int64 totalWritten = 3

• int64 fileCount = 4

• optional int64 shuffleCount = 5

• map<string, int64> shuffleFallbackCounts = 6

• optional HeartbeatInfo heartbeatInfo = 7

• optional int64 applicationCount = 8

• map<string, int64> applicationFallbackCounts = 9

Used in: ResourceRequest

• string appId = 1

Used in: ResourceRequest

• string appId = 1

• optional string secret = 2

Used in: ResourceRequest

• repeated string shuffleKeys = 1

Used in: RegisterWorkerRequest, WorkerHeartbeatRequest

• string mountPoint = 1

• int64 usableSpace = 2

• int64 avgFlushTime = 3

• int64 usedSlots = 4

• int32 status = 5

• int64 avgFetchTime = 6

• int32 storageType = 7

• int64 totalSpace = 8

Used in: AppHeartbeatRequest

• string appId = 1

• int64 totalWritten = 2

• int64 fileCount = 3

• int64 shuffleCount = 4

• map<string, int64> shuffleFallbackCounts = 5

Used in: ResourceRequest

• string appId = 1

• optional UserIdentifier userIdentifier = 2

• map<string, string> extraInfo = 3

Used in: ResourceRequest

• string host = 1

• int32 rpcPort = 2

• int32 pushPort = 3

• int32 fetchPort = 4

• int32 replicatePort = 5

• map<string, DiskInfo> disks = 6

• map<string, ResourceConsumption> userResourceConsumption = 7

• int32 internalPort = 8

• optional string networkLocation = 9

Used in: ResourceRequest

• repeated WorkerAddress unavailable = 1

Used in: ResourceRequest

• repeated WorkerAddress workers = 1

Used in: ResourceRequest

• repeated WorkerAddress unavailable = 1

Used in: ResourceRequest

• string shuffleKey = 1

• string hostName = 2

• map<string, SlotInfo> workerAllocations = 3

Used in: RegisterWorkerRequest, WorkerHeartbeatRequest

• int64 diskBytesWritten = 1

• int64 diskFileCount = 2

• int64 hdfsBytesWritten = 3

• int64 hdfsFileCount = 4

• map<string, ResourceConsumption> subResourceConsumption = 5

• Type cmdType = 1

  Type of the command

• optional string requestId = 2

• optional RequestSlotsRequest requestSlotsRequest = 10

• optional UnregisterShuffleRequest unregisterShuffleRequest = 12

• optional AppHeartbeatRequest appHeartbeatRequest = 13

• optional AppLostRequest appLostRequest = 14

• optional WorkerLostRequest workerLostRequest = 15

• optional WorkerHeartbeatRequest workerHeartbeatRequest = 16

• optional RegisterWorkerRequest registerWorkerRequest = 17

• optional ReportWorkerUnavailableRequest reportWorkerUnavailableRequest = 18

• optional RemoveWorkersUnavailableInfoRequest removeWorkersUnavailableInfoRequest = 20

• optional WorkerExcludeRequest workerExcludeRequest = 21

• optional WorkerEventRequest workerEventRequest = 22

• optional ApplicationMetaRequest applicationMetaRequest = 23

• optional ReportWorkerDecommissionRequest reportWorkerDecommissionRequest = 24

• optional BatchUnregisterShuffleRequest batchUnregisterShuffleRequest = 25

• optional RegisterApplicationInfoRequest registerApplicationInfoRequest = 26

• optional ReviseLostShufflesRequest reviseLostShufflesRequest = 102

• Type cmdType = 1

  Type of the command

• optional bool success = 2

• optional string message = 3

• Status status = 4

Used in: ResourceRequest

• string appId = 1

• repeated int32 lostShuffles = 2

Used in: RequestSlotsRequest

• map<string, int32> slot = 1

Used in: ResourceResponse

• UNKNOWN = 0

• OK = 1

• INTERNAL_ERROR = 2

Used in: ResourceRequest, ResourceResponse

• Unknown = 0

• UnRegisterShuffle = 12

• RequestSlots = 13

• AppHeartbeat = 15

• AppLost = 16

• WorkerLost = 17

• WorkerHeartbeat = 18

• RegisterWorker = 19

• ReportWorkerUnavailable = 20

• UpdatePartitionSize = 21

• RemoveWorkersUnavailableInfo = 23

• WorkerExclude = 24

• WorkerEvent = 25

• ApplicationMeta = 26

• ReportWorkerDecommission = 27

• BatchUnRegisterShuffle = 28

• ReviseLostShuffles = 29

• RegisterApplicationInfo = 30

Used in: ResourceRequest

• string shuffleKey = 1

Used in: RegisterApplicationInfoRequest

• string tenantId = 1

• string name = 2

Used in: RemoveWorkersUnavailableInfoRequest, ReportWorkerDecommissionRequest, ReportWorkerUnavailableRequest, WorkerEventRequest, WorkerExcludeRequest

• string host = 1

• int32 rpcPort = 2

• int32 pushPort = 3

• int32 fetchPort = 4

• int32 replicatePort = 5

• int32 internalPort = 6

Used in: ResourceRequest

• repeated WorkerAddress workerAddress = 1

• WorkerEventType workerEventType = 2

Used in: WorkerEventRequest

• None = 0

  refer to TransportMessages.proto.PbWorkerEvent.EventType

• Immediately = 1

  Immediately exit

• Decommission = 2

  from normal to decommission, then exit

• DecommissionThenIdle = 3

  from normal to decommission and keep alive

• Graceful = 4

  from normal to graceful, then exit

• Recommission = 5

  -> from InDecommissionThenIdle/Idle state to Normal

Used in: ResourceRequest

• repeated WorkerAddress workersToAdd = 1

• repeated WorkerAddress workersToRemove = 2

Used in: ResourceRequest

• string host = 1

• int32 rpcPort = 2

• int32 pushPort = 3

• int32 fetchPort = 4

• int32 replicatePort = 5

• map<string, DiskInfo> disks = 6

• int64 time = 7

• map<string, ResourceConsumption> userResourceConsumption = 8

• map<string, int64> estimatedAppDiskUsage = 9

  deprecated

• bool highWorkload = 10

• optional WorkerStatus workerStatus = 11

Used in: ResourceRequest

• string host = 1

• int32 rpcPort = 2

• int32 pushPort = 3

• int32 fetchPort = 4

• int32 replicatePort = 5

Used in: WorkerHeartbeatRequest

• WorkerStatus.State state = 1

• int64 stateStartTime = 2

Used in: WorkerStatus

• Normal = 0

• Idle = 1

• Exit = 2

• InDecommissionThenIdle = 3

  -> Idle

• InDecommission = 4

  -> Exit

• InGraceFul = 5

  -> Exit

• InExit = 6