package presto

Get desktop application:
View/edit binary Protocol Buffers messages

• required string name = 1

• repeated Array arrays = 2

• repeated Tuple offsets = 3

• optional Tuple dim = 4

• optional bool is_list = 5

Structure to represent a multi-dimensional array

Used in: Arg, CreateRequest, TransferRequest, UpdateArrayRequest

• required string name = 1

• required Tuple dim = 2

• optional int64 size = 3

• optional bool sparse = 4

• optional Tuple psizes = 5

  optional ServerInfo location = 4;

Used in: HelloReplyRequest

• required int64 size = 1

• required string name = 2

• required ServerInfo location = 3

Used in: WorkerRequest

• required string name = 1

• optional string store = 2

• optional int64 id = 3

• required int64 uid = 4

• repeated string arraynames = 1

• repeated Tuple offsets = 2

• required Tuple dim = 3

• required string varname = 4

Used in: WorkerRequest

• repeated NewArg cargs = 1

• repeated Tuple offsets = 2

• required Tuple dims = 3

• required string name = 4

• optional int64 id = 5

• required int64 uid = 6

• repeated NewArg task_args = 7

• optional int64 parenttaskid = 8

Used in: WorkerRequest

• required Array arr = 1

• optional double initial_data = 2

Used in: WorkerRequest

• required string name = 1

• required ServerInfo location = 2

• optional int64 size = 3

• optional string store = 4

• optional int64 id = 5

• optional int64 uid = 6

• optional FetchRequest.Policy policy = 7

Used in: FetchRequest

• WORKER_CONN = 1

• R_CONN = 2

Used in: MasterRequest

• required ServerInfo location = 1

• optional int64 shared_memory = 2

• optional int32 executors = 3

• repeated ArrayStoreData array_stores = 4

• optional int64 mem_total = 5

• optional int64 mem_used = 6

• optional bool is_heartbeat = 7

Used in: WorkerRequest

• optional ServerInfo master_location = 1

• required ServerInfo worker_location = 2

• optional int64 abs_time = 3

• optional int32 reply_attr_flag = 4

• optional bool is_heartbeat = 5

• required int32 num_workers = 6

Used in: WorkerRequest

• required string array_name = 1

• required string store_name = 2

• required IORequest.Type type = 3

• optional int64 id = 4

• required int64 uid = 5

Used in: IORequest

• LOAD = 1

• SAVE = 2

Used in: WorkerRequest

• required string msg = 1

• required MasterRequest.Type type = 1

• optional UpdateArrayRequest update = 2

• optional NewUpdateRequest newupdate = 3

• optional TaskDoneRequest taskdone = 4

• optional HelloReplyRequest helloreply = 5

• optional WorkerAbortRequest workerabort = 6

• optional MetadataUpdateReply metadataupdate = 7

Used in: MasterRequest

• UPDATE = 1

• NEWUPDATE = 2

• TASKDONE = 3

• HELLOREPLY = 4

• SHUTDOWN = 5

  this shutdown is sent from master->master to commit suicide

• WORKERABORT = 6

  notify master that a worker is terminating

• METADATAUPDATEREPLY = 7

Used in: MasterRequest

• required int64 id = 1

• required int64 uid = 2

• optional ServerInfo location = 3

• optional string message = 4

• optional int64 status = 5

Used in: WorkerRequest

• required int64 id = 1

• required int64 uid = 2

• required bool status = 3

Used in: CreateCompositeRequest, NewExecuteRRequest

• required string arrayname = 1

• required string varname = 2

• repeated string list_arraynames = 3

Used in: WorkerRequest

• repeated string func = 1

• repeated NewArg args = 2

• repeated RawArg raw_args = 3

• repeated NewArg composite_args = 4

• optional int64 id = 5

• required int64 uid = 6

• optional int64 parenttaskid = 7

• optional bool stage_updates = 8

Used in: MasterRequest

• required string name = 1

• required ServerInfo location = 2

• required int64 size = 3

• required int64 row_dim = 4

• required int64 col_dim = 5

Used in: WorkerRequest

• required int64 id = 1

• required int64 uid = 2

• required string split_name = 3

• required int32 executor = 4

• required int64 parenttaskid = 5

Used in: NewExecuteRRequest

• required string name = 1

• optional bytes value = 2

• required bool fetch_need = 3

• optional string server_addr = 4

• optional int32 server_port = 5

• optional string fetch_id = 6

• optional int64 data_size = 7

Generic Response message used for all requests

• optional Response.Status status = 1

• optional string msg = 2

Used in: Response

• OK = 1

• ERROR = 2

• repeated ServerInfo servers = 1

Structures used to pass around information about servers

Used in: ArrayStoreData, FetchRequest, HelloReplyRequest, HelloRequest, MetadataUpdateReply, NewUpdateRequest, ServerConfig, TaskDoneRequest, UpdateArrayRequest, WorkerAbortRequest

• required string name = 1

• required int32 presto_port = 2

• optional int32 start_port_range = 3

• optional int32 end_port_range = 4

Used in: MasterRequest

• required int64 id = 1

• repeated string update_names = 2

• repeated int64 update_sizes = 3

• required ServerInfo location = 4

• repeated string update_stores = 5

• repeated bool update_empties = 6

• required int64 uid = 7

• optional int64 mem_used = 8

• optional string task_message = 9

• optional int64 task_result = 10

• repeated int64 row_dim = 11

• repeated int64 col_dim = 12

• optional int64 npartitions = 13

• optional int32 loader_port = 14

Used in: WorkerRequest

• required Array arr = 1

• required string hostname = 2

• required int32 port = 3

Used in: Arg, Array, CompositeArg, CreateCompositeRequest

• repeated int64 val = 1

Used in: MasterRequest

• required Array array = 1

• required ServerInfo location = 2

• required string clear_name = 3

Used in: WorkerRequest

• required VerticaDLRequest.Type type = 1

• optional int64 split_size = 2

• optional string split_name = 3

• repeated string query_result = 4

• required int64 id = 5

• optional int64 uid = 6

Used in: VerticaDLRequest

• START = 1

• FETCH = 2

• STOP = 3

Used in: MasterRequest

• required ServerInfo location = 1

• required string reason = 2

• optional int64 shared_memory = 3

• optional int32 executors = 4

NOTE: We use WorkerRequest to differentiate between different request types in the ZeroMQ server-side implementation.

• required WorkerRequest.Type type = 1

• optional HelloRequest hello = 2

• optional CreateRequest create = 3

• optional ClearRequest clear = 4

• optional CreateCompositeRequest createcomposite = 5

• optional TransferRequest transfer = 6

• optional FetchRequest fetch = 7

• optional NewExecuteRRequest newexecr = 8

• optional IORequest io = 9

• optional LogRequest log = 10

• optional VerticaDLRequest verticaload = 11

• optional MetadataUpdateRequest metadataupdate = 12

• optional PersistRequest persist = 13

  shutdown doesn't have any request

Used in: WorkerRequest

• HELLO = 1

• CREATE = 2

• CLEAR = 3

• CREATECOMPOSITE = 4

• TRANSFER = 5

• SHUTDOWN = 7

• FETCH = 9

• NEWEXECR = 10

• NEWTRANSFER = 11

• IO = 12

• LOG = 13

• VERTICALOAD = 14

• METADATAUPDATE = 15

• PERSIST = 16