Default package

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: ColumnMessage

• required bytes data = 1

• repeated int32 start_indices = 2

• repeated int32 end_indices = 3

Used in: ColumnMessage

• required bytes data = 1

Used in: DataMessage

• required ColumnMessage.Type type = 1

  See enum above

• optional IntColumnMessage int_column = 3

• optional LongColumnMessage long_column = 4

• optional FloatColumnMessage float_column = 5

• optional DoubleColumnMessage double_column = 6

• optional StringColumnMessage string_column = 7

• optional BooleanColumnMessage boolean_column = 8

• optional DateTimeColumnMessage date_column = 9

• optional BlobColumnMessage blob_column = 10

Used in: ColumnMessage

• INT = 0

• LONG = 1

• FLOAT = 2

• DOUBLE = 3

• STRING = 4

• BOOLEAN = 5

• DATETIME = 6

• BLOB = 7

Used in: TransportMessage

• required ControlMessage.Type type = 1

  See enum above

• optional int32 worker_id = 2

• optional SocketInfo remote_address = 3

• repeated ResourceStats resource_stats = 4

• repeated int32 acked_worker_ids = 5

• optional Exception worker_exception = 6

  REMOVE_WORKER

Used in: ControlMessage

• SHUTDOWN = 1

  master -> workers

• WORKER_HEARTBEAT = 2

  worker -> master

• REMOVE_WORKER = 3

  master -> workers

• ADD_WORKER = 4

  master -> workers

• REMOVE_WORKER_ACK = 5

  worker -> master

• ADD_WORKER_ACK = 6

  worker -> master

• RESOURCE_STATS = 7

  worker -> master

Used in: TransportMessage

• required DataMessage.Type type = 1

• optional uint64 operatorID = 2

• repeated ColumnMessage columns = 3

• optional uint32 num_tuples = 4

• optional uint64 seq = 5

Used in: DataMessage

• NORMAL = 1

  Normal Data

• EOI = 2

  End of Iteration

Used in: ColumnMessage

• required bytes data = 1

Used in: ColumnMessage

• required bytes data = 1

Used in: ControlMessage

• required bytes exception = 1

  for now, the exception is a simple java serialized object.

Used in: QueryReport

• required uint64 elapse = 2

  elapse of query execution.

Used in: ColumnMessage

• required bytes data = 1

Used in: ColumnMessage

• required bytes data = 1

Used in: ColumnMessage

• required bytes data = 1

Used in: QueryMessage

• required bytes query = 1

  for now, the query is a simple java serialized object.

Used in: TransportMessage

• required uint64 query_id = 1

• required uint64 subquery_id = 2

• required QueryMessage.Type type = 3

• optional QueryReport query_report = 4

  Report of the query execution. when type is QUERY_COMPLETE

• optional Query query = 5

  query data, when type is QUERY_DISTRIBUTE

• optional int32 worker_id = 6

  worker id, when type is QUERY_RECOVER

Used in: QueryMessage

• QUERY_DISTRIBUTE = 0

  distribute a query, master -> worker

• QUERY_START = 1

  start the query, master -> worker

• QUERY_PAUSE = 7

  master -> worker

• QUERY_RESUME = 8

  master -> worker

• QUERY_KILL = 9

  master -> worker

• QUERY_READY_TO_EXECUTE = 2

  worker -> master

• QUERY_COMPLETE = 6

  worker -> master

• QUERY_RECOVER = 3

  master -> worker

Used in: QueryMessage

• required bool success = 1

  if the query execution succeeds.

• required ExecutionStatistics execution_statistics = 2

• optional bytes cause = 3

  the cause of a failed execution. It should be a serialized java exception Object.

Used in: ControlMessage

• required int64 timestamp = 1

• required int32 opId = 2

• required string measurement = 3

• required int64 value = 4

• required int64 queryId = 5

• required int64 subqueryId = 6

Used in: ControlMessage

• required string host = 1

• required int32 port = 2

Used in: ColumnMessage

• required bytes data = 1

• repeated int32 start_indices = 2

• repeated int32 end_indices = 3

• required TransportMessage.Type type = 1

• optional DataMessage dataMessage = 2

• optional QueryMessage queryMessage = 3

• optional ControlMessage controlMessage = 4

Used in: TransportMessage

• DATA = 0

• QUERY = 1

• CONTROL = 2