package openhufu

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc send (DataPacketProto, ResponseProto)

  datapacket.proto:31

  message DataPacketProto

  datapacket.proto:7

  • optional HeaderProto headerProto = 1

  • optional PayloadProto payloadProto = 2

  message ResponseProto

  datapacket.proto:25

  • int32 status = 1

  • string msg = 2

• rpc getOwnerInfo (GeneralRequest, OwnerInfo)

  service.proto:26

• rpc AddOwner (OwnerInfo, GeneralResponse)

  service.proto:27

  message GeneralResponse

  service.proto:15

  • int32 status = 1

  • string msg = 2

• rpc GetTableSchema (GeneralRequest, SchemaProto)

  service.proto:28

• rpc GetAllTableSchema (GeneralRequest, TableSchemaListProto)

  service.proto:29

  message TableSchemaListProto

  data.proto:117

  • repeated TableSchemaProto table = 1

• rpc Query (QueryPlanProto, stream DataSetProto)

  service.proto:30

  message QueryPlanProto

  plan.proto:101

  • PlanType type = 1

  • optional TaskInfo taskInfo = 2

  • string tableName = 3

  • repeated Expression selectExp = 4

  • repeated Expression whereExp = 5

  • repeated Expression aggExp = 6

  • repeated int32 group = 7

  • repeated Collation order = 8

  • int32 fetch = 9

  • int32 offset = 10

  • optional JoinCondition joinInfo = 11

  • repeated QueryPlanProto children = 12

  message DataSetProto

  data.proto:107

  • optional SchemaProto schema = 1

  • repeated ColumnProto column = 2

Used in: ColumnProto

• repeated bool cell = 1

Used in: ColumnProto

• repeated bytes cell = 1

Used in: RowProto

• oneof cel

  • int32 i32cel = 1

  • int64 i64cel = 2

  • float f32cel = 3

  • double f64cel = 4

  • bool boolcel = 5

  • string strcel = 6

  • bytes bytescel = 7

Used in: QueryPlanProto

• int32 ref = 1

• Direction direction = 2

Used in: SchemaProto

• string name = 1

• ColumnType type = 2

• Modifier modifier = 3

Used in: DataSetProto

• bytes isnull = 1

• oneof col

  • I32Column i32col = 2

  • I64Column i64col = 3

  • F32Column f32col = 4

  • F64Column f64col = 5

  • BoolColumn boolcol = 6

  • StringColumn strcol = 7

  • BytesColumn bytescol = 8

Used in: ColumnDesc, Expression

• UNKNOWN = 0

  don't change the number of each type type of larger number has higher priority in type convertion

• BOOLEAN = 1

• BYTE = 2

• SHORT = 3

• INT = 4

• LONG = 5

• FLOAT = 6

• DOUBLE = 7

• STRING = 8

• BLOB = 9

• DATE = 10

• TIME = 11

• TIMESTAMP = 12

• INTERVAL = 13

• GEOMETRY = 14

Used in: Collation

• ASC = 0

• DESC = 1

Used in: JoinCondition, QueryPlanProto

• OperatorType opType = 1

• ColumnType outType = 2

• repeated Expression in = 3

• Modifier modifier = 4

• oneof value

  • bool b = 5

  • int32 i32 = 6

  • int64 i64 = 7

  • float f32 = 8

  • double f64 = 9

  • string str = 10

  • bytes blob = 11

Used in: ColumnProto

• repeated float cell = 1

Used in: ColumnProto

• repeated double cell = 1

Used as request type in: Service.GetAllTableSchema, Service.GetTableSchema, Service.getOwnerInfo

• string value = 1

Used in: DataPacketProto

• int64 taskId = 1

• int32 ptoId = 2

• int32 stepId = 3

• int64 extraInfo = 4

• int32 senderId = 5

• int32 receiverId = 6

Used in: ColumnProto

• repeated int32 cell = 1

Used in: ColumnProto

• repeated int64 cell = 1

Used in: QueryPlanProto

• JoinType type = 1

• Modifier modifier = 2

• repeated int32 leftKey = 3

• repeated int32 rightKey = 4

• optional Expression condition = 5

Used in: JoinCondition

• INNER = 0

• LEFT = 1

• RIGHT = 2

• OUTER = 3

• SEMI = 4

Used in: ColumnDesc, Expression, JoinCondition

• HIDDEN = 0

• PUBLIC = 1

• PROTECTED = 2

• PRIVATE = 3

• UNSUPPORT = 100

Used in: Expression

• NONE = 0

• REF = 1

• LITERAL = 2

• PLUS = 100

  for binary

• MINUS = 101

• TIMES = 102

• DIVIDE = 103

• MOD = 104

• GT = 105

• GE = 106

• LT = 107

• LE = 108

• EQ = 109

• NE = 110

• AND = 111

• OR = 112

• LIKE = 113

• MAX = 114

• MIN = 115

• AS = 200

  for unary

• NOT = 201

• PLUS_PRE = 202

• MINUS_PRE = 203

• IS_NULL = 204

• IS_NOT_NULL = 205

• CASE = 300

  for mutliple

• INTERSECTION = 400

  for set

• UNION = 401

• SCALAR_FUNC = 500

  for functions

• AGG_FUNC = 501

Used as request type in: Service.AddOwner

Used as response type in: Service.getOwnerInfo

• int32 id = 1

• string endpoint = 2

Used in: DataPacketProto

• repeated bytes payloadBytes = 1

Used in: QueryPlanProto

• ROOT = 0

• LEAF = 1

• UNARY = 2

• BINARY = 3

• EMPTY = 4

Used in: RowsProto

• bytes isnull = 1

• repeated CellProto cells = 2

• repeated RowProto rows = 1

Used as response type in: Service.GetTableSchema

Used as field type in: DataSetProto, TableSchemaProto

• repeated ColumnDesc columnDesc = 1

Used in: ColumnProto

• repeated string cell = 1

Used in: TableSchemaListProto

• string name = 1

• optional SchemaProto schema = 2

Used in: QueryPlanProto

• int64 taskId = 1

• repeated int32 parties = 2