package plugins

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc GetTable (GetTableRequest, GetTableResponse)

  plugins.proto:14

  message GetTableRequest

  plugins.proto:20

  • optional TableContext table_context = 1

  message GetTableResponse

  plugins.proto:24

  • optional Schema schema = 1

• rpc PushDownPredicates (PushDownPredicatesRequest, PushDownPredicatesResponse)

  plugins.proto:15

  message PushDownPredicatesRequest

  plugins.proto:28

  TODO: Add schema? Maybe TableWithSchemaContext? Or PhysicalTableContext?

  • optional TableContext table_context = 1

  • bytes new_predicates = 2

    []Expression JSONs, not performance sensitive.

  • bytes pushed_down_predicates = 3

  message PushDownPredicatesResponse

  plugins.proto:37

  • bytes rejected = 1

    []Expression JSONs, not performance sensitive.

  • bytes pushed_down = 2

  • bool changed = 3

• rpc Materialize (MaterializeRequest, MaterializeResponse)

  plugins.proto:16

  message MaterializeRequest

  plugins.proto:44

  • optional TableContext table_context = 1

  • optional Schema schema = 2

  • bytes pushed_down_predicates = 3

  • optional PhysicalVariableContext variable_context = 4

  message MaterializeResponse

  plugins.proto:51

  • string socket_path = 1

• rpc Metadata (MetadataRequest, MetadataResponse)

  plugins.proto:17

  message MetadataRequest

  plugins.proto:55

  (message has no fields)

  message MetadataResponse

  plugins.proto:57

  • int64 api_level = 1

• rpc Run (RunRequest, stream RunResponseMessage)

  plugins.proto:62

  message RunRequest

  plugins.proto:65

  • optional ExecutionVariableContext variable_context = 4

  message RunResponseMessage

  plugins.proto:69

  • optional Record record = 1

  • optional MetadataMessage metadata = 2

Used in: RunRequest

• repeated ExecutionVariableContextFrame frames = 1

Used in: ExecutionVariableContext

• repeated Value values = 1

Used in: RunResponseMessage

• int32 message_type = 1

• optional google.protobuf.Timestamp watermark = 2

Used in: MaterializeRequest

• repeated PhysicalVariableContextFrame frames = 1

Used in: PhysicalVariableContext

• repeated SchemaField fields = 1

Used in: RunResponseMessage

• repeated Value values = 1

• bool retraction = 2

• optional google.protobuf.Timestamp event_time = 3

Used in: GetTableResponse, MaterializeRequest

• repeated SchemaField fields = 1

• int32 time_field = 2

• bool no_retractions = 3

Used in: PhysicalVariableContextFrame, Schema

• string name = 1

• optional Type type = 2

Used in: Type

• string name = 1

• optional Type type = 2

Used in: GetTableRequest, MaterializeRequest, PushDownPredicatesRequest

• string table_name = 1

• map<string, string> options = 2

Used in: SchemaField, StructField

• int32 type_id = 1

• optional Type list = 2

• repeated StructField struct = 3

• repeated Type tuple = 4

• repeated Type union = 5

Used in: ExecutionVariableContextFrame, Record

• int32 type_id = 1

• int64 int = 2

• double float = 3

• bool boolean = 4

• string str = 5

• optional google.protobuf.Timestamp time = 6

• optional google.protobuf.Duration duration = 7

• repeated Value list = 8

  TODO: These should have their own messages.

• repeated Value struct = 9

• repeated Value tuple = 10