package tws.proto.task

Get desktop application:
View/edit binary Protocol Buffers messages

• bool sendBarrier = 1

• int32 currentBarrierID = 2

• int32 currentBarrierID = 1

• int32 taskID = 2

• int32 currentBarrierID = 1

• bool checkpointComplete = 1

• int32 currentBarrierID = 2

• int32 sinkID = 3

• string family = 1

• int32 index = 2

• string family = 1

• int32 index = 2

• int64 version = 3

• string family = 1

• repeated int32 members = 2

• int32 containers = 3

• int32 containerIndex = 4

• string family = 1

• int64 version = 2

• FamilyInitializeResponse.Status status = 3

Used in: FamilyInitializeResponse

• OK = 0

• REJECTED = 1

TaskDiscovery message is sent from the source and sink task to checkpoint manager when worker initiates.

• int32 taskID = 1

• TaskDiscovery.TaskType taskType = 2

• int32 parrallelism = 3

Used in: TaskDiscovery

• SOURCE = 0

• SINK = 1

• string family = 1

• int32 index = 2

• int64 version = 3

• string family = 1

• int32 index = 2