package rayexec.execution

Get desktop application:
View/edit binary Protocol Buffers messages

Used in: PhysicalCreateSchema

• string name = 1

• OnConflict on_conflict = 2

Used in: PhysicalCreateTable

• string name = 1

• repeated schema.Field columns = 2

• OnConflict on_conflict = 3

Used in: PhysicalDrop

• string schema = 1

• optional DropObject object = 2

• bool cascade = 3

• bool if_exists = 4

Used in: DropInfo

• oneof value

  • string index = 1

  • string function = 2

  • string table = 3

  • string view = 4

  • EmptyDropObject schema = 5

    Schema name already contained in drop info.

Used in: DropObject

(message has no fields)

Used in: IntermediatePipeline

• optional PhysicalOperator operator = 1

• optional uint32 partitioning_requirement = 2

Used in: IntermediatePipelineGroup

• optional IntermediatePipelineId id = 1

• optional PipelineSink sink = 2

• optional PipelineSource source = 3

• repeated IntermediateOperator operators = 4

Used in: hybrid.PlanResponse

• repeated IntermediatePipeline pipelines = 1

Used in: IntermediatePipeline, PipelineSinkInGroup, PipelineSourceOtherPipeline

• uint32 id = 1

Used in: CreateSchemaInfo, CreateTableInfo

• INVALID_ON_CONFLICT = 0

• IGNORE = 1

• REPLACE = 2

• ERROR = 3

Used in: PhysicalOperator

• optional functions.CopyToFunction copy_to = 1

• optional access.FileLocation location = 2

• optional schema.Schema schema = 3

Used in: PhysicalOperator

• string catalog = 1

• optional CreateSchemaInfo info = 2

Used in: PhysicalOperator

• string catalog = 1

• string schema = 2

• optional CreateTableInfo info = 3

• bool is_ctas = 4

Used in: PhysicalOperator

• string catalog = 1

• optional DropInfo info = 2

Used in: PhysicalOperator

(message has no fields)

Used in: PhysicalOperator

• optional physical_expr.PhysicalScalarExpression predicate = 1

Used in: PhysicalOperator

• string catalog = 1

• string schema = 2

• optional catalog.CatalogEntry table = 3

Used in: PhysicalOperator

• uint64 limit = 1

• optional uint64 offset = 2

Used in: PhysicalOperator

• repeated physical_expr.PhysicalSortExpression exprs = 1

• uint64 num_outputs = 1

Used in: PhysicalOperator

• repeated physical_expr.PhysicalSortExpression exprs = 1

Used in: PhysicalOperator

• optional physical_expr.PhysicalScalarExpression filter = 1

Used in: IntermediateOperator

• oneof value

  • PhysicalCreateSchema create_schema = 1

  • PhysicalCreateTable create_table = 2

  • PhysicalDrop drop = 3

  • PhysicalEmpty empty = 4

  • PhysicalFilter filter = 5

  • PhysicalProject project = 6

  • PhysicalInsert insert = 7

  • PhysicalLimit limit = 8

  • PhysicalScan scan = 10

  • PhysicalUngroupedAggregate ungrouped_aggregate = 11

  • PhysicalUnion union = 12

  • PhysicalValues values = 13

  • PhysicalTableFunction table_function = 14

  • PhysicalNestedLoopJoin nl_join = 15

  • PhysicalCopyTo copy_to = 16

  • PhysicalLocalSort local_sort = 17

  • PhysicalMergeSortedInputs merge_sorted = 18

Used in: PhysicalOperator

• repeated physical_expr.PhysicalScalarExpression exprs = 1

Used in: PhysicalOperator

• string catalog = 1

• string schema = 2

• optional catalog.CatalogEntry table = 3

Used in: PhysicalOperator

• optional functions.PlannedTableFunction function = 1

• optional Projections projections = 2

Used in: PhysicalOperator

• repeated physical_expr.PhysicalAggregateExpression aggregates = 1

Used in: PhysicalOperator

(message has no fields)

Used in: PhysicalOperator

• optional array.IpcStreamBatch batches = 1

Used in: IntermediatePipeline

• oneof value

  • PipelineSinkQueryOutput query_output = 1

  • PipelineSinkInPipeline in_pipeline = 2

  • PipelineSinkInGroup in_group = 3

  • PipelineSinkOtherGroup other_group = 4

  • PipelineSinkMaterialization materialization = 5

Used in: PipelineSink

• optional IntermediatePipelineId id = 1

• uint32 operator_idx = 2

• uint32 input_idx = 3

Used in: PipelineSink

(message has no fields)

Used in: PipelineSink

• uint32 materialization_ref = 1

Used in: PipelineSink

• optional StreamId stream_id = 1

• uint32 partitions = 2

Used in: PipelineSink

(message has no fields)

Used in: IntermediatePipeline

• oneof value

  • PipelineSourceInPipeline in_pipeline = 1

  • PipelineSourceOtherPipeline other_pipeline = 2

  • PipelineSourceOtherGroup other_group = 3

  • PipelineSourceMaterialization materialization = 4

Used in: PipelineSource

(message has no fields)

Used in: PipelineSource

• uint32 materialization_ref = 1

Used in: PipelineSource

• optional StreamId stream_id = 1

• uint32 partitions = 2

Used in: PipelineSource

• optional IntermediatePipelineId id = 1

• optional uint32 partitioning_requirement = 2

Used in: PhysicalTableFunction

• repeated uint32 column_indices = 1

Used in: PipelineSinkOtherGroup, PipelineSourceOtherGroup, hybrid.FinalizeRequest, hybrid.PullRequest, hybrid.PushRequest

• optional foreign.Uuid query_id = 1

• optional foreign.Uuid stream_id = 2