planpb

Documentation

Index

• Variables
• type AggregateExpression
  • func (*AggregateExpression) Descriptor() ([]byte, []int)
  • func (this *AggregateExpression) Equal(that interface{}) bool
  • func (m *AggregateExpression) GetArgs() []*AggregateExpression_Arg
  • func (m *AggregateExpression) GetArgsDataTypes() []typespb.DataType
  • func (m *AggregateExpression) GetId() int64
  • func (m *AggregateExpression) GetInitArgs() []*ScalarValue
  • func (m *AggregateExpression) GetName() string
  • func (this *AggregateExpression) GoString() string
  • func (m *AggregateExpression) Marshal() (dAtA []byte, err error)
  • func (m *AggregateExpression) MarshalTo(dAtA []byte) (int, error)
  • func (m *AggregateExpression) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AggregateExpression) ProtoMessage()
  • func (m *AggregateExpression) Reset()
  • func (m *AggregateExpression) Size() (n int)
  • func (this *AggregateExpression) String() string
  • func (m *AggregateExpression) Unmarshal(dAtA []byte) error
  • func (m *AggregateExpression) XXX_DiscardUnknown()
  • func (m *AggregateExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AggregateExpression) XXX_Merge(src proto.Message)
  • func (m *AggregateExpression) XXX_Size() int
  • func (m *AggregateExpression) XXX_Unmarshal(b []byte) error
• type AggregateExpression_Arg
  • func (*AggregateExpression_Arg) Descriptor() ([]byte, []int)
  • func (this *AggregateExpression_Arg) Equal(that interface{}) bool
  • func (m *AggregateExpression_Arg) GetColumn() *Column
  • func (m *AggregateExpression_Arg) GetConstant() *ScalarValue
  • func (m *AggregateExpression_Arg) GetValue() isAggregateExpression_Arg_Value
  • func (this *AggregateExpression_Arg) GoString() string
  • func (m *AggregateExpression_Arg) Marshal() (dAtA []byte, err error)
  • func (m *AggregateExpression_Arg) MarshalTo(dAtA []byte) (int, error)
  • func (m *AggregateExpression_Arg) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AggregateExpression_Arg) ProtoMessage()
  • func (m *AggregateExpression_Arg) Reset()
  • func (m *AggregateExpression_Arg) Size() (n int)
  • func (this *AggregateExpression_Arg) String() string
  • func (m *AggregateExpression_Arg) Unmarshal(dAtA []byte) error
  • func (m *AggregateExpression_Arg) XXX_DiscardUnknown()
  • func (m *AggregateExpression_Arg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AggregateExpression_Arg) XXX_Merge(src proto.Message)
  • func (*AggregateExpression_Arg) XXX_OneofWrappers() []interface{}
  • func (m *AggregateExpression_Arg) XXX_Size() int
  • func (m *AggregateExpression_Arg) XXX_Unmarshal(b []byte) error
• type AggregateExpression_Arg_Column
  • func (this *AggregateExpression_Arg_Column) Equal(that interface{}) bool
  • func (this *AggregateExpression_Arg_Column) GoString() string
  • func (m *AggregateExpression_Arg_Column) MarshalTo(dAtA []byte) (int, error)
  • func (m *AggregateExpression_Arg_Column) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *AggregateExpression_Arg_Column) Size() (n int)
  • func (this *AggregateExpression_Arg_Column) String() string
• type AggregateExpression_Arg_Constant
  • func (this *AggregateExpression_Arg_Constant) Equal(that interface{}) bool
  • func (this *AggregateExpression_Arg_Constant) GoString() string
  • func (m *AggregateExpression_Arg_Constant) MarshalTo(dAtA []byte) (int, error)
  • func (m *AggregateExpression_Arg_Constant) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *AggregateExpression_Arg_Constant) Size() (n int)
  • func (this *AggregateExpression_Arg_Constant) String() string
• type AggregateOperator
  • func (*AggregateOperator) Descriptor() ([]byte, []int)
  • func (this *AggregateOperator) Equal(that interface{}) bool
  • func (m *AggregateOperator) GetFinalizeResults() bool
  • func (m *AggregateOperator) GetGroupNames() []string
  • func (m *AggregateOperator) GetGroups() []*Column
  • func (m *AggregateOperator) GetPartialAgg() bool
  • func (m *AggregateOperator) GetValueNames() []string
  • func (m *AggregateOperator) GetValues() []*AggregateExpression
  • func (m *AggregateOperator) GetWindowed() bool
  • func (this *AggregateOperator) GoString() string
  • func (m *AggregateOperator) Marshal() (dAtA []byte, err error)
  • func (m *AggregateOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *AggregateOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*AggregateOperator) ProtoMessage()
  • func (m *AggregateOperator) Reset()
  • func (m *AggregateOperator) Size() (n int)
  • func (this *AggregateOperator) String() string
  • func (m *AggregateOperator) Unmarshal(dAtA []byte) error
  • func (m *AggregateOperator) XXX_DiscardUnknown()
  • func (m *AggregateOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *AggregateOperator) XXX_Merge(src proto.Message)
  • func (m *AggregateOperator) XXX_Size() int
  • func (m *AggregateOperator) XXX_Unmarshal(b []byte) error
• type Column
  • func (*Column) Descriptor() ([]byte, []int)
  • func (this *Column) Equal(that interface{}) bool
  • func (m *Column) GetIndex() uint64
  • func (m *Column) GetNode() uint64
  • func (this *Column) GoString() string
  • func (m *Column) Marshal() (dAtA []byte, err error)
  • func (m *Column) MarshalTo(dAtA []byte) (int, error)
  • func (m *Column) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Column) ProtoMessage()
  • func (m *Column) Reset()
  • func (m *Column) Size() (n int)
  • func (this *Column) String() string
  • func (m *Column) Unmarshal(dAtA []byte) error
  • func (m *Column) XXX_DiscardUnknown()
  • func (m *Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Column) XXX_Merge(src proto.Message)
  • func (m *Column) XXX_Size() int
  • func (m *Column) XXX_Unmarshal(b []byte) error
• type DAG
  • func (*DAG) Descriptor() ([]byte, []int)
  • func (this *DAG) Equal(that interface{}) bool
  • func (m *DAG) GetNodes() []*DAG_DAGNode
  • func (this *DAG) GoString() string
  • func (m *DAG) Marshal() (dAtA []byte, err error)
  • func (m *DAG) MarshalTo(dAtA []byte) (int, error)
  • func (m *DAG) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DAG) ProtoMessage()
  • func (m *DAG) Reset()
  • func (m *DAG) Size() (n int)
  • func (this *DAG) String() string
  • func (m *DAG) Unmarshal(dAtA []byte) error
  • func (m *DAG) XXX_DiscardUnknown()
  • func (m *DAG) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DAG) XXX_Merge(src proto.Message)
  • func (m *DAG) XXX_Size() int
  • func (m *DAG) XXX_Unmarshal(b []byte) error
• type DAG_DAGNode
  • func (*DAG_DAGNode) Descriptor() ([]byte, []int)
  • func (this *DAG_DAGNode) Equal(that interface{}) bool
  • func (m *DAG_DAGNode) GetId() uint64
  • func (m *DAG_DAGNode) GetSortedChildren() []uint64
  • func (m *DAG_DAGNode) GetSortedParents() []uint64
  • func (this *DAG_DAGNode) GoString() string
  • func (m *DAG_DAGNode) Marshal() (dAtA []byte, err error)
  • func (m *DAG_DAGNode) MarshalTo(dAtA []byte) (int, error)
  • func (m *DAG_DAGNode) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*DAG_DAGNode) ProtoMessage()
  • func (m *DAG_DAGNode) Reset()
  • func (m *DAG_DAGNode) Size() (n int)
  • func (this *DAG_DAGNode) String() string
  • func (m *DAG_DAGNode) Unmarshal(dAtA []byte) error
  • func (m *DAG_DAGNode) XXX_DiscardUnknown()
  • func (m *DAG_DAGNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *DAG_DAGNode) XXX_Merge(src proto.Message)
  • func (m *DAG_DAGNode) XXX_Size() int
  • func (m *DAG_DAGNode) XXX_Unmarshal(b []byte) error
• type EmptySourceOperator
  • func (*EmptySourceOperator) Descriptor() ([]byte, []int)
  • func (this *EmptySourceOperator) Equal(that interface{}) bool
  • func (m *EmptySourceOperator) GetColumnNames() []string
  • func (m *EmptySourceOperator) GetColumnTypes() []typespb.DataType
  • func (this *EmptySourceOperator) GoString() string
  • func (m *EmptySourceOperator) Marshal() (dAtA []byte, err error)
  • func (m *EmptySourceOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *EmptySourceOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*EmptySourceOperator) ProtoMessage()
  • func (m *EmptySourceOperator) Reset()
  • func (m *EmptySourceOperator) Size() (n int)
  • func (this *EmptySourceOperator) String() string
  • func (m *EmptySourceOperator) Unmarshal(dAtA []byte) error
  • func (m *EmptySourceOperator) XXX_DiscardUnknown()
  • func (m *EmptySourceOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *EmptySourceOperator) XXX_Merge(src proto.Message)
  • func (m *EmptySourceOperator) XXX_Size() int
  • func (m *EmptySourceOperator) XXX_Unmarshal(b []byte) error
• type FilterOperator
  • func (*FilterOperator) Descriptor() ([]byte, []int)
  • func (this *FilterOperator) Equal(that interface{}) bool
  • func (m *FilterOperator) GetColumns() []*Column
  • func (m *FilterOperator) GetExpression() *ScalarExpression
  • func (this *FilterOperator) GoString() string
  • func (m *FilterOperator) Marshal() (dAtA []byte, err error)
  • func (m *FilterOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *FilterOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*FilterOperator) ProtoMessage()
  • func (m *FilterOperator) Reset()
  • func (m *FilterOperator) Size() (n int)
  • func (this *FilterOperator) String() string
  • func (m *FilterOperator) Unmarshal(dAtA []byte) error
  • func (m *FilterOperator) XXX_DiscardUnknown()
  • func (m *FilterOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *FilterOperator) XXX_Merge(src proto.Message)
  • func (m *FilterOperator) XXX_Size() int
  • func (m *FilterOperator) XXX_Unmarshal(b []byte) error
• type GRPCSinkOperator
  • func (*GRPCSinkOperator) Descriptor() ([]byte, []int)
  • func (this *GRPCSinkOperator) Equal(that interface{}) bool
  • func (m *GRPCSinkOperator) GetAddress() string
  • func (m *GRPCSinkOperator) GetConnectionOptions() *GRPCSinkOperator_GRPCConnectionOptions
  • func (m *GRPCSinkOperator) GetDestination() isGRPCSinkOperator_Destination
  • func (m *GRPCSinkOperator) GetGRPCSourceID() uint64
  • func (m *GRPCSinkOperator) GetOutputTable() *GRPCSinkOperator_ResultTable
  • func (this *GRPCSinkOperator) GoString() string
  • func (m *GRPCSinkOperator) Marshal() (dAtA []byte, err error)
  • func (m *GRPCSinkOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *GRPCSinkOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GRPCSinkOperator) ProtoMessage()
  • func (m *GRPCSinkOperator) Reset()
  • func (m *GRPCSinkOperator) Size() (n int)
  • func (this *GRPCSinkOperator) String() string
  • func (m *GRPCSinkOperator) Unmarshal(dAtA []byte) error
  • func (m *GRPCSinkOperator) XXX_DiscardUnknown()
  • func (m *GRPCSinkOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GRPCSinkOperator) XXX_Merge(src proto.Message)
  • func (*GRPCSinkOperator) XXX_OneofWrappers() []interface{}
  • func (m *GRPCSinkOperator) XXX_Size() int
  • func (m *GRPCSinkOperator) XXX_Unmarshal(b []byte) error
• type GRPCSinkOperator_GRPCConnectionOptions
  • func (*GRPCSinkOperator_GRPCConnectionOptions) Descriptor() ([]byte, []int)
  • func (this *GRPCSinkOperator_GRPCConnectionOptions) Equal(that interface{}) bool
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) GetSslTargetname() string
  • func (this *GRPCSinkOperator_GRPCConnectionOptions) GoString() string
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) Marshal() (dAtA []byte, err error)
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) MarshalTo(dAtA []byte) (int, error)
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GRPCSinkOperator_GRPCConnectionOptions) ProtoMessage()
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) Reset()
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) Size() (n int)
  • func (this *GRPCSinkOperator_GRPCConnectionOptions) String() string
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) Unmarshal(dAtA []byte) error
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_DiscardUnknown()
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_Merge(src proto.Message)
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_Size() int
  • func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_Unmarshal(b []byte) error
• type GRPCSinkOperator_GRPCSourceID
  • func (this *GRPCSinkOperator_GRPCSourceID) Equal(that interface{}) bool
  • func (this *GRPCSinkOperator_GRPCSourceID) GoString() string
  • func (m *GRPCSinkOperator_GRPCSourceID) MarshalTo(dAtA []byte) (int, error)
  • func (m *GRPCSinkOperator_GRPCSourceID) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *GRPCSinkOperator_GRPCSourceID) Size() (n int)
  • func (this *GRPCSinkOperator_GRPCSourceID) String() string
• type GRPCSinkOperator_OutputTable
  • func (this *GRPCSinkOperator_OutputTable) Equal(that interface{}) bool
  • func (this *GRPCSinkOperator_OutputTable) GoString() string
  • func (m *GRPCSinkOperator_OutputTable) MarshalTo(dAtA []byte) (int, error)
  • func (m *GRPCSinkOperator_OutputTable) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *GRPCSinkOperator_OutputTable) Size() (n int)
  • func (this *GRPCSinkOperator_OutputTable) String() string
• type GRPCSinkOperator_ResultTable
  • func (*GRPCSinkOperator_ResultTable) Descriptor() ([]byte, []int)
  • func (this *GRPCSinkOperator_ResultTable) Equal(that interface{}) bool
  • func (m *GRPCSinkOperator_ResultTable) GetColumnNames() []string
  • func (m *GRPCSinkOperator_ResultTable) GetColumnSemanticTypes() []typespb.SemanticType
  • func (m *GRPCSinkOperator_ResultTable) GetColumnTypes() []typespb.DataType
  • func (m *GRPCSinkOperator_ResultTable) GetTableName() string
  • func (this *GRPCSinkOperator_ResultTable) GoString() string
  • func (m *GRPCSinkOperator_ResultTable) Marshal() (dAtA []byte, err error)
  • func (m *GRPCSinkOperator_ResultTable) MarshalTo(dAtA []byte) (int, error)
  • func (m *GRPCSinkOperator_ResultTable) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GRPCSinkOperator_ResultTable) ProtoMessage()
  • func (m *GRPCSinkOperator_ResultTable) Reset()
  • func (m *GRPCSinkOperator_ResultTable) Size() (n int)
  • func (this *GRPCSinkOperator_ResultTable) String() string
  • func (m *GRPCSinkOperator_ResultTable) Unmarshal(dAtA []byte) error
  • func (m *GRPCSinkOperator_ResultTable) XXX_DiscardUnknown()
  • func (m *GRPCSinkOperator_ResultTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GRPCSinkOperator_ResultTable) XXX_Merge(src proto.Message)
  • func (m *GRPCSinkOperator_ResultTable) XXX_Size() int
  • func (m *GRPCSinkOperator_ResultTable) XXX_Unmarshal(b []byte) error
• type GRPCSourceOperator
  • func (*GRPCSourceOperator) Descriptor() ([]byte, []int)
  • func (this *GRPCSourceOperator) Equal(that interface{}) bool
  • func (m *GRPCSourceOperator) GetColumnNames() []string
  • func (m *GRPCSourceOperator) GetColumnTypes() []typespb.DataType
  • func (this *GRPCSourceOperator) GoString() string
  • func (m *GRPCSourceOperator) Marshal() (dAtA []byte, err error)
  • func (m *GRPCSourceOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *GRPCSourceOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*GRPCSourceOperator) ProtoMessage()
  • func (m *GRPCSourceOperator) Reset()
  • func (m *GRPCSourceOperator) Size() (n int)
  • func (this *GRPCSourceOperator) String() string
  • func (m *GRPCSourceOperator) Unmarshal(dAtA []byte) error
  • func (m *GRPCSourceOperator) XXX_DiscardUnknown()
  • func (m *GRPCSourceOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *GRPCSourceOperator) XXX_Merge(src proto.Message)
  • func (m *GRPCSourceOperator) XXX_Size() int
  • func (m *GRPCSourceOperator) XXX_Unmarshal(b []byte) error
• type JoinOperator
  • func (*JoinOperator) Descriptor() ([]byte, []int)
  • func (this *JoinOperator) Equal(that interface{}) bool
  • func (m *JoinOperator) GetColumnNames() []string
  • func (m *JoinOperator) GetEqualityConditions() []*JoinOperator_EqualityCondition
  • func (m *JoinOperator) GetOutputColumns() []*JoinOperator_ParentColumn
  • func (m *JoinOperator) GetRowsPerBatch() uint64
  • func (m *JoinOperator) GetType() JoinOperator_JoinType
  • func (this *JoinOperator) GoString() string
  • func (m *JoinOperator) Marshal() (dAtA []byte, err error)
  • func (m *JoinOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *JoinOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*JoinOperator) ProtoMessage()
  • func (m *JoinOperator) Reset()
  • func (m *JoinOperator) Size() (n int)
  • func (this *JoinOperator) String() string
  • func (m *JoinOperator) Unmarshal(dAtA []byte) error
  • func (m *JoinOperator) XXX_DiscardUnknown()
  • func (m *JoinOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *JoinOperator) XXX_Merge(src proto.Message)
  • func (m *JoinOperator) XXX_Size() int
  • func (m *JoinOperator) XXX_Unmarshal(b []byte) error
• type JoinOperator_EqualityCondition
  • func (*JoinOperator_EqualityCondition) Descriptor() ([]byte, []int)
  • func (this *JoinOperator_EqualityCondition) Equal(that interface{}) bool
  • func (m *JoinOperator_EqualityCondition) GetLeftColumnIndex() uint64
  • func (m *JoinOperator_EqualityCondition) GetRightColumnIndex() uint64
  • func (this *JoinOperator_EqualityCondition) GoString() string
  • func (m *JoinOperator_EqualityCondition) Marshal() (dAtA []byte, err error)
  • func (m *JoinOperator_EqualityCondition) MarshalTo(dAtA []byte) (int, error)
  • func (m *JoinOperator_EqualityCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*JoinOperator_EqualityCondition) ProtoMessage()
  • func (m *JoinOperator_EqualityCondition) Reset()
  • func (m *JoinOperator_EqualityCondition) Size() (n int)
  • func (this *JoinOperator_EqualityCondition) String() string
  • func (m *JoinOperator_EqualityCondition) Unmarshal(dAtA []byte) error
  • func (m *JoinOperator_EqualityCondition) XXX_DiscardUnknown()
  • func (m *JoinOperator_EqualityCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *JoinOperator_EqualityCondition) XXX_Merge(src proto.Message)
  • func (m *JoinOperator_EqualityCondition) XXX_Size() int
  • func (m *JoinOperator_EqualityCondition) XXX_Unmarshal(b []byte) error
• type JoinOperator_JoinType
  • func (JoinOperator_JoinType) EnumDescriptor() ([]byte, []int)
  • func (x JoinOperator_JoinType) String() string
• type JoinOperator_ParentColumn
  • func (*JoinOperator_ParentColumn) Descriptor() ([]byte, []int)
  • func (this *JoinOperator_ParentColumn) Equal(that interface{}) bool
  • func (m *JoinOperator_ParentColumn) GetColumnIndex() uint64
  • func (m *JoinOperator_ParentColumn) GetParentIndex() uint64
  • func (this *JoinOperator_ParentColumn) GoString() string
  • func (m *JoinOperator_ParentColumn) Marshal() (dAtA []byte, err error)
  • func (m *JoinOperator_ParentColumn) MarshalTo(dAtA []byte) (int, error)
  • func (m *JoinOperator_ParentColumn) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*JoinOperator_ParentColumn) ProtoMessage()
  • func (m *JoinOperator_ParentColumn) Reset()
  • func (m *JoinOperator_ParentColumn) Size() (n int)
  • func (this *JoinOperator_ParentColumn) String() string
  • func (m *JoinOperator_ParentColumn) Unmarshal(dAtA []byte) error
  • func (m *JoinOperator_ParentColumn) XXX_DiscardUnknown()
  • func (m *JoinOperator_ParentColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *JoinOperator_ParentColumn) XXX_Merge(src proto.Message)
  • func (m *JoinOperator_ParentColumn) XXX_Size() int
  • func (m *JoinOperator_ParentColumn) XXX_Unmarshal(b []byte) error
• type LimitOperator
  • func (*LimitOperator) Descriptor() ([]byte, []int)
  • func (this *LimitOperator) Equal(that interface{}) bool
  • func (m *LimitOperator) GetAbortableSrcs() []uint64
  • func (m *LimitOperator) GetColumns() []*Column
  • func (m *LimitOperator) GetLimit() int64
  • func (this *LimitOperator) GoString() string
  • func (m *LimitOperator) Marshal() (dAtA []byte, err error)
  • func (m *LimitOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *LimitOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*LimitOperator) ProtoMessage()
  • func (m *LimitOperator) Reset()
  • func (m *LimitOperator) Size() (n int)
  • func (this *LimitOperator) String() string
  • func (m *LimitOperator) Unmarshal(dAtA []byte) error
  • func (m *LimitOperator) XXX_DiscardUnknown()
  • func (m *LimitOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *LimitOperator) XXX_Merge(src proto.Message)
  • func (m *LimitOperator) XXX_Size() int
  • func (m *LimitOperator) XXX_Unmarshal(b []byte) error
• type MapOperator
  • func (*MapOperator) Descriptor() ([]byte, []int)
  • func (this *MapOperator) Equal(that interface{}) bool
  • func (m *MapOperator) GetColumnNames() []string
  • func (m *MapOperator) GetExpressions() []*ScalarExpression
  • func (this *MapOperator) GoString() string
  • func (m *MapOperator) Marshal() (dAtA []byte, err error)
  • func (m *MapOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *MapOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MapOperator) ProtoMessage()
  • func (m *MapOperator) Reset()
  • func (m *MapOperator) Size() (n int)
  • func (this *MapOperator) String() string
  • func (m *MapOperator) Unmarshal(dAtA []byte) error
  • func (m *MapOperator) XXX_DiscardUnknown()
  • func (m *MapOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MapOperator) XXX_Merge(src proto.Message)
  • func (m *MapOperator) XXX_Size() int
  • func (m *MapOperator) XXX_Unmarshal(b []byte) error
• type MemorySinkOperator
  • func (*MemorySinkOperator) Descriptor() ([]byte, []int)
  • func (this *MemorySinkOperator) Equal(that interface{}) bool
  • func (m *MemorySinkOperator) GetColumnNames() []string
  • func (m *MemorySinkOperator) GetColumnSemanticTypes() []typespb.SemanticType
  • func (m *MemorySinkOperator) GetColumnTypes() []typespb.DataType
  • func (m *MemorySinkOperator) GetName() string
  • func (this *MemorySinkOperator) GoString() string
  • func (m *MemorySinkOperator) Marshal() (dAtA []byte, err error)
  • func (m *MemorySinkOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *MemorySinkOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MemorySinkOperator) ProtoMessage()
  • func (m *MemorySinkOperator) Reset()
  • func (m *MemorySinkOperator) Size() (n int)
  • func (this *MemorySinkOperator) String() string
  • func (m *MemorySinkOperator) Unmarshal(dAtA []byte) error
  • func (m *MemorySinkOperator) XXX_DiscardUnknown()
  • func (m *MemorySinkOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MemorySinkOperator) XXX_Merge(src proto.Message)
  • func (m *MemorySinkOperator) XXX_Size() int
  • func (m *MemorySinkOperator) XXX_Unmarshal(b []byte) error
• type MemorySourceOperator
  • func (*MemorySourceOperator) Descriptor() ([]byte, []int)
  • func (this *MemorySourceOperator) Equal(that interface{}) bool
  • func (m *MemorySourceOperator) GetColumnIdxs() []int64
  • func (m *MemorySourceOperator) GetColumnNames() []string
  • func (m *MemorySourceOperator) GetColumnTypes() []typespb.DataType
  • func (m *MemorySourceOperator) GetName() string
  • func (m *MemorySourceOperator) GetStartTime() *types.Int64Value
  • func (m *MemorySourceOperator) GetStopTime() *types.Int64Value
  • func (m *MemorySourceOperator) GetStreaming() bool
  • func (m *MemorySourceOperator) GetTablet() string
  • func (this *MemorySourceOperator) GoString() string
  • func (m *MemorySourceOperator) Marshal() (dAtA []byte, err error)
  • func (m *MemorySourceOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *MemorySourceOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*MemorySourceOperator) ProtoMessage()
  • func (m *MemorySourceOperator) Reset()
  • func (m *MemorySourceOperator) Size() (n int)
  • func (this *MemorySourceOperator) String() string
  • func (m *MemorySourceOperator) Unmarshal(dAtA []byte) error
  • func (m *MemorySourceOperator) XXX_DiscardUnknown()
  • func (m *MemorySourceOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MemorySourceOperator) XXX_Merge(src proto.Message)
  • func (m *MemorySourceOperator) XXX_Size() int
  • func (m *MemorySourceOperator) XXX_Unmarshal(b []byte) error
• type OTelAttribute
  • func (*OTelAttribute) Descriptor() ([]byte, []int)
  • func (this *OTelAttribute) Equal(that interface{}) bool
  • func (m *OTelAttribute) GetColumn() *OTelAttribute_Column
  • func (m *OTelAttribute) GetName() string
  • func (m *OTelAttribute) GetStringValue() string
  • func (m *OTelAttribute) GetValue() isOTelAttribute_Value
  • func (this *OTelAttribute) GoString() string
  • func (m *OTelAttribute) Marshal() (dAtA []byte, err error)
  • func (m *OTelAttribute) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelAttribute) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelAttribute) ProtoMessage()
  • func (m *OTelAttribute) Reset()
  • func (m *OTelAttribute) Size() (n int)
  • func (this *OTelAttribute) String() string
  • func (m *OTelAttribute) Unmarshal(dAtA []byte) error
  • func (m *OTelAttribute) XXX_DiscardUnknown()
  • func (m *OTelAttribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelAttribute) XXX_Merge(src proto.Message)
  • func (*OTelAttribute) XXX_OneofWrappers() []interface{}
  • func (m *OTelAttribute) XXX_Size() int
  • func (m *OTelAttribute) XXX_Unmarshal(b []byte) error
• type OTelAttribute_Column
  • func (*OTelAttribute_Column) Descriptor() ([]byte, []int)
  • func (this *OTelAttribute_Column) Equal(that interface{}) bool
  • func (m *OTelAttribute_Column) GetCanBeJsonEncodedArray() bool
  • func (m *OTelAttribute_Column) GetColumnIndex() int64
  • func (m *OTelAttribute_Column) GetColumnType() typespb.DataType
  • func (this *OTelAttribute_Column) GoString() string
  • func (m *OTelAttribute_Column) Marshal() (dAtA []byte, err error)
  • func (m *OTelAttribute_Column) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelAttribute_Column) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelAttribute_Column) ProtoMessage()
  • func (m *OTelAttribute_Column) Reset()
  • func (m *OTelAttribute_Column) Size() (n int)
  • func (this *OTelAttribute_Column) String() string
  • func (m *OTelAttribute_Column) Unmarshal(dAtA []byte) error
  • func (m *OTelAttribute_Column) XXX_DiscardUnknown()
  • func (m *OTelAttribute_Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelAttribute_Column) XXX_Merge(src proto.Message)
  • func (m *OTelAttribute_Column) XXX_Size() int
  • func (m *OTelAttribute_Column) XXX_Unmarshal(b []byte) error
• type OTelAttribute_Column_
  • func (this *OTelAttribute_Column_) Equal(that interface{}) bool
  • func (this *OTelAttribute_Column_) GoString() string
  • func (m *OTelAttribute_Column_) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelAttribute_Column_) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *OTelAttribute_Column_) Size() (n int)
  • func (this *OTelAttribute_Column_) String() string
• type OTelAttribute_StringValue
  • func (this *OTelAttribute_StringValue) Equal(that interface{}) bool
  • func (this *OTelAttribute_StringValue) GoString() string
  • func (m *OTelAttribute_StringValue) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelAttribute_StringValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *OTelAttribute_StringValue) Size() (n int)
  • func (this *OTelAttribute_StringValue) String() string
• type OTelEndpointConfig
  • func (*OTelEndpointConfig) Descriptor() ([]byte, []int)
  • func (this *OTelEndpointConfig) Equal(that interface{}) bool
  • func (m *OTelEndpointConfig) GetHeaders() map[string]string
  • func (m *OTelEndpointConfig) GetInsecure() bool
  • func (m *OTelEndpointConfig) GetTimeout() int64
  • func (m *OTelEndpointConfig) GetURL() string
  • func (this *OTelEndpointConfig) GoString() string
  • func (m *OTelEndpointConfig) Marshal() (dAtA []byte, err error)
  • func (m *OTelEndpointConfig) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelEndpointConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelEndpointConfig) ProtoMessage()
  • func (m *OTelEndpointConfig) Reset()
  • func (m *OTelEndpointConfig) Size() (n int)
  • func (this *OTelEndpointConfig) String() string
  • func (m *OTelEndpointConfig) Unmarshal(dAtA []byte) error
  • func (m *OTelEndpointConfig) XXX_DiscardUnknown()
  • func (m *OTelEndpointConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelEndpointConfig) XXX_Merge(src proto.Message)
  • func (m *OTelEndpointConfig) XXX_Size() int
  • func (m *OTelEndpointConfig) XXX_Unmarshal(b []byte) error
• type OTelExportSinkOperator
  • func (*OTelExportSinkOperator) Descriptor() ([]byte, []int)
  • func (this *OTelExportSinkOperator) Equal(that interface{}) bool
  • func (m *OTelExportSinkOperator) GetEndpointConfig() *OTelEndpointConfig
  • func (m *OTelExportSinkOperator) GetMetrics() []*OTelMetric
  • func (m *OTelExportSinkOperator) GetResource() *OTelResource
  • func (m *OTelExportSinkOperator) GetSpans() []*OTelSpan
  • func (this *OTelExportSinkOperator) GoString() string
  • func (m *OTelExportSinkOperator) Marshal() (dAtA []byte, err error)
  • func (m *OTelExportSinkOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelExportSinkOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelExportSinkOperator) ProtoMessage()
  • func (m *OTelExportSinkOperator) Reset()
  • func (m *OTelExportSinkOperator) Size() (n int)
  • func (this *OTelExportSinkOperator) String() string
  • func (m *OTelExportSinkOperator) Unmarshal(dAtA []byte) error
  • func (m *OTelExportSinkOperator) XXX_DiscardUnknown()
  • func (m *OTelExportSinkOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelExportSinkOperator) XXX_Merge(src proto.Message)
  • func (m *OTelExportSinkOperator) XXX_Size() int
  • func (m *OTelExportSinkOperator) XXX_Unmarshal(b []byte) error
• type OTelMetric
  • func (*OTelMetric) Descriptor() ([]byte, []int)
  • func (this *OTelMetric) Equal(that interface{}) bool
  • func (m *OTelMetric) GetAttributes() []*OTelAttribute
  • func (m *OTelMetric) GetData() isOTelMetric_Data
  • func (m *OTelMetric) GetDescription() string
  • func (m *OTelMetric) GetGauge() *OTelMetricGauge
  • func (m *OTelMetric) GetName() string
  • func (m *OTelMetric) GetSummary() *OTelMetricSummary
  • func (m *OTelMetric) GetTimeColumnIndex() int64
  • func (m *OTelMetric) GetUnit() string
  • func (this *OTelMetric) GoString() string
  • func (m *OTelMetric) Marshal() (dAtA []byte, err error)
  • func (m *OTelMetric) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelMetric) ProtoMessage()
  • func (m *OTelMetric) Reset()
  • func (m *OTelMetric) Size() (n int)
  • func (this *OTelMetric) String() string
  • func (m *OTelMetric) Unmarshal(dAtA []byte) error
  • func (m *OTelMetric) XXX_DiscardUnknown()
  • func (m *OTelMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelMetric) XXX_Merge(src proto.Message)
  • func (*OTelMetric) XXX_OneofWrappers() []interface{}
  • func (m *OTelMetric) XXX_Size() int
  • func (m *OTelMetric) XXX_Unmarshal(b []byte) error
• type OTelMetricGauge
  • func (*OTelMetricGauge) Descriptor() ([]byte, []int)
  • func (this *OTelMetricGauge) Equal(that interface{}) bool
  • func (m *OTelMetricGauge) GetFloatColumnIndex() int64
  • func (m *OTelMetricGauge) GetIntColumnIndex() int64
  • func (m *OTelMetricGauge) GetValueColumn() isOTelMetricGauge_ValueColumn
  • func (this *OTelMetricGauge) GoString() string
  • func (m *OTelMetricGauge) Marshal() (dAtA []byte, err error)
  • func (m *OTelMetricGauge) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelMetricGauge) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelMetricGauge) ProtoMessage()
  • func (m *OTelMetricGauge) Reset()
  • func (m *OTelMetricGauge) Size() (n int)
  • func (this *OTelMetricGauge) String() string
  • func (m *OTelMetricGauge) Unmarshal(dAtA []byte) error
  • func (m *OTelMetricGauge) XXX_DiscardUnknown()
  • func (m *OTelMetricGauge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelMetricGauge) XXX_Merge(src proto.Message)
  • func (*OTelMetricGauge) XXX_OneofWrappers() []interface{}
  • func (m *OTelMetricGauge) XXX_Size() int
  • func (m *OTelMetricGauge) XXX_Unmarshal(b []byte) error
• type OTelMetricGauge_FloatColumnIndex
  • func (this *OTelMetricGauge_FloatColumnIndex) Equal(that interface{}) bool
  • func (this *OTelMetricGauge_FloatColumnIndex) GoString() string
  • func (m *OTelMetricGauge_FloatColumnIndex) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelMetricGauge_FloatColumnIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *OTelMetricGauge_FloatColumnIndex) Size() (n int)
  • func (this *OTelMetricGauge_FloatColumnIndex) String() string
• type OTelMetricGauge_IntColumnIndex
  • func (this *OTelMetricGauge_IntColumnIndex) Equal(that interface{}) bool
  • func (this *OTelMetricGauge_IntColumnIndex) GoString() string
  • func (m *OTelMetricGauge_IntColumnIndex) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelMetricGauge_IntColumnIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *OTelMetricGauge_IntColumnIndex) Size() (n int)
  • func (this *OTelMetricGauge_IntColumnIndex) String() string
• type OTelMetricSummary
  • func (*OTelMetricSummary) Descriptor() ([]byte, []int)
  • func (this *OTelMetricSummary) Equal(that interface{}) bool
  • func (m *OTelMetricSummary) GetCountColumnIndex() int64
  • func (m *OTelMetricSummary) GetQuantileValues() []*OTelMetricSummary_ValueAtQuantile
  • func (m *OTelMetricSummary) GetSumColumnIndex() int64
  • func (this *OTelMetricSummary) GoString() string
  • func (m *OTelMetricSummary) Marshal() (dAtA []byte, err error)
  • func (m *OTelMetricSummary) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelMetricSummary) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelMetricSummary) ProtoMessage()
  • func (m *OTelMetricSummary) Reset()
  • func (m *OTelMetricSummary) Size() (n int)
  • func (this *OTelMetricSummary) String() string
  • func (m *OTelMetricSummary) Unmarshal(dAtA []byte) error
  • func (m *OTelMetricSummary) XXX_DiscardUnknown()
  • func (m *OTelMetricSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelMetricSummary) XXX_Merge(src proto.Message)
  • func (m *OTelMetricSummary) XXX_Size() int
  • func (m *OTelMetricSummary) XXX_Unmarshal(b []byte) error
• type OTelMetricSummary_ValueAtQuantile
  • func (*OTelMetricSummary_ValueAtQuantile) Descriptor() ([]byte, []int)
  • func (this *OTelMetricSummary_ValueAtQuantile) Equal(that interface{}) bool
  • func (m *OTelMetricSummary_ValueAtQuantile) GetQuantile() float64
  • func (m *OTelMetricSummary_ValueAtQuantile) GetValueColumnIndex() int64
  • func (this *OTelMetricSummary_ValueAtQuantile) GoString() string
  • func (m *OTelMetricSummary_ValueAtQuantile) Marshal() (dAtA []byte, err error)
  • func (m *OTelMetricSummary_ValueAtQuantile) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelMetricSummary_ValueAtQuantile) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelMetricSummary_ValueAtQuantile) ProtoMessage()
  • func (m *OTelMetricSummary_ValueAtQuantile) Reset()
  • func (m *OTelMetricSummary_ValueAtQuantile) Size() (n int)
  • func (this *OTelMetricSummary_ValueAtQuantile) String() string
  • func (m *OTelMetricSummary_ValueAtQuantile) Unmarshal(dAtA []byte) error
  • func (m *OTelMetricSummary_ValueAtQuantile) XXX_DiscardUnknown()
  • func (m *OTelMetricSummary_ValueAtQuantile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelMetricSummary_ValueAtQuantile) XXX_Merge(src proto.Message)
  • func (m *OTelMetricSummary_ValueAtQuantile) XXX_Size() int
  • func (m *OTelMetricSummary_ValueAtQuantile) XXX_Unmarshal(b []byte) error
• type OTelMetric_Gauge
  • func (this *OTelMetric_Gauge) Equal(that interface{}) bool
  • func (this *OTelMetric_Gauge) GoString() string
  • func (m *OTelMetric_Gauge) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelMetric_Gauge) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *OTelMetric_Gauge) Size() (n int)
  • func (this *OTelMetric_Gauge) String() string
• type OTelMetric_Summary
  • func (this *OTelMetric_Summary) Equal(that interface{}) bool
  • func (this *OTelMetric_Summary) GoString() string
  • func (m *OTelMetric_Summary) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelMetric_Summary) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *OTelMetric_Summary) Size() (n int)
  • func (this *OTelMetric_Summary) String() string
• type OTelResource
  • func (*OTelResource) Descriptor() ([]byte, []int)
  • func (this *OTelResource) Equal(that interface{}) bool
  • func (m *OTelResource) GetAttributes() []*OTelAttribute
  • func (this *OTelResource) GoString() string
  • func (m *OTelResource) Marshal() (dAtA []byte, err error)
  • func (m *OTelResource) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelResource) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelResource) ProtoMessage()
  • func (m *OTelResource) Reset()
  • func (m *OTelResource) Size() (n int)
  • func (this *OTelResource) String() string
  • func (m *OTelResource) Unmarshal(dAtA []byte) error
  • func (m *OTelResource) XXX_DiscardUnknown()
  • func (m *OTelResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelResource) XXX_Merge(src proto.Message)
  • func (m *OTelResource) XXX_Size() int
  • func (m *OTelResource) XXX_Unmarshal(b []byte) error
• type OTelSpan
  • func (*OTelSpan) Descriptor() ([]byte, []int)
  • func (this *OTelSpan) Equal(that interface{}) bool
  • func (m *OTelSpan) GetAttributes() []*OTelAttribute
  • func (m *OTelSpan) GetEndTimeColumnIndex() int64
  • func (m *OTelSpan) GetKindValue() int64
  • func (m *OTelSpan) GetName() isOTelSpan_Name
  • func (m *OTelSpan) GetNameColumnIndex() int64
  • func (m *OTelSpan) GetNameString() string
  • func (m *OTelSpan) GetParentSpanIDColumn() int64
  • func (m *OTelSpan) GetSpanIDColumn() int64
  • func (m *OTelSpan) GetStartTimeColumnIndex() int64
  • func (m *OTelSpan) GetTraceIDColumn() int64
  • func (this *OTelSpan) GoString() string
  • func (m *OTelSpan) Marshal() (dAtA []byte, err error)
  • func (m *OTelSpan) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelSpan) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*OTelSpan) ProtoMessage()
  • func (m *OTelSpan) Reset()
  • func (m *OTelSpan) Size() (n int)
  • func (this *OTelSpan) String() string
  • func (m *OTelSpan) Unmarshal(dAtA []byte) error
  • func (m *OTelSpan) XXX_DiscardUnknown()
  • func (m *OTelSpan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *OTelSpan) XXX_Merge(src proto.Message)
  • func (*OTelSpan) XXX_OneofWrappers() []interface{}
  • func (m *OTelSpan) XXX_Size() int
  • func (m *OTelSpan) XXX_Unmarshal(b []byte) error
• type OTelSpan_NameColumnIndex
  • func (this *OTelSpan_NameColumnIndex) Equal(that interface{}) bool
  • func (this *OTelSpan_NameColumnIndex) GoString() string
  • func (m *OTelSpan_NameColumnIndex) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelSpan_NameColumnIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *OTelSpan_NameColumnIndex) Size() (n int)
  • func (this *OTelSpan_NameColumnIndex) String() string
• type OTelSpan_NameString
  • func (this *OTelSpan_NameString) Equal(that interface{}) bool
  • func (this *OTelSpan_NameString) GoString() string
  • func (m *OTelSpan_NameString) MarshalTo(dAtA []byte) (int, error)
  • func (m *OTelSpan_NameString) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *OTelSpan_NameString) Size() (n int)
  • func (this *OTelSpan_NameString) String() string
• type Operator
  • func (*Operator) Descriptor() ([]byte, []int)
  • func (this *Operator) Equal(that interface{}) bool
  • func (m *Operator) GetAggOp() *AggregateOperator
  • func (m *Operator) GetEmptySourceOp() *EmptySourceOperator
  • func (m *Operator) GetFilterOp() *FilterOperator
  • func (m *Operator) GetGRPCSinkOp() *GRPCSinkOperator
  • func (m *Operator) GetGRPCSourceOp() *GRPCSourceOperator
  • func (m *Operator) GetJoinOp() *JoinOperator
  • func (m *Operator) GetLimitOp() *LimitOperator
  • func (m *Operator) GetMapOp() *MapOperator
  • func (m *Operator) GetMemSinkOp() *MemorySinkOperator
  • func (m *Operator) GetMemSourceOp() *MemorySourceOperator
  • func (m *Operator) GetOTelSinkOp() *OTelExportSinkOperator
  • func (m *Operator) GetOp() isOperator_Op
  • func (m *Operator) GetOpType() OperatorType
  • func (m *Operator) GetUdtfSourceOp() *UDTFSourceOperator
  • func (m *Operator) GetUnionOp() *UnionOperator
  • func (this *Operator) GoString() string
  • func (m *Operator) Marshal() (dAtA []byte, err error)
  • func (m *Operator) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Operator) ProtoMessage()
  • func (m *Operator) Reset()
  • func (m *Operator) Size() (n int)
  • func (this *Operator) String() string
  • func (m *Operator) Unmarshal(dAtA []byte) error
  • func (m *Operator) XXX_DiscardUnknown()
  • func (m *Operator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Operator) XXX_Merge(src proto.Message)
  • func (*Operator) XXX_OneofWrappers() []interface{}
  • func (m *Operator) XXX_Size() int
  • func (m *Operator) XXX_Unmarshal(b []byte) error
• type OperatorType
  • func (OperatorType) EnumDescriptor() ([]byte, []int)
  • func (x OperatorType) String() string
• type Operator_AggOp
  • func (this *Operator_AggOp) Equal(that interface{}) bool
  • func (this *Operator_AggOp) GoString() string
  • func (m *Operator_AggOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_AggOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_AggOp) Size() (n int)
  • func (this *Operator_AggOp) String() string
• type Operator_EmptySourceOp
  • func (this *Operator_EmptySourceOp) Equal(that interface{}) bool
  • func (this *Operator_EmptySourceOp) GoString() string
  • func (m *Operator_EmptySourceOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_EmptySourceOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_EmptySourceOp) Size() (n int)
  • func (this *Operator_EmptySourceOp) String() string
• type Operator_FilterOp
  • func (this *Operator_FilterOp) Equal(that interface{}) bool
  • func (this *Operator_FilterOp) GoString() string
  • func (m *Operator_FilterOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_FilterOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_FilterOp) Size() (n int)
  • func (this *Operator_FilterOp) String() string
• type Operator_GRPCSinkOp
  • func (this *Operator_GRPCSinkOp) Equal(that interface{}) bool
  • func (this *Operator_GRPCSinkOp) GoString() string
  • func (m *Operator_GRPCSinkOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_GRPCSinkOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_GRPCSinkOp) Size() (n int)
  • func (this *Operator_GRPCSinkOp) String() string
• type Operator_GRPCSourceOp
  • func (this *Operator_GRPCSourceOp) Equal(that interface{}) bool
  • func (this *Operator_GRPCSourceOp) GoString() string
  • func (m *Operator_GRPCSourceOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_GRPCSourceOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_GRPCSourceOp) Size() (n int)
  • func (this *Operator_GRPCSourceOp) String() string
• type Operator_JoinOp
  • func (this *Operator_JoinOp) Equal(that interface{}) bool
  • func (this *Operator_JoinOp) GoString() string
  • func (m *Operator_JoinOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_JoinOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_JoinOp) Size() (n int)
  • func (this *Operator_JoinOp) String() string
• type Operator_LimitOp
  • func (this *Operator_LimitOp) Equal(that interface{}) bool
  • func (this *Operator_LimitOp) GoString() string
  • func (m *Operator_LimitOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_LimitOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_LimitOp) Size() (n int)
  • func (this *Operator_LimitOp) String() string
• type Operator_MapOp
  • func (this *Operator_MapOp) Equal(that interface{}) bool
  • func (this *Operator_MapOp) GoString() string
  • func (m *Operator_MapOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_MapOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_MapOp) Size() (n int)
  • func (this *Operator_MapOp) String() string
• type Operator_MemSinkOp
  • func (this *Operator_MemSinkOp) Equal(that interface{}) bool
  • func (this *Operator_MemSinkOp) GoString() string
  • func (m *Operator_MemSinkOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_MemSinkOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_MemSinkOp) Size() (n int)
  • func (this *Operator_MemSinkOp) String() string
• type Operator_MemSourceOp
  • func (this *Operator_MemSourceOp) Equal(that interface{}) bool
  • func (this *Operator_MemSourceOp) GoString() string
  • func (m *Operator_MemSourceOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_MemSourceOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_MemSourceOp) Size() (n int)
  • func (this *Operator_MemSourceOp) String() string
• type Operator_OTelSinkOp
  • func (this *Operator_OTelSinkOp) Equal(that interface{}) bool
  • func (this *Operator_OTelSinkOp) GoString() string
  • func (m *Operator_OTelSinkOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_OTelSinkOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_OTelSinkOp) Size() (n int)
  • func (this *Operator_OTelSinkOp) String() string
• type Operator_UdtfSourceOp
  • func (this *Operator_UdtfSourceOp) Equal(that interface{}) bool
  • func (this *Operator_UdtfSourceOp) GoString() string
  • func (m *Operator_UdtfSourceOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_UdtfSourceOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_UdtfSourceOp) Size() (n int)
  • func (this *Operator_UdtfSourceOp) String() string
• type Operator_UnionOp
  • func (this *Operator_UnionOp) Equal(that interface{}) bool
  • func (this *Operator_UnionOp) GoString() string
  • func (m *Operator_UnionOp) MarshalTo(dAtA []byte) (int, error)
  • func (m *Operator_UnionOp) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *Operator_UnionOp) Size() (n int)
  • func (this *Operator_UnionOp) String() string
• type Plan
  • func (*Plan) Descriptor() ([]byte, []int)
  • func (this *Plan) Equal(that interface{}) bool
  • func (m *Plan) GetDag() *DAG
  • func (m *Plan) GetExecutionStatusDestinations() []*Plan_ExecutionStatusDestination
  • func (m *Plan) GetIncomingAgentIDs() []*uuidpb.UUID
  • func (m *Plan) GetNodes() []*PlanFragment
  • func (m *Plan) GetPlanOptions() *PlanOptions
  • func (this *Plan) GoString() string
  • func (m *Plan) Marshal() (dAtA []byte, err error)
  • func (m *Plan) MarshalTo(dAtA []byte) (int, error)
  • func (m *Plan) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Plan) ProtoMessage()
  • func (m *Plan) Reset()
  • func (m *Plan) Size() (n int)
  • func (this *Plan) String() string
  • func (m *Plan) Unmarshal(dAtA []byte) error
  • func (m *Plan) XXX_DiscardUnknown()
  • func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Plan) XXX_Merge(src proto.Message)
  • func (m *Plan) XXX_Size() int
  • func (m *Plan) XXX_Unmarshal(b []byte) error
• type PlanFragment
  • func (*PlanFragment) Descriptor() ([]byte, []int)
  • func (this *PlanFragment) Equal(that interface{}) bool
  • func (m *PlanFragment) GetDag() *DAG
  • func (m *PlanFragment) GetId() uint64
  • func (m *PlanFragment) GetNodes() []*PlanNode
  • func (this *PlanFragment) GoString() string
  • func (m *PlanFragment) Marshal() (dAtA []byte, err error)
  • func (m *PlanFragment) MarshalTo(dAtA []byte) (int, error)
  • func (m *PlanFragment) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PlanFragment) ProtoMessage()
  • func (m *PlanFragment) Reset()
  • func (m *PlanFragment) Size() (n int)
  • func (this *PlanFragment) String() string
  • func (m *PlanFragment) Unmarshal(dAtA []byte) error
  • func (m *PlanFragment) XXX_DiscardUnknown()
  • func (m *PlanFragment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PlanFragment) XXX_Merge(src proto.Message)
  • func (m *PlanFragment) XXX_Size() int
  • func (m *PlanFragment) XXX_Unmarshal(b []byte) error
• type PlanNode
  • func (*PlanNode) Descriptor() ([]byte, []int)
  • func (this *PlanNode) Equal(that interface{}) bool
  • func (m *PlanNode) GetId() uint64
  • func (m *PlanNode) GetOp() *Operator
  • func (this *PlanNode) GoString() string
  • func (m *PlanNode) Marshal() (dAtA []byte, err error)
  • func (m *PlanNode) MarshalTo(dAtA []byte) (int, error)
  • func (m *PlanNode) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PlanNode) ProtoMessage()
  • func (m *PlanNode) Reset()
  • func (m *PlanNode) Size() (n int)
  • func (this *PlanNode) String() string
  • func (m *PlanNode) Unmarshal(dAtA []byte) error
  • func (m *PlanNode) XXX_DiscardUnknown()
  • func (m *PlanNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PlanNode) XXX_Merge(src proto.Message)
  • func (m *PlanNode) XXX_Size() int
  • func (m *PlanNode) XXX_Unmarshal(b []byte) error
• type PlanOptions
  • func (*PlanOptions) Descriptor() ([]byte, []int)
  • func (this *PlanOptions) Equal(that interface{}) bool
  • func (m *PlanOptions) GetAnalyze() bool
  • func (m *PlanOptions) GetExplain() bool
  • func (m *PlanOptions) GetMaxOutputRowsPerTable() int64
  • func (this *PlanOptions) GoString() string
  • func (m *PlanOptions) Marshal() (dAtA []byte, err error)
  • func (m *PlanOptions) MarshalTo(dAtA []byte) (int, error)
  • func (m *PlanOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*PlanOptions) ProtoMessage()
  • func (m *PlanOptions) Reset()
  • func (m *PlanOptions) Size() (n int)
  • func (this *PlanOptions) String() string
  • func (m *PlanOptions) Unmarshal(dAtA []byte) error
  • func (m *PlanOptions) XXX_DiscardUnknown()
  • func (m *PlanOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PlanOptions) XXX_Merge(src proto.Message)
  • func (m *PlanOptions) XXX_Size() int
  • func (m *PlanOptions) XXX_Unmarshal(b []byte) error
• type Plan_ExecutionStatusDestination
  • func (*Plan_ExecutionStatusDestination) Descriptor() ([]byte, []int)
  • func (this *Plan_ExecutionStatusDestination) Equal(that interface{}) bool
  • func (m *Plan_ExecutionStatusDestination) GetGrpcAddress() string
  • func (m *Plan_ExecutionStatusDestination) GetSslTargetname() string
  • func (this *Plan_ExecutionStatusDestination) GoString() string
  • func (m *Plan_ExecutionStatusDestination) Marshal() (dAtA []byte, err error)
  • func (m *Plan_ExecutionStatusDestination) MarshalTo(dAtA []byte) (int, error)
  • func (m *Plan_ExecutionStatusDestination) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Plan_ExecutionStatusDestination) ProtoMessage()
  • func (m *Plan_ExecutionStatusDestination) Reset()
  • func (m *Plan_ExecutionStatusDestination) Size() (n int)
  • func (this *Plan_ExecutionStatusDestination) String() string
  • func (m *Plan_ExecutionStatusDestination) Unmarshal(dAtA []byte) error
  • func (m *Plan_ExecutionStatusDestination) XXX_DiscardUnknown()
  • func (m *Plan_ExecutionStatusDestination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Plan_ExecutionStatusDestination) XXX_Merge(src proto.Message)
  • func (m *Plan_ExecutionStatusDestination) XXX_Size() int
  • func (m *Plan_ExecutionStatusDestination) XXX_Unmarshal(b []byte) error
• type ScalarExpression
  • func (*ScalarExpression) Descriptor() ([]byte, []int)
  • func (this *ScalarExpression) Equal(that interface{}) bool
  • func (m *ScalarExpression) GetColumn() *Column
  • func (m *ScalarExpression) GetConstant() *ScalarValue
  • func (m *ScalarExpression) GetFunc() *ScalarFunc
  • func (m *ScalarExpression) GetValue() isScalarExpression_Value
  • func (this *ScalarExpression) GoString() string
  • func (m *ScalarExpression) Marshal() (dAtA []byte, err error)
  • func (m *ScalarExpression) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarExpression) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScalarExpression) ProtoMessage()
  • func (m *ScalarExpression) Reset()
  • func (m *ScalarExpression) Size() (n int)
  • func (this *ScalarExpression) String() string
  • func (m *ScalarExpression) Unmarshal(dAtA []byte) error
  • func (m *ScalarExpression) XXX_DiscardUnknown()
  • func (m *ScalarExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScalarExpression) XXX_Merge(src proto.Message)
  • func (*ScalarExpression) XXX_OneofWrappers() []interface{}
  • func (m *ScalarExpression) XXX_Size() int
  • func (m *ScalarExpression) XXX_Unmarshal(b []byte) error
• type ScalarExpression_Column
  • func (this *ScalarExpression_Column) Equal(that interface{}) bool
  • func (this *ScalarExpression_Column) GoString() string
  • func (m *ScalarExpression_Column) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarExpression_Column) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarExpression_Column) Size() (n int)
  • func (this *ScalarExpression_Column) String() string
• type ScalarExpression_Constant
  • func (this *ScalarExpression_Constant) Equal(that interface{}) bool
  • func (this *ScalarExpression_Constant) GoString() string
  • func (m *ScalarExpression_Constant) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarExpression_Constant) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarExpression_Constant) Size() (n int)
  • func (this *ScalarExpression_Constant) String() string
• type ScalarExpression_Func
  • func (this *ScalarExpression_Func) Equal(that interface{}) bool
  • func (this *ScalarExpression_Func) GoString() string
  • func (m *ScalarExpression_Func) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarExpression_Func) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarExpression_Func) Size() (n int)
  • func (this *ScalarExpression_Func) String() string
• type ScalarFunc
  • func (*ScalarFunc) Descriptor() ([]byte, []int)
  • func (this *ScalarFunc) Equal(that interface{}) bool
  • func (m *ScalarFunc) GetArgs() []*ScalarExpression
  • func (m *ScalarFunc) GetArgsDataTypes() []typespb.DataType
  • func (m *ScalarFunc) GetId() int64
  • func (m *ScalarFunc) GetInitArgs() []*ScalarValue
  • func (m *ScalarFunc) GetName() string
  • func (this *ScalarFunc) GoString() string
  • func (m *ScalarFunc) Marshal() (dAtA []byte, err error)
  • func (m *ScalarFunc) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarFunc) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScalarFunc) ProtoMessage()
  • func (m *ScalarFunc) Reset()
  • func (m *ScalarFunc) Size() (n int)
  • func (this *ScalarFunc) String() string
  • func (m *ScalarFunc) Unmarshal(dAtA []byte) error
  • func (m *ScalarFunc) XXX_DiscardUnknown()
  • func (m *ScalarFunc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScalarFunc) XXX_Merge(src proto.Message)
  • func (m *ScalarFunc) XXX_Size() int
  • func (m *ScalarFunc) XXX_Unmarshal(b []byte) error
• type ScalarValue
  • func (*ScalarValue) Descriptor() ([]byte, []int)
  • func (this *ScalarValue) Equal(that interface{}) bool
  • func (m *ScalarValue) GetBoolValue() bool
  • func (m *ScalarValue) GetDataType() typespb.DataType
  • func (m *ScalarValue) GetFloat64Value() float64
  • func (m *ScalarValue) GetInt64Value() int64
  • func (m *ScalarValue) GetStringValue() string
  • func (m *ScalarValue) GetTime64NsValue() int64
  • func (m *ScalarValue) GetUint128Value() *typespb.UInt128
  • func (m *ScalarValue) GetValue() isScalarValue_Value
  • func (this *ScalarValue) GoString() string
  • func (m *ScalarValue) Marshal() (dAtA []byte, err error)
  • func (m *ScalarValue) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ScalarValue) ProtoMessage()
  • func (m *ScalarValue) Reset()
  • func (m *ScalarValue) Size() (n int)
  • func (this *ScalarValue) String() string
  • func (m *ScalarValue) Unmarshal(dAtA []byte) error
  • func (m *ScalarValue) XXX_DiscardUnknown()
  • func (m *ScalarValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ScalarValue) XXX_Merge(src proto.Message)
  • func (*ScalarValue) XXX_OneofWrappers() []interface{}
  • func (m *ScalarValue) XXX_Size() int
  • func (m *ScalarValue) XXX_Unmarshal(b []byte) error
• type ScalarValue_BoolValue
  • func (this *ScalarValue_BoolValue) Equal(that interface{}) bool
  • func (this *ScalarValue_BoolValue) GoString() string
  • func (m *ScalarValue_BoolValue) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarValue_BoolValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarValue_BoolValue) Size() (n int)
  • func (this *ScalarValue_BoolValue) String() string
• type ScalarValue_Float64Value
  • func (this *ScalarValue_Float64Value) Equal(that interface{}) bool
  • func (this *ScalarValue_Float64Value) GoString() string
  • func (m *ScalarValue_Float64Value) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarValue_Float64Value) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarValue_Float64Value) Size() (n int)
  • func (this *ScalarValue_Float64Value) String() string
• type ScalarValue_Int64Value
  • func (this *ScalarValue_Int64Value) Equal(that interface{}) bool
  • func (this *ScalarValue_Int64Value) GoString() string
  • func (m *ScalarValue_Int64Value) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarValue_Int64Value) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarValue_Int64Value) Size() (n int)
  • func (this *ScalarValue_Int64Value) String() string
• type ScalarValue_StringValue
  • func (this *ScalarValue_StringValue) Equal(that interface{}) bool
  • func (this *ScalarValue_StringValue) GoString() string
  • func (m *ScalarValue_StringValue) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarValue_StringValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarValue_StringValue) Size() (n int)
  • func (this *ScalarValue_StringValue) String() string
• type ScalarValue_Time64NsValue
  • func (this *ScalarValue_Time64NsValue) Equal(that interface{}) bool
  • func (this *ScalarValue_Time64NsValue) GoString() string
  • func (m *ScalarValue_Time64NsValue) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarValue_Time64NsValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarValue_Time64NsValue) Size() (n int)
  • func (this *ScalarValue_Time64NsValue) String() string
• type ScalarValue_Uint128Value
  • func (this *ScalarValue_Uint128Value) Equal(that interface{}) bool
  • func (this *ScalarValue_Uint128Value) GoString() string
  • func (m *ScalarValue_Uint128Value) MarshalTo(dAtA []byte) (int, error)
  • func (m *ScalarValue_Uint128Value) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (m *ScalarValue_Uint128Value) Size() (n int)
  • func (this *ScalarValue_Uint128Value) String() string
• type UDTFSourceOperator
  • func (*UDTFSourceOperator) Descriptor() ([]byte, []int)
  • func (this *UDTFSourceOperator) Equal(that interface{}) bool
  • func (m *UDTFSourceOperator) GetArgValues() []*ScalarValue
  • func (m *UDTFSourceOperator) GetName() string
  • func (this *UDTFSourceOperator) GoString() string
  • func (m *UDTFSourceOperator) Marshal() (dAtA []byte, err error)
  • func (m *UDTFSourceOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *UDTFSourceOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UDTFSourceOperator) ProtoMessage()
  • func (m *UDTFSourceOperator) Reset()
  • func (m *UDTFSourceOperator) Size() (n int)
  • func (this *UDTFSourceOperator) String() string
  • func (m *UDTFSourceOperator) Unmarshal(dAtA []byte) error
  • func (m *UDTFSourceOperator) XXX_DiscardUnknown()
  • func (m *UDTFSourceOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UDTFSourceOperator) XXX_Merge(src proto.Message)
  • func (m *UDTFSourceOperator) XXX_Size() int
  • func (m *UDTFSourceOperator) XXX_Unmarshal(b []byte) error
• type UnionOperator
  • func (*UnionOperator) Descriptor() ([]byte, []int)
  • func (this *UnionOperator) Equal(that interface{}) bool
  • func (m *UnionOperator) GetColumnMappings() []*UnionOperator_ColumnMapping
  • func (m *UnionOperator) GetColumnNames() []string
  • func (m *UnionOperator) GetRowsPerBatch() uint64
  • func (this *UnionOperator) GoString() string
  • func (m *UnionOperator) Marshal() (dAtA []byte, err error)
  • func (m *UnionOperator) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnionOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnionOperator) ProtoMessage()
  • func (m *UnionOperator) Reset()
  • func (m *UnionOperator) Size() (n int)
  • func (this *UnionOperator) String() string
  • func (m *UnionOperator) Unmarshal(dAtA []byte) error
  • func (m *UnionOperator) XXX_DiscardUnknown()
  • func (m *UnionOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnionOperator) XXX_Merge(src proto.Message)
  • func (m *UnionOperator) XXX_Size() int
  • func (m *UnionOperator) XXX_Unmarshal(b []byte) error
• type UnionOperator_ColumnMapping
  • func (*UnionOperator_ColumnMapping) Descriptor() ([]byte, []int)
  • func (this *UnionOperator_ColumnMapping) Equal(that interface{}) bool
  • func (m *UnionOperator_ColumnMapping) GetColumnIndexes() []int64
  • func (this *UnionOperator_ColumnMapping) GoString() string
  • func (m *UnionOperator_ColumnMapping) Marshal() (dAtA []byte, err error)
  • func (m *UnionOperator_ColumnMapping) MarshalTo(dAtA []byte) (int, error)
  • func (m *UnionOperator_ColumnMapping) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*UnionOperator_ColumnMapping) ProtoMessage()
  • func (m *UnionOperator_ColumnMapping) Reset()
  • func (m *UnionOperator_ColumnMapping) Size() (n int)
  • func (this *UnionOperator_ColumnMapping) String() string
  • func (m *UnionOperator_ColumnMapping) Unmarshal(dAtA []byte) error
  • func (m *UnionOperator_ColumnMapping) XXX_DiscardUnknown()
  • func (m *UnionOperator_ColumnMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *UnionOperator_ColumnMapping) XXX_Merge(src proto.Message)
  • func (m *UnionOperator_ColumnMapping) XXX_Size() int
  • func (m *UnionOperator_ColumnMapping) XXX_Unmarshal(b []byte) error

Variables

var (
	ErrInvalidLengthPlan        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPlan          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPlan = fmt.Errorf("proto: unexpected end of group")
)

var JoinOperator_JoinType_name = map[int32]string{
	0: "INNER",
	1: "LEFT_OUTER",
	3: "FULL_OUTER",
}

var JoinOperator_JoinType_value = map[string]int32{
	"INNER":      0,
	"LEFT_OUTER": 1,
	"FULL_OUTER": 3,
}

var OperatorType_name = map[int32]string{
	0:    "OPERATOR_TYPE_UNKNOWN",
	1000: "MEMORY_SOURCE_OPERATOR",
	1100: "GRPC_SOURCE_OPERATOR",
	1200: "UDTF_SOURCE_OPERATOR",
	1300: "EMPTY_SOURCE_OPERATOR",
	2000: "MAP_OPERATOR",
	2100: "AGGREGATE_OPERATOR",
	2200: "FILTER_OPERATOR",
	2300: "LIMIT_OPERATOR",
	2400: "UNION_OPERATOR",
	2500: "JOIN_OPERATOR",
	9000: "MEMORY_SINK_OPERATOR",
	9100: "GRPC_SINK_OPERATOR",
	9200: "OTEL_EXPORT_SINK_OPERATOR",
}

var OperatorType_value = map[string]int32{
	"OPERATOR_TYPE_UNKNOWN":     0,
	"MEMORY_SOURCE_OPERATOR":    1000,
	"GRPC_SOURCE_OPERATOR":      1100,
	"UDTF_SOURCE_OPERATOR":      1200,
	"EMPTY_SOURCE_OPERATOR":     1300,
	"MAP_OPERATOR":              2000,
	"AGGREGATE_OPERATOR":        2100,
	"FILTER_OPERATOR":           2200,
	"LIMIT_OPERATOR":            2300,
	"UNION_OPERATOR":            2400,
	"JOIN_OPERATOR":             2500,
	"MEMORY_SINK_OPERATOR":      9000,
	"GRPC_SINK_OPERATOR":        9100,
	"OTEL_EXPORT_SINK_OPERATOR": 9200,
}

Types

type AggregateExpression

type AggregateExpression struct {
	Name          string                     `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	InitArgs      []*ScalarValue             `protobuf:"bytes,4,rep,name=init_args,json=initArgs,proto3" json:"init_args,omitempty"`
	Args          []*AggregateExpression_Arg `protobuf:"bytes,5,rep,name=args,proto3" json:"args,omitempty"`
	Id            int64                      `protobuf:"varint,6,opt,name=id,proto3" json:"id,omitempty"`
	ArgsDataTypes []typespb.DataType         `` /* 133-byte string literal not displayed */
}

func (*AggregateExpression) Descriptor

func (*AggregateExpression) Descriptor() ([]byte, []int)

func (*AggregateExpression) Equal

func (this *AggregateExpression) Equal(that interface{}) bool

func (*AggregateExpression) GetArgs

func (m *AggregateExpression) GetArgs() []*AggregateExpression_Arg

func (*AggregateExpression) GetArgsDataTypes

func (m *AggregateExpression) GetArgsDataTypes() []typespb.DataType

func (*AggregateExpression) GetId

func (m *AggregateExpression) GetId() int64

func (*AggregateExpression) GetInitArgs

func (m *AggregateExpression) GetInitArgs() []*ScalarValue

func (*AggregateExpression) GetName

func (m *AggregateExpression) GetName() string

func (*AggregateExpression) GoString

func (this *AggregateExpression) GoString() string

func (*AggregateExpression) Marshal

func (m *AggregateExpression) Marshal() (dAtA []byte, err error)

func (*AggregateExpression) MarshalTo

func (m *AggregateExpression) MarshalTo(dAtA []byte) (int, error)

func (*AggregateExpression) MarshalToSizedBuffer

func (m *AggregateExpression) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AggregateExpression) ProtoMessage

func (*AggregateExpression) ProtoMessage()

func (*AggregateExpression) Reset

func (m *AggregateExpression) Reset()

func (*AggregateExpression) Size

func (m *AggregateExpression) Size() (n int)

func (*AggregateExpression) String

func (this *AggregateExpression) String() string

func (*AggregateExpression) Unmarshal

func (m *AggregateExpression) Unmarshal(dAtA []byte) error

func (*AggregateExpression) XXX_DiscardUnknown

func (m *AggregateExpression) XXX_DiscardUnknown()

func (*AggregateExpression) XXX_Marshal

func (m *AggregateExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AggregateExpression) XXX_Merge

func (m *AggregateExpression) XXX_Merge(src proto.Message)

func (*AggregateExpression) XXX_Size

func (m *AggregateExpression) XXX_Size() int

func (*AggregateExpression) XXX_Unmarshal

func (m *AggregateExpression) XXX_Unmarshal(b []byte) error

type AggregateExpression_Arg

type AggregateExpression_Arg struct {
	// Types that are valid to be assigned to Value:
	//
	//	*AggregateExpression_Arg_Constant
	//	*AggregateExpression_Arg_Column
	Value isAggregateExpression_Arg_Value `protobuf_oneof:"value"`
}

func (*AggregateExpression_Arg) Descriptor

func (*AggregateExpression_Arg) Descriptor() ([]byte, []int)

func (*AggregateExpression_Arg) Equal

func (this *AggregateExpression_Arg) Equal(that interface{}) bool

func (*AggregateExpression_Arg) GetColumn

func (m *AggregateExpression_Arg) GetColumn() *Column

func (*AggregateExpression_Arg) GetConstant

func (m *AggregateExpression_Arg) GetConstant() *ScalarValue

func (*AggregateExpression_Arg) GetValue

func (m *AggregateExpression_Arg) GetValue() isAggregateExpression_Arg_Value

func (*AggregateExpression_Arg) GoString

func (this *AggregateExpression_Arg) GoString() string

func (*AggregateExpression_Arg) Marshal

func (m *AggregateExpression_Arg) Marshal() (dAtA []byte, err error)

func (*AggregateExpression_Arg) MarshalTo

func (m *AggregateExpression_Arg) MarshalTo(dAtA []byte) (int, error)

func (*AggregateExpression_Arg) MarshalToSizedBuffer

func (m *AggregateExpression_Arg) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AggregateExpression_Arg) ProtoMessage

func (*AggregateExpression_Arg) ProtoMessage()

func (*AggregateExpression_Arg) Reset

func (m *AggregateExpression_Arg) Reset()

func (*AggregateExpression_Arg) Size

func (m *AggregateExpression_Arg) Size() (n int)

func (*AggregateExpression_Arg) String

func (this *AggregateExpression_Arg) String() string

func (*AggregateExpression_Arg) Unmarshal

func (m *AggregateExpression_Arg) Unmarshal(dAtA []byte) error

func (*AggregateExpression_Arg) XXX_DiscardUnknown

func (m *AggregateExpression_Arg) XXX_DiscardUnknown()

func (*AggregateExpression_Arg) XXX_Marshal

func (m *AggregateExpression_Arg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AggregateExpression_Arg) XXX_Merge

func (m *AggregateExpression_Arg) XXX_Merge(src proto.Message)

func (*AggregateExpression_Arg) XXX_OneofWrappers

func (*AggregateExpression_Arg) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*AggregateExpression_Arg) XXX_Size

func (m *AggregateExpression_Arg) XXX_Size() int

func (*AggregateExpression_Arg) XXX_Unmarshal

func (m *AggregateExpression_Arg) XXX_Unmarshal(b []byte) error

type AggregateExpression_Arg_Column

type AggregateExpression_Arg_Column struct {
	Column *Column `protobuf:"bytes,2,opt,name=column,proto3,oneof" json:"column,omitempty"`
}

func (*AggregateExpression_Arg_Column) Equal

func (this *AggregateExpression_Arg_Column) Equal(that interface{}) bool

func (*AggregateExpression_Arg_Column) GoString

func (this *AggregateExpression_Arg_Column) GoString() string

func (*AggregateExpression_Arg_Column) MarshalTo

func (m *AggregateExpression_Arg_Column) MarshalTo(dAtA []byte) (int, error)

func (*AggregateExpression_Arg_Column) MarshalToSizedBuffer

func (m *AggregateExpression_Arg_Column) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AggregateExpression_Arg_Column) Size

func (m *AggregateExpression_Arg_Column) Size() (n int)

func (*AggregateExpression_Arg_Column) String

func (this *AggregateExpression_Arg_Column) String() string

type AggregateExpression_Arg_Constant

type AggregateExpression_Arg_Constant struct {
	Constant *ScalarValue `protobuf:"bytes,1,opt,name=constant,proto3,oneof" json:"constant,omitempty"`
}

func (*AggregateExpression_Arg_Constant) Equal

func (this *AggregateExpression_Arg_Constant) Equal(that interface{}) bool

func (*AggregateExpression_Arg_Constant) GoString

func (this *AggregateExpression_Arg_Constant) GoString() string

func (*AggregateExpression_Arg_Constant) MarshalTo

func (m *AggregateExpression_Arg_Constant) MarshalTo(dAtA []byte) (int, error)

func (*AggregateExpression_Arg_Constant) MarshalToSizedBuffer

func (m *AggregateExpression_Arg_Constant) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AggregateExpression_Arg_Constant) Size

func (m *AggregateExpression_Arg_Constant) Size() (n int)

func (*AggregateExpression_Arg_Constant) String

func (this *AggregateExpression_Arg_Constant) String() string

type AggregateOperator

type AggregateOperator struct {
	Values          []*AggregateExpression `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	Groups          []*Column              `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
	GroupNames      []string               `protobuf:"bytes,3,rep,name=group_names,json=groupNames,proto3" json:"group_names,omitempty"`
	ValueNames      []string               `protobuf:"bytes,4,rep,name=value_names,json=valueNames,proto3" json:"value_names,omitempty"`
	Windowed        bool                   `protobuf:"varint,5,opt,name=windowed,proto3" json:"windowed,omitempty"`
	PartialAgg      bool                   `protobuf:"varint,6,opt,name=partial_agg,json=partialAgg,proto3" json:"partial_agg,omitempty"`
	FinalizeResults bool                   `protobuf:"varint,7,opt,name=finalize_results,json=finalizeResults,proto3" json:"finalize_results,omitempty"`
}

func (*AggregateOperator) Descriptor

func (*AggregateOperator) Descriptor() ([]byte, []int)

func (*AggregateOperator) Equal

func (this *AggregateOperator) Equal(that interface{}) bool

func (*AggregateOperator) GetFinalizeResults

func (m *AggregateOperator) GetFinalizeResults() bool

func (*AggregateOperator) GetGroupNames

func (m *AggregateOperator) GetGroupNames() []string

func (*AggregateOperator) GetGroups

func (m *AggregateOperator) GetGroups() []*Column

func (*AggregateOperator) GetPartialAgg

func (m *AggregateOperator) GetPartialAgg() bool

func (*AggregateOperator) GetValueNames

func (m *AggregateOperator) GetValueNames() []string

func (*AggregateOperator) GetValues

func (m *AggregateOperator) GetValues() []*AggregateExpression

func (*AggregateOperator) GetWindowed

func (m *AggregateOperator) GetWindowed() bool

func (*AggregateOperator) GoString

func (this *AggregateOperator) GoString() string

func (*AggregateOperator) Marshal

func (m *AggregateOperator) Marshal() (dAtA []byte, err error)

func (*AggregateOperator) MarshalTo

func (m *AggregateOperator) MarshalTo(dAtA []byte) (int, error)

func (*AggregateOperator) MarshalToSizedBuffer

func (m *AggregateOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AggregateOperator) ProtoMessage

func (*AggregateOperator) ProtoMessage()

func (*AggregateOperator) Reset

func (m *AggregateOperator) Reset()

func (*AggregateOperator) Size

func (m *AggregateOperator) Size() (n int)

func (*AggregateOperator) String

func (this *AggregateOperator) String() string

func (*AggregateOperator) Unmarshal

func (m *AggregateOperator) Unmarshal(dAtA []byte) error

func (*AggregateOperator) XXX_DiscardUnknown

func (m *AggregateOperator) XXX_DiscardUnknown()

func (*AggregateOperator) XXX_Marshal

func (m *AggregateOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AggregateOperator) XXX_Merge

func (m *AggregateOperator) XXX_Merge(src proto.Message)

func (*AggregateOperator) XXX_Size

func (m *AggregateOperator) XXX_Size() int

func (*AggregateOperator) XXX_Unmarshal

func (m *AggregateOperator) XXX_Unmarshal(b []byte) error

type Column

type Column struct {
	Node  uint64 `protobuf:"varint,1,opt,name=node,proto3" json:"node,omitempty"`
	Index uint64 `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
}

func (*Column) Descriptor

func (*Column) Descriptor() ([]byte, []int)

func (*Column) Equal

func (this *Column) Equal(that interface{}) bool

func (*Column) GetIndex

func (m *Column) GetIndex() uint64

func (*Column) GetNode

func (m *Column) GetNode() uint64

func (*Column) GoString

func (this *Column) GoString() string

func (*Column) Marshal

func (m *Column) Marshal() (dAtA []byte, err error)

func (*Column) MarshalTo

func (m *Column) MarshalTo(dAtA []byte) (int, error)

func (*Column) MarshalToSizedBuffer

func (m *Column) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Column) ProtoMessage

func (*Column) ProtoMessage()

func (*Column) Reset

func (m *Column) Reset()

func (*Column) Size

func (m *Column) Size() (n int)

func (*Column) String

func (this *Column) String() string

func (*Column) Unmarshal

func (m *Column) Unmarshal(dAtA []byte) error

func (*Column) XXX_DiscardUnknown

func (m *Column) XXX_DiscardUnknown()

func (*Column) XXX_Marshal

func (m *Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Column) XXX_Merge

func (m *Column) XXX_Merge(src proto.Message)

func (*Column) XXX_Size

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal

func (m *Column) XXX_Unmarshal(b []byte) error

type DAG

type DAG struct {
	Nodes []*DAG_DAGNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

func (*DAG) Descriptor

func (*DAG) Descriptor() ([]byte, []int)

func (*DAG) Equal

func (this *DAG) Equal(that interface{}) bool

func (*DAG) GetNodes

func (m *DAG) GetNodes() []*DAG_DAGNode

func (*DAG) GoString

func (this *DAG) GoString() string

func (*DAG) Marshal

func (m *DAG) Marshal() (dAtA []byte, err error)

func (*DAG) MarshalTo

func (m *DAG) MarshalTo(dAtA []byte) (int, error)

func (*DAG) MarshalToSizedBuffer

func (m *DAG) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DAG) ProtoMessage

func (*DAG) ProtoMessage()

func (*DAG) Reset

func (m *DAG) Reset()

func (*DAG) Size

func (m *DAG) Size() (n int)

func (*DAG) String

func (this *DAG) String() string

func (*DAG) Unmarshal

func (m *DAG) Unmarshal(dAtA []byte) error

func (*DAG) XXX_DiscardUnknown

func (m *DAG) XXX_DiscardUnknown()

func (*DAG) XXX_Marshal

func (m *DAG) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DAG) XXX_Merge

func (m *DAG) XXX_Merge(src proto.Message)

func (*DAG) XXX_Size

func (m *DAG) XXX_Size() int

func (*DAG) XXX_Unmarshal

func (m *DAG) XXX_Unmarshal(b []byte) error

type DAG_DAGNode

type DAG_DAGNode struct {
	Id             uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	SortedParents  []uint64 `protobuf:"varint,4,rep,packed,name=sorted_parents,json=sortedParents,proto3" json:"sorted_parents,omitempty"`
	SortedChildren []uint64 `protobuf:"varint,3,rep,packed,name=sorted_children,json=sortedChildren,proto3" json:"sorted_children,omitempty"`
}

func (*DAG_DAGNode) Descriptor

func (*DAG_DAGNode) Descriptor() ([]byte, []int)

func (*DAG_DAGNode) Equal

func (this *DAG_DAGNode) Equal(that interface{}) bool

func (*DAG_DAGNode) GetId

func (m *DAG_DAGNode) GetId() uint64

func (*DAG_DAGNode) GetSortedChildren

func (m *DAG_DAGNode) GetSortedChildren() []uint64

func (*DAG_DAGNode) GetSortedParents

func (m *DAG_DAGNode) GetSortedParents() []uint64

func (*DAG_DAGNode) GoString

func (this *DAG_DAGNode) GoString() string

func (*DAG_DAGNode) Marshal

func (m *DAG_DAGNode) Marshal() (dAtA []byte, err error)

func (*DAG_DAGNode) MarshalTo

func (m *DAG_DAGNode) MarshalTo(dAtA []byte) (int, error)

func (*DAG_DAGNode) MarshalToSizedBuffer

func (m *DAG_DAGNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DAG_DAGNode) ProtoMessage

func (*DAG_DAGNode) ProtoMessage()

func (*DAG_DAGNode) Reset

func (m *DAG_DAGNode) Reset()

func (*DAG_DAGNode) Size

func (m *DAG_DAGNode) Size() (n int)

func (*DAG_DAGNode) String

func (this *DAG_DAGNode) String() string

func (*DAG_DAGNode) Unmarshal

func (m *DAG_DAGNode) Unmarshal(dAtA []byte) error

func (*DAG_DAGNode) XXX_DiscardUnknown

func (m *DAG_DAGNode) XXX_DiscardUnknown()

func (*DAG_DAGNode) XXX_Marshal

func (m *DAG_DAGNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DAG_DAGNode) XXX_Merge

func (m *DAG_DAGNode) XXX_Merge(src proto.Message)

func (*DAG_DAGNode) XXX_Size

func (m *DAG_DAGNode) XXX_Size() int

func (*DAG_DAGNode) XXX_Unmarshal

func (m *DAG_DAGNode) XXX_Unmarshal(b []byte) error

type EmptySourceOperator

type EmptySourceOperator struct {
	ColumnNames []string           `protobuf:"bytes,1,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	ColumnTypes []typespb.DataType `protobuf:"varint,2,rep,packed,name=column_types,json=columnTypes,proto3,enum=px.types.DataType" json:"column_types,omitempty"`
}

func (*EmptySourceOperator) Descriptor

func (*EmptySourceOperator) Descriptor() ([]byte, []int)

func (*EmptySourceOperator) Equal

func (this *EmptySourceOperator) Equal(that interface{}) bool

func (*EmptySourceOperator) GetColumnNames

func (m *EmptySourceOperator) GetColumnNames() []string

func (*EmptySourceOperator) GetColumnTypes

func (m *EmptySourceOperator) GetColumnTypes() []typespb.DataType

func (*EmptySourceOperator) GoString

func (this *EmptySourceOperator) GoString() string

func (*EmptySourceOperator) Marshal

func (m *EmptySourceOperator) Marshal() (dAtA []byte, err error)

func (*EmptySourceOperator) MarshalTo

func (m *EmptySourceOperator) MarshalTo(dAtA []byte) (int, error)

func (*EmptySourceOperator) MarshalToSizedBuffer

func (m *EmptySourceOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EmptySourceOperator) ProtoMessage

func (*EmptySourceOperator) ProtoMessage()

func (*EmptySourceOperator) Reset

func (m *EmptySourceOperator) Reset()

func (*EmptySourceOperator) Size

func (m *EmptySourceOperator) Size() (n int)

func (*EmptySourceOperator) String

func (this *EmptySourceOperator) String() string

func (*EmptySourceOperator) Unmarshal

func (m *EmptySourceOperator) Unmarshal(dAtA []byte) error

func (*EmptySourceOperator) XXX_DiscardUnknown

func (m *EmptySourceOperator) XXX_DiscardUnknown()

func (*EmptySourceOperator) XXX_Marshal

func (m *EmptySourceOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EmptySourceOperator) XXX_Merge

func (m *EmptySourceOperator) XXX_Merge(src proto.Message)

func (*EmptySourceOperator) XXX_Size

func (m *EmptySourceOperator) XXX_Size() int

func (*EmptySourceOperator) XXX_Unmarshal

func (m *EmptySourceOperator) XXX_Unmarshal(b []byte) error

type FilterOperator

type FilterOperator struct {
	Expression *ScalarExpression `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	Columns    []*Column         `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
}

func (*FilterOperator) Descriptor

func (*FilterOperator) Descriptor() ([]byte, []int)

func (*FilterOperator) Equal

func (this *FilterOperator) Equal(that interface{}) bool

func (*FilterOperator) GetColumns

func (m *FilterOperator) GetColumns() []*Column

func (*FilterOperator) GetExpression

func (m *FilterOperator) GetExpression() *ScalarExpression

func (*FilterOperator) GoString

func (this *FilterOperator) GoString() string

func (*FilterOperator) Marshal

func (m *FilterOperator) Marshal() (dAtA []byte, err error)

func (*FilterOperator) MarshalTo

func (m *FilterOperator) MarshalTo(dAtA []byte) (int, error)

func (*FilterOperator) MarshalToSizedBuffer

func (m *FilterOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FilterOperator) ProtoMessage

func (*FilterOperator) ProtoMessage()

func (*FilterOperator) Reset

func (m *FilterOperator) Reset()

func (*FilterOperator) Size

func (m *FilterOperator) Size() (n int)

func (*FilterOperator) String

func (this *FilterOperator) String() string

func (*FilterOperator) Unmarshal

func (m *FilterOperator) Unmarshal(dAtA []byte) error

func (*FilterOperator) XXX_DiscardUnknown

func (m *FilterOperator) XXX_DiscardUnknown()

func (*FilterOperator) XXX_Marshal

func (m *FilterOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilterOperator) XXX_Merge

func (m *FilterOperator) XXX_Merge(src proto.Message)

func (*FilterOperator) XXX_Size

func (m *FilterOperator) XXX_Size() int

func (*FilterOperator) XXX_Unmarshal

func (m *FilterOperator) XXX_Unmarshal(b []byte) error

type GRPCSinkOperator

type GRPCSinkOperator struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Types that are valid to be assigned to Destination:
	//
	//	*GRPCSinkOperator_GRPCSourceID
	//	*GRPCSinkOperator_OutputTable
	Destination       isGRPCSinkOperator_Destination          `protobuf_oneof:"destination"`
	ConnectionOptions *GRPCSinkOperator_GRPCConnectionOptions `protobuf:"bytes,5,opt,name=connection_options,json=connectionOptions,proto3" json:"connection_options,omitempty"`
}

func (*GRPCSinkOperator) Descriptor

func (*GRPCSinkOperator) Descriptor() ([]byte, []int)

func (*GRPCSinkOperator) Equal

func (this *GRPCSinkOperator) Equal(that interface{}) bool

func (*GRPCSinkOperator) GetAddress

func (m *GRPCSinkOperator) GetAddress() string

func (*GRPCSinkOperator) GetConnectionOptions

func (m *GRPCSinkOperator) GetConnectionOptions() *GRPCSinkOperator_GRPCConnectionOptions

func (*GRPCSinkOperator) GetDestination

func (m *GRPCSinkOperator) GetDestination() isGRPCSinkOperator_Destination

func (*GRPCSinkOperator) GetGRPCSourceID

func (m *GRPCSinkOperator) GetGRPCSourceID() uint64

func (*GRPCSinkOperator) GetOutputTable

func (m *GRPCSinkOperator) GetOutputTable() *GRPCSinkOperator_ResultTable

func (*GRPCSinkOperator) GoString

func (this *GRPCSinkOperator) GoString() string

func (*GRPCSinkOperator) Marshal

func (m *GRPCSinkOperator) Marshal() (dAtA []byte, err error)

func (*GRPCSinkOperator) MarshalTo

func (m *GRPCSinkOperator) MarshalTo(dAtA []byte) (int, error)

func (*GRPCSinkOperator) MarshalToSizedBuffer

func (m *GRPCSinkOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCSinkOperator) ProtoMessage

func (*GRPCSinkOperator) ProtoMessage()

func (*GRPCSinkOperator) Reset

func (m *GRPCSinkOperator) Reset()

func (*GRPCSinkOperator) Size

func (m *GRPCSinkOperator) Size() (n int)

func (*GRPCSinkOperator) String

func (this *GRPCSinkOperator) String() string

func (*GRPCSinkOperator) Unmarshal

func (m *GRPCSinkOperator) Unmarshal(dAtA []byte) error

func (*GRPCSinkOperator) XXX_DiscardUnknown

func (m *GRPCSinkOperator) XXX_DiscardUnknown()

func (*GRPCSinkOperator) XXX_Marshal

func (m *GRPCSinkOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GRPCSinkOperator) XXX_Merge

func (m *GRPCSinkOperator) XXX_Merge(src proto.Message)

func (*GRPCSinkOperator) XXX_OneofWrappers

func (*GRPCSinkOperator) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GRPCSinkOperator) XXX_Size

func (m *GRPCSinkOperator) XXX_Size() int

func (*GRPCSinkOperator) XXX_Unmarshal

func (m *GRPCSinkOperator) XXX_Unmarshal(b []byte) error

type GRPCSinkOperator_GRPCConnectionOptions

type GRPCSinkOperator_GRPCConnectionOptions struct {
	SslTargetname string `protobuf:"bytes,1,opt,name=ssl_targetname,json=sslTargetname,proto3" json:"ssl_targetname,omitempty"`
}

func (*GRPCSinkOperator_GRPCConnectionOptions) Descriptor

func (*GRPCSinkOperator_GRPCConnectionOptions) Descriptor() ([]byte, []int)

func (*GRPCSinkOperator_GRPCConnectionOptions) Equal

func (this *GRPCSinkOperator_GRPCConnectionOptions) Equal(that interface{}) bool

func (*GRPCSinkOperator_GRPCConnectionOptions) GetSslTargetname

func (m *GRPCSinkOperator_GRPCConnectionOptions) GetSslTargetname() string

func (*GRPCSinkOperator_GRPCConnectionOptions) GoString

func (this *GRPCSinkOperator_GRPCConnectionOptions) GoString() string

func (*GRPCSinkOperator_GRPCConnectionOptions) Marshal

func (m *GRPCSinkOperator_GRPCConnectionOptions) Marshal() (dAtA []byte, err error)

func (*GRPCSinkOperator_GRPCConnectionOptions) MarshalTo

func (m *GRPCSinkOperator_GRPCConnectionOptions) MarshalTo(dAtA []byte) (int, error)

func (*GRPCSinkOperator_GRPCConnectionOptions) MarshalToSizedBuffer

func (m *GRPCSinkOperator_GRPCConnectionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCSinkOperator_GRPCConnectionOptions) ProtoMessage

func (*GRPCSinkOperator_GRPCConnectionOptions) ProtoMessage()

func (*GRPCSinkOperator_GRPCConnectionOptions) Reset

func (m *GRPCSinkOperator_GRPCConnectionOptions) Reset()

func (*GRPCSinkOperator_GRPCConnectionOptions) Size

func (m *GRPCSinkOperator_GRPCConnectionOptions) Size() (n int)

func (*GRPCSinkOperator_GRPCConnectionOptions) String

func (this *GRPCSinkOperator_GRPCConnectionOptions) String() string

func (*GRPCSinkOperator_GRPCConnectionOptions) Unmarshal

func (m *GRPCSinkOperator_GRPCConnectionOptions) Unmarshal(dAtA []byte) error

func (*GRPCSinkOperator_GRPCConnectionOptions) XXX_DiscardUnknown

func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_DiscardUnknown()

func (*GRPCSinkOperator_GRPCConnectionOptions) XXX_Marshal

func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GRPCSinkOperator_GRPCConnectionOptions) XXX_Merge

func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_Merge(src proto.Message)

func (*GRPCSinkOperator_GRPCConnectionOptions) XXX_Size

func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_Size() int

func (*GRPCSinkOperator_GRPCConnectionOptions) XXX_Unmarshal

func (m *GRPCSinkOperator_GRPCConnectionOptions) XXX_Unmarshal(b []byte) error

type GRPCSinkOperator_GRPCSourceID

type GRPCSinkOperator_GRPCSourceID struct {
	GRPCSourceID uint64 `protobuf:"varint,3,opt,name=grpc_source_id,json=grpcSourceId,proto3,oneof" json:"grpc_source_id,omitempty"`
}

func (*GRPCSinkOperator_GRPCSourceID) Equal

func (this *GRPCSinkOperator_GRPCSourceID) Equal(that interface{}) bool

func (*GRPCSinkOperator_GRPCSourceID) GoString

func (this *GRPCSinkOperator_GRPCSourceID) GoString() string

func (*GRPCSinkOperator_GRPCSourceID) MarshalTo

func (m *GRPCSinkOperator_GRPCSourceID) MarshalTo(dAtA []byte) (int, error)

func (*GRPCSinkOperator_GRPCSourceID) MarshalToSizedBuffer

func (m *GRPCSinkOperator_GRPCSourceID) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCSinkOperator_GRPCSourceID) Size

func (m *GRPCSinkOperator_GRPCSourceID) Size() (n int)

func (*GRPCSinkOperator_GRPCSourceID) String

func (this *GRPCSinkOperator_GRPCSourceID) String() string

type GRPCSinkOperator_OutputTable

type GRPCSinkOperator_OutputTable struct {
	OutputTable *GRPCSinkOperator_ResultTable `protobuf:"bytes,4,opt,name=output_table,json=outputTable,proto3,oneof" json:"output_table,omitempty"`
}

func (*GRPCSinkOperator_OutputTable) Equal

func (this *GRPCSinkOperator_OutputTable) Equal(that interface{}) bool

func (*GRPCSinkOperator_OutputTable) GoString

func (this *GRPCSinkOperator_OutputTable) GoString() string

func (*GRPCSinkOperator_OutputTable) MarshalTo

func (m *GRPCSinkOperator_OutputTable) MarshalTo(dAtA []byte) (int, error)

func (*GRPCSinkOperator_OutputTable) MarshalToSizedBuffer

func (m *GRPCSinkOperator_OutputTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCSinkOperator_OutputTable) Size

func (m *GRPCSinkOperator_OutputTable) Size() (n int)

func (*GRPCSinkOperator_OutputTable) String

func (this *GRPCSinkOperator_OutputTable) String() string

type GRPCSinkOperator_ResultTable

type GRPCSinkOperator_ResultTable struct {
	TableName           string                 `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnTypes         []typespb.DataType     `protobuf:"varint,2,rep,packed,name=column_types,json=columnTypes,proto3,enum=px.types.DataType" json:"column_types,omitempty"`
	ColumnNames         []string               `protobuf:"bytes,3,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	ColumnSemanticTypes []typespb.SemanticType `` /* 155-byte string literal not displayed */
}

func (*GRPCSinkOperator_ResultTable) Descriptor

func (*GRPCSinkOperator_ResultTable) Descriptor() ([]byte, []int)

func (*GRPCSinkOperator_ResultTable) Equal

func (this *GRPCSinkOperator_ResultTable) Equal(that interface{}) bool

func (*GRPCSinkOperator_ResultTable) GetColumnNames

func (m *GRPCSinkOperator_ResultTable) GetColumnNames() []string

func (*GRPCSinkOperator_ResultTable) GetColumnSemanticTypes

func (m *GRPCSinkOperator_ResultTable) GetColumnSemanticTypes() []typespb.SemanticType

func (*GRPCSinkOperator_ResultTable) GetColumnTypes

func (m *GRPCSinkOperator_ResultTable) GetColumnTypes() []typespb.DataType

func (*GRPCSinkOperator_ResultTable) GetTableName

func (m *GRPCSinkOperator_ResultTable) GetTableName() string

func (*GRPCSinkOperator_ResultTable) GoString

func (this *GRPCSinkOperator_ResultTable) GoString() string

func (*GRPCSinkOperator_ResultTable) Marshal

func (m *GRPCSinkOperator_ResultTable) Marshal() (dAtA []byte, err error)

func (*GRPCSinkOperator_ResultTable) MarshalTo

func (m *GRPCSinkOperator_ResultTable) MarshalTo(dAtA []byte) (int, error)

func (*GRPCSinkOperator_ResultTable) MarshalToSizedBuffer

func (m *GRPCSinkOperator_ResultTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCSinkOperator_ResultTable) ProtoMessage

func (*GRPCSinkOperator_ResultTable) ProtoMessage()

func (*GRPCSinkOperator_ResultTable) Reset

func (m *GRPCSinkOperator_ResultTable) Reset()

func (*GRPCSinkOperator_ResultTable) Size

func (m *GRPCSinkOperator_ResultTable) Size() (n int)

func (*GRPCSinkOperator_ResultTable) String

func (this *GRPCSinkOperator_ResultTable) String() string

func (*GRPCSinkOperator_ResultTable) Unmarshal

func (m *GRPCSinkOperator_ResultTable) Unmarshal(dAtA []byte) error

func (*GRPCSinkOperator_ResultTable) XXX_DiscardUnknown

func (m *GRPCSinkOperator_ResultTable) XXX_DiscardUnknown()

func (*GRPCSinkOperator_ResultTable) XXX_Marshal

func (m *GRPCSinkOperator_ResultTable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GRPCSinkOperator_ResultTable) XXX_Merge

func (m *GRPCSinkOperator_ResultTable) XXX_Merge(src proto.Message)

func (*GRPCSinkOperator_ResultTable) XXX_Size

func (m *GRPCSinkOperator_ResultTable) XXX_Size() int

func (*GRPCSinkOperator_ResultTable) XXX_Unmarshal

func (m *GRPCSinkOperator_ResultTable) XXX_Unmarshal(b []byte) error

type GRPCSourceOperator

type GRPCSourceOperator struct {
	ColumnTypes []typespb.DataType `protobuf:"varint,1,rep,packed,name=column_types,json=columnTypes,proto3,enum=px.types.DataType" json:"column_types,omitempty"`
	ColumnNames []string           `protobuf:"bytes,2,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
}

func (*GRPCSourceOperator) Descriptor

func (*GRPCSourceOperator) Descriptor() ([]byte, []int)

func (*GRPCSourceOperator) Equal

func (this *GRPCSourceOperator) Equal(that interface{}) bool

func (*GRPCSourceOperator) GetColumnNames

func (m *GRPCSourceOperator) GetColumnNames() []string

func (*GRPCSourceOperator) GetColumnTypes

func (m *GRPCSourceOperator) GetColumnTypes() []typespb.DataType

func (*GRPCSourceOperator) GoString

func (this *GRPCSourceOperator) GoString() string

func (*GRPCSourceOperator) Marshal

func (m *GRPCSourceOperator) Marshal() (dAtA []byte, err error)

func (*GRPCSourceOperator) MarshalTo

func (m *GRPCSourceOperator) MarshalTo(dAtA []byte) (int, error)

func (*GRPCSourceOperator) MarshalToSizedBuffer

func (m *GRPCSourceOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GRPCSourceOperator) ProtoMessage

func (*GRPCSourceOperator) ProtoMessage()

func (*GRPCSourceOperator) Reset

func (m *GRPCSourceOperator) Reset()

func (*GRPCSourceOperator) Size

func (m *GRPCSourceOperator) Size() (n int)

func (*GRPCSourceOperator) String

func (this *GRPCSourceOperator) String() string

func (*GRPCSourceOperator) Unmarshal

func (m *GRPCSourceOperator) Unmarshal(dAtA []byte) error

func (*GRPCSourceOperator) XXX_DiscardUnknown

func (m *GRPCSourceOperator) XXX_DiscardUnknown()

func (*GRPCSourceOperator) XXX_Marshal

func (m *GRPCSourceOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GRPCSourceOperator) XXX_Merge

func (m *GRPCSourceOperator) XXX_Merge(src proto.Message)

func (*GRPCSourceOperator) XXX_Size

func (m *GRPCSourceOperator) XXX_Size() int

func (*GRPCSourceOperator) XXX_Unmarshal

func (m *GRPCSourceOperator) XXX_Unmarshal(b []byte) error

type JoinOperator

type JoinOperator struct {
	Type               JoinOperator_JoinType             `protobuf:"varint,1,opt,name=type,proto3,enum=px.carnot.planpb.JoinOperator_JoinType" json:"type,omitempty"`
	EqualityConditions []*JoinOperator_EqualityCondition `protobuf:"bytes,2,rep,name=equality_conditions,json=equalityConditions,proto3" json:"equality_conditions,omitempty"`
	OutputColumns      []*JoinOperator_ParentColumn      `protobuf:"bytes,3,rep,name=output_columns,json=outputColumns,proto3" json:"output_columns,omitempty"`
	ColumnNames        []string                          `protobuf:"bytes,4,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	RowsPerBatch       uint64                            `protobuf:"varint,5,opt,name=rows_per_batch,json=rowsPerBatch,proto3" json:"rows_per_batch,omitempty"`
}

func (*JoinOperator) Descriptor

func (*JoinOperator) Descriptor() ([]byte, []int)

func (*JoinOperator) Equal

func (this *JoinOperator) Equal(that interface{}) bool

func (*JoinOperator) GetColumnNames

func (m *JoinOperator) GetColumnNames() []string

func (*JoinOperator) GetEqualityConditions

func (m *JoinOperator) GetEqualityConditions() []*JoinOperator_EqualityCondition

func (*JoinOperator) GetOutputColumns

func (m *JoinOperator) GetOutputColumns() []*JoinOperator_ParentColumn

func (*JoinOperator) GetRowsPerBatch

func (m *JoinOperator) GetRowsPerBatch() uint64

func (*JoinOperator) GetType

func (m *JoinOperator) GetType() JoinOperator_JoinType

func (*JoinOperator) GoString

func (this *JoinOperator) GoString() string

func (*JoinOperator) Marshal

func (m *JoinOperator) Marshal() (dAtA []byte, err error)

func (*JoinOperator) MarshalTo

func (m *JoinOperator) MarshalTo(dAtA []byte) (int, error)

func (*JoinOperator) MarshalToSizedBuffer

func (m *JoinOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JoinOperator) ProtoMessage

func (*JoinOperator) ProtoMessage()

func (*JoinOperator) Reset

func (m *JoinOperator) Reset()

func (*JoinOperator) Size

func (m *JoinOperator) Size() (n int)

func (*JoinOperator) String

func (this *JoinOperator) String() string

func (*JoinOperator) Unmarshal

func (m *JoinOperator) Unmarshal(dAtA []byte) error

func (*JoinOperator) XXX_DiscardUnknown

func (m *JoinOperator) XXX_DiscardUnknown()

func (*JoinOperator) XXX_Marshal

func (m *JoinOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JoinOperator) XXX_Merge

func (m *JoinOperator) XXX_Merge(src proto.Message)

func (*JoinOperator) XXX_Size

func (m *JoinOperator) XXX_Size() int

func (*JoinOperator) XXX_Unmarshal

func (m *JoinOperator) XXX_Unmarshal(b []byte) error

type JoinOperator_EqualityCondition

type JoinOperator_EqualityCondition struct {
	LeftColumnIndex  uint64 `protobuf:"varint,1,opt,name=left_column_index,json=leftColumnIndex,proto3" json:"left_column_index,omitempty"`
	RightColumnIndex uint64 `protobuf:"varint,2,opt,name=right_column_index,json=rightColumnIndex,proto3" json:"right_column_index,omitempty"`
}

func (*JoinOperator_EqualityCondition) Descriptor

func (*JoinOperator_EqualityCondition) Descriptor() ([]byte, []int)

func (*JoinOperator_EqualityCondition) Equal

func (this *JoinOperator_EqualityCondition) Equal(that interface{}) bool

func (*JoinOperator_EqualityCondition) GetLeftColumnIndex

func (m *JoinOperator_EqualityCondition) GetLeftColumnIndex() uint64

func (*JoinOperator_EqualityCondition) GetRightColumnIndex

func (m *JoinOperator_EqualityCondition) GetRightColumnIndex() uint64

func (*JoinOperator_EqualityCondition) GoString

func (this *JoinOperator_EqualityCondition) GoString() string

func (*JoinOperator_EqualityCondition) Marshal

func (m *JoinOperator_EqualityCondition) Marshal() (dAtA []byte, err error)

func (*JoinOperator_EqualityCondition) MarshalTo

func (m *JoinOperator_EqualityCondition) MarshalTo(dAtA []byte) (int, error)

func (*JoinOperator_EqualityCondition) MarshalToSizedBuffer

func (m *JoinOperator_EqualityCondition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JoinOperator_EqualityCondition) ProtoMessage

func (*JoinOperator_EqualityCondition) ProtoMessage()

func (*JoinOperator_EqualityCondition) Reset

func (m *JoinOperator_EqualityCondition) Reset()

func (*JoinOperator_EqualityCondition) Size

func (m *JoinOperator_EqualityCondition) Size() (n int)

func (*JoinOperator_EqualityCondition) String

func (this *JoinOperator_EqualityCondition) String() string

func (*JoinOperator_EqualityCondition) Unmarshal

func (m *JoinOperator_EqualityCondition) Unmarshal(dAtA []byte) error

func (*JoinOperator_EqualityCondition) XXX_DiscardUnknown

func (m *JoinOperator_EqualityCondition) XXX_DiscardUnknown()

func (*JoinOperator_EqualityCondition) XXX_Marshal

func (m *JoinOperator_EqualityCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JoinOperator_EqualityCondition) XXX_Merge

func (m *JoinOperator_EqualityCondition) XXX_Merge(src proto.Message)

func (*JoinOperator_EqualityCondition) XXX_Size

func (m *JoinOperator_EqualityCondition) XXX_Size() int

func (*JoinOperator_EqualityCondition) XXX_Unmarshal

func (m *JoinOperator_EqualityCondition) XXX_Unmarshal(b []byte) error

type JoinOperator_JoinType

type JoinOperator_JoinType int32

const (
	INNER      JoinOperator_JoinType = 0
	LEFT_OUTER JoinOperator_JoinType = 1
	FULL_OUTER JoinOperator_JoinType = 3
)

func (JoinOperator_JoinType) EnumDescriptor

func (JoinOperator_JoinType) EnumDescriptor() ([]byte, []int)

func (JoinOperator_JoinType) String

func (x JoinOperator_JoinType) String() string

type JoinOperator_ParentColumn

type JoinOperator_ParentColumn struct {
	ParentIndex uint64 `protobuf:"varint,1,opt,name=parent_index,json=parentIndex,proto3" json:"parent_index,omitempty"`
	ColumnIndex uint64 `protobuf:"varint,2,opt,name=column_index,json=columnIndex,proto3" json:"column_index,omitempty"`
}

func (*JoinOperator_ParentColumn) Descriptor

func (*JoinOperator_ParentColumn) Descriptor() ([]byte, []int)

func (*JoinOperator_ParentColumn) Equal

func (this *JoinOperator_ParentColumn) Equal(that interface{}) bool

func (*JoinOperator_ParentColumn) GetColumnIndex

func (m *JoinOperator_ParentColumn) GetColumnIndex() uint64

func (*JoinOperator_ParentColumn) GetParentIndex

func (m *JoinOperator_ParentColumn) GetParentIndex() uint64

func (*JoinOperator_ParentColumn) GoString

func (this *JoinOperator_ParentColumn) GoString() string

func (*JoinOperator_ParentColumn) Marshal

func (m *JoinOperator_ParentColumn) Marshal() (dAtA []byte, err error)

func (*JoinOperator_ParentColumn) MarshalTo

func (m *JoinOperator_ParentColumn) MarshalTo(dAtA []byte) (int, error)

func (*JoinOperator_ParentColumn) MarshalToSizedBuffer

func (m *JoinOperator_ParentColumn) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*JoinOperator_ParentColumn) ProtoMessage

func (*JoinOperator_ParentColumn) ProtoMessage()

func (*JoinOperator_ParentColumn) Reset

func (m *JoinOperator_ParentColumn) Reset()

func (*JoinOperator_ParentColumn) Size

func (m *JoinOperator_ParentColumn) Size() (n int)

func (*JoinOperator_ParentColumn) String

func (this *JoinOperator_ParentColumn) String() string

func (*JoinOperator_ParentColumn) Unmarshal

func (m *JoinOperator_ParentColumn) Unmarshal(dAtA []byte) error

func (*JoinOperator_ParentColumn) XXX_DiscardUnknown

func (m *JoinOperator_ParentColumn) XXX_DiscardUnknown()

func (*JoinOperator_ParentColumn) XXX_Marshal

func (m *JoinOperator_ParentColumn) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*JoinOperator_ParentColumn) XXX_Merge

func (m *JoinOperator_ParentColumn) XXX_Merge(src proto.Message)

func (*JoinOperator_ParentColumn) XXX_Size

func (m *JoinOperator_ParentColumn) XXX_Size() int

func (*JoinOperator_ParentColumn) XXX_Unmarshal

func (m *JoinOperator_ParentColumn) XXX_Unmarshal(b []byte) error

type LimitOperator

type LimitOperator struct {
	Limit         int64     `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Columns       []*Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	AbortableSrcs []uint64  `protobuf:"varint,3,rep,packed,name=abortable_srcs,json=abortableSrcs,proto3" json:"abortable_srcs,omitempty"`
}

func (*LimitOperator) Descriptor

func (*LimitOperator) Descriptor() ([]byte, []int)

func (*LimitOperator) Equal

func (this *LimitOperator) Equal(that interface{}) bool

func (*LimitOperator) GetAbortableSrcs

func (m *LimitOperator) GetAbortableSrcs() []uint64

func (*LimitOperator) GetColumns

func (m *LimitOperator) GetColumns() []*Column

func (*LimitOperator) GetLimit

func (m *LimitOperator) GetLimit() int64

func (*LimitOperator) GoString

func (this *LimitOperator) GoString() string

func (*LimitOperator) Marshal

func (m *LimitOperator) Marshal() (dAtA []byte, err error)

func (*LimitOperator) MarshalTo

func (m *LimitOperator) MarshalTo(dAtA []byte) (int, error)

func (*LimitOperator) MarshalToSizedBuffer

func (m *LimitOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LimitOperator) ProtoMessage

func (*LimitOperator) ProtoMessage()

func (*LimitOperator) Reset

func (m *LimitOperator) Reset()

func (*LimitOperator) Size

func (m *LimitOperator) Size() (n int)

func (*LimitOperator) String

func (this *LimitOperator) String() string

func (*LimitOperator) Unmarshal

func (m *LimitOperator) Unmarshal(dAtA []byte) error

func (*LimitOperator) XXX_DiscardUnknown

func (m *LimitOperator) XXX_DiscardUnknown()

func (*LimitOperator) XXX_Marshal

func (m *LimitOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LimitOperator) XXX_Merge

func (m *LimitOperator) XXX_Merge(src proto.Message)

func (*LimitOperator) XXX_Size

func (m *LimitOperator) XXX_Size() int

func (*LimitOperator) XXX_Unmarshal

func (m *LimitOperator) XXX_Unmarshal(b []byte) error

type MapOperator

type MapOperator struct {
	Expressions []*ScalarExpression `protobuf:"bytes,1,rep,name=expressions,proto3" json:"expressions,omitempty"`
	ColumnNames []string            `protobuf:"bytes,2,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
}

func (*MapOperator) Descriptor

func (*MapOperator) Descriptor() ([]byte, []int)

func (*MapOperator) Equal

func (this *MapOperator) Equal(that interface{}) bool

func (*MapOperator) GetColumnNames

func (m *MapOperator) GetColumnNames() []string

func (*MapOperator) GetExpressions

func (m *MapOperator) GetExpressions() []*ScalarExpression

func (*MapOperator) GoString

func (this *MapOperator) GoString() string

func (*MapOperator) Marshal

func (m *MapOperator) Marshal() (dAtA []byte, err error)

func (*MapOperator) MarshalTo

func (m *MapOperator) MarshalTo(dAtA []byte) (int, error)

func (*MapOperator) MarshalToSizedBuffer

func (m *MapOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MapOperator) ProtoMessage

func (*MapOperator) ProtoMessage()

func (*MapOperator) Reset

func (m *MapOperator) Reset()

func (*MapOperator) Size

func (m *MapOperator) Size() (n int)

func (*MapOperator) String

func (this *MapOperator) String() string

func (*MapOperator) Unmarshal

func (m *MapOperator) Unmarshal(dAtA []byte) error

func (*MapOperator) XXX_DiscardUnknown

func (m *MapOperator) XXX_DiscardUnknown()

func (*MapOperator) XXX_Marshal

func (m *MapOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MapOperator) XXX_Merge

func (m *MapOperator) XXX_Merge(src proto.Message)

func (*MapOperator) XXX_Size

func (m *MapOperator) XXX_Size() int

func (*MapOperator) XXX_Unmarshal

func (m *MapOperator) XXX_Unmarshal(b []byte) error

type MemorySinkOperator

type MemorySinkOperator struct {
	Name                string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ColumnTypes         []typespb.DataType     `protobuf:"varint,2,rep,packed,name=column_types,json=columnTypes,proto3,enum=px.types.DataType" json:"column_types,omitempty"`
	ColumnNames         []string               `protobuf:"bytes,3,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	ColumnSemanticTypes []typespb.SemanticType `` /* 155-byte string literal not displayed */
}

func (*MemorySinkOperator) Descriptor

func (*MemorySinkOperator) Descriptor() ([]byte, []int)

func (*MemorySinkOperator) Equal

func (this *MemorySinkOperator) Equal(that interface{}) bool

func (*MemorySinkOperator) GetColumnNames

func (m *MemorySinkOperator) GetColumnNames() []string

func (*MemorySinkOperator) GetColumnSemanticTypes

func (m *MemorySinkOperator) GetColumnSemanticTypes() []typespb.SemanticType

func (*MemorySinkOperator) GetColumnTypes

func (m *MemorySinkOperator) GetColumnTypes() []typespb.DataType

func (*MemorySinkOperator) GetName

func (m *MemorySinkOperator) GetName() string

func (*MemorySinkOperator) GoString

func (this *MemorySinkOperator) GoString() string

func (*MemorySinkOperator) Marshal

func (m *MemorySinkOperator) Marshal() (dAtA []byte, err error)

func (*MemorySinkOperator) MarshalTo

func (m *MemorySinkOperator) MarshalTo(dAtA []byte) (int, error)

func (*MemorySinkOperator) MarshalToSizedBuffer

func (m *MemorySinkOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MemorySinkOperator) ProtoMessage

func (*MemorySinkOperator) ProtoMessage()

func (*MemorySinkOperator) Reset

func (m *MemorySinkOperator) Reset()

func (*MemorySinkOperator) Size

func (m *MemorySinkOperator) Size() (n int)

func (*MemorySinkOperator) String

func (this *MemorySinkOperator) String() string

func (*MemorySinkOperator) Unmarshal

func (m *MemorySinkOperator) Unmarshal(dAtA []byte) error

func (*MemorySinkOperator) XXX_DiscardUnknown

func (m *MemorySinkOperator) XXX_DiscardUnknown()

func (*MemorySinkOperator) XXX_Marshal

func (m *MemorySinkOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MemorySinkOperator) XXX_Merge

func (m *MemorySinkOperator) XXX_Merge(src proto.Message)

func (*MemorySinkOperator) XXX_Size

func (m *MemorySinkOperator) XXX_Size() int

func (*MemorySinkOperator) XXX_Unmarshal

func (m *MemorySinkOperator) XXX_Unmarshal(b []byte) error

type MemorySourceOperator

type MemorySourceOperator struct {
	Name        string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ColumnIdxs  []int64            `protobuf:"varint,2,rep,packed,name=column_idxs,json=columnIdxs,proto3" json:"column_idxs,omitempty"`
	ColumnNames []string           `protobuf:"bytes,3,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	ColumnTypes []typespb.DataType `protobuf:"varint,4,rep,packed,name=column_types,json=columnTypes,proto3,enum=px.types.DataType" json:"column_types,omitempty"`
	StartTime   *types.Int64Value  `protobuf:"bytes,5,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	StopTime    *types.Int64Value  `protobuf:"bytes,6,opt,name=stop_time,json=stopTime,proto3" json:"stop_time,omitempty"`
	Tablet      string             `protobuf:"bytes,7,opt,name=tablet,proto3" json:"tablet,omitempty"`
	Streaming   bool               `protobuf:"varint,8,opt,name=streaming,proto3" json:"streaming,omitempty"`
}

func (*MemorySourceOperator) Descriptor

func (*MemorySourceOperator) Descriptor() ([]byte, []int)

func (*MemorySourceOperator) Equal

func (this *MemorySourceOperator) Equal(that interface{}) bool

func (*MemorySourceOperator) GetColumnIdxs

func (m *MemorySourceOperator) GetColumnIdxs() []int64

func (*MemorySourceOperator) GetColumnNames

func (m *MemorySourceOperator) GetColumnNames() []string

func (*MemorySourceOperator) GetColumnTypes

func (m *MemorySourceOperator) GetColumnTypes() []typespb.DataType

func (*MemorySourceOperator) GetName

func (m *MemorySourceOperator) GetName() string

func (*MemorySourceOperator) GetStartTime

func (m *MemorySourceOperator) GetStartTime() *types.Int64Value

func (*MemorySourceOperator) GetStopTime

func (m *MemorySourceOperator) GetStopTime() *types.Int64Value

func (*MemorySourceOperator) GetStreaming

func (m *MemorySourceOperator) GetStreaming() bool

func (*MemorySourceOperator) GetTablet

func (m *MemorySourceOperator) GetTablet() string

func (*MemorySourceOperator) GoString

func (this *MemorySourceOperator) GoString() string

func (*MemorySourceOperator) Marshal

func (m *MemorySourceOperator) Marshal() (dAtA []byte, err error)

func (*MemorySourceOperator) MarshalTo

func (m *MemorySourceOperator) MarshalTo(dAtA []byte) (int, error)

func (*MemorySourceOperator) MarshalToSizedBuffer

func (m *MemorySourceOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MemorySourceOperator) ProtoMessage

func (*MemorySourceOperator) ProtoMessage()

func (*MemorySourceOperator) Reset

func (m *MemorySourceOperator) Reset()

func (*MemorySourceOperator) Size

func (m *MemorySourceOperator) Size() (n int)

func (*MemorySourceOperator) String

func (this *MemorySourceOperator) String() string

func (*MemorySourceOperator) Unmarshal

func (m *MemorySourceOperator) Unmarshal(dAtA []byte) error

func (*MemorySourceOperator) XXX_DiscardUnknown

func (m *MemorySourceOperator) XXX_DiscardUnknown()

func (*MemorySourceOperator) XXX_Marshal

func (m *MemorySourceOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MemorySourceOperator) XXX_Merge

func (m *MemorySourceOperator) XXX_Merge(src proto.Message)

func (*MemorySourceOperator) XXX_Size

func (m *MemorySourceOperator) XXX_Size() int

func (*MemorySourceOperator) XXX_Unmarshal

func (m *MemorySourceOperator) XXX_Unmarshal(b []byte) error

type OTelAttribute

type OTelAttribute struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Value:
	//
	//	*OTelAttribute_Column_
	//	*OTelAttribute_StringValue
	Value isOTelAttribute_Value `protobuf_oneof:"value"`
}

func (*OTelAttribute) Descriptor

func (*OTelAttribute) Descriptor() ([]byte, []int)

func (*OTelAttribute) Equal

func (this *OTelAttribute) Equal(that interface{}) bool

func (*OTelAttribute) GetColumn

func (m *OTelAttribute) GetColumn() *OTelAttribute_Column

func (*OTelAttribute) GetName

func (m *OTelAttribute) GetName() string

func (*OTelAttribute) GetStringValue

func (m *OTelAttribute) GetStringValue() string

func (*OTelAttribute) GetValue

func (m *OTelAttribute) GetValue() isOTelAttribute_Value

func (*OTelAttribute) GoString

func (this *OTelAttribute) GoString() string

func (*OTelAttribute) Marshal

func (m *OTelAttribute) Marshal() (dAtA []byte, err error)

func (*OTelAttribute) MarshalTo

func (m *OTelAttribute) MarshalTo(dAtA []byte) (int, error)

func (*OTelAttribute) MarshalToSizedBuffer

func (m *OTelAttribute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelAttribute) ProtoMessage

func (*OTelAttribute) ProtoMessage()

func (*OTelAttribute) Reset

func (m *OTelAttribute) Reset()

func (*OTelAttribute) Size

func (m *OTelAttribute) Size() (n int)

func (*OTelAttribute) String

func (this *OTelAttribute) String() string

func (*OTelAttribute) Unmarshal

func (m *OTelAttribute) Unmarshal(dAtA []byte) error

func (*OTelAttribute) XXX_DiscardUnknown

func (m *OTelAttribute) XXX_DiscardUnknown()

func (*OTelAttribute) XXX_Marshal

func (m *OTelAttribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelAttribute) XXX_Merge

func (m *OTelAttribute) XXX_Merge(src proto.Message)

func (*OTelAttribute) XXX_OneofWrappers

func (*OTelAttribute) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OTelAttribute) XXX_Size

func (m *OTelAttribute) XXX_Size() int

func (*OTelAttribute) XXX_Unmarshal

func (m *OTelAttribute) XXX_Unmarshal(b []byte) error

type OTelAttribute_Column

type OTelAttribute_Column struct {
	ColumnType            typespb.DataType `protobuf:"varint,1,opt,name=column_type,json=columnType,proto3,enum=px.types.DataType" json:"column_type,omitempty"`
	ColumnIndex           int64            `protobuf:"varint,2,opt,name=column_index,json=columnIndex,proto3" json:"column_index,omitempty"`
	CanBeJsonEncodedArray bool             `` /* 131-byte string literal not displayed */
}

func (*OTelAttribute_Column) Descriptor

func (*OTelAttribute_Column) Descriptor() ([]byte, []int)

func (*OTelAttribute_Column) Equal

func (this *OTelAttribute_Column) Equal(that interface{}) bool

func (*OTelAttribute_Column) GetCanBeJsonEncodedArray

func (m *OTelAttribute_Column) GetCanBeJsonEncodedArray() bool

func (*OTelAttribute_Column) GetColumnIndex

func (m *OTelAttribute_Column) GetColumnIndex() int64

func (*OTelAttribute_Column) GetColumnType

func (m *OTelAttribute_Column) GetColumnType() typespb.DataType

func (*OTelAttribute_Column) GoString

func (this *OTelAttribute_Column) GoString() string

func (*OTelAttribute_Column) Marshal

func (m *OTelAttribute_Column) Marshal() (dAtA []byte, err error)

func (*OTelAttribute_Column) MarshalTo

func (m *OTelAttribute_Column) MarshalTo(dAtA []byte) (int, error)

func (*OTelAttribute_Column) MarshalToSizedBuffer

func (m *OTelAttribute_Column) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelAttribute_Column) ProtoMessage

func (*OTelAttribute_Column) ProtoMessage()

func (*OTelAttribute_Column) Reset

func (m *OTelAttribute_Column) Reset()

func (*OTelAttribute_Column) Size

func (m *OTelAttribute_Column) Size() (n int)

func (*OTelAttribute_Column) String

func (this *OTelAttribute_Column) String() string

func (*OTelAttribute_Column) Unmarshal

func (m *OTelAttribute_Column) Unmarshal(dAtA []byte) error

func (*OTelAttribute_Column) XXX_DiscardUnknown

func (m *OTelAttribute_Column) XXX_DiscardUnknown()

func (*OTelAttribute_Column) XXX_Marshal

func (m *OTelAttribute_Column) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelAttribute_Column) XXX_Merge

func (m *OTelAttribute_Column) XXX_Merge(src proto.Message)

func (*OTelAttribute_Column) XXX_Size

func (m *OTelAttribute_Column) XXX_Size() int

func (*OTelAttribute_Column) XXX_Unmarshal

func (m *OTelAttribute_Column) XXX_Unmarshal(b []byte) error

type OTelAttribute_Column_

type OTelAttribute_Column_ struct {
	Column *OTelAttribute_Column `protobuf:"bytes,2,opt,name=column,proto3,oneof" json:"column,omitempty"`
}

func (*OTelAttribute_Column_) Equal

func (this *OTelAttribute_Column_) Equal(that interface{}) bool

func (*OTelAttribute_Column_) GoString

func (this *OTelAttribute_Column_) GoString() string

func (*OTelAttribute_Column_) MarshalTo

func (m *OTelAttribute_Column_) MarshalTo(dAtA []byte) (int, error)

func (*OTelAttribute_Column_) MarshalToSizedBuffer

func (m *OTelAttribute_Column_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelAttribute_Column_) Size

func (m *OTelAttribute_Column_) Size() (n int)

func (*OTelAttribute_Column_) String

func (this *OTelAttribute_Column_) String() string

type OTelAttribute_StringValue

type OTelAttribute_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=string_value,json=stringValue,proto3,oneof" json:"string_value,omitempty"`
}

func (*OTelAttribute_StringValue) Equal

func (this *OTelAttribute_StringValue) Equal(that interface{}) bool

func (*OTelAttribute_StringValue) GoString

func (this *OTelAttribute_StringValue) GoString() string

func (*OTelAttribute_StringValue) MarshalTo

func (m *OTelAttribute_StringValue) MarshalTo(dAtA []byte) (int, error)

func (*OTelAttribute_StringValue) MarshalToSizedBuffer

func (m *OTelAttribute_StringValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelAttribute_StringValue) Size

func (m *OTelAttribute_StringValue) Size() (n int)

func (*OTelAttribute_StringValue) String

func (this *OTelAttribute_StringValue) String() string

type OTelEndpointConfig

type OTelEndpointConfig struct {
	URL      string            `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Headers  map[string]string `` /* 155-byte string literal not displayed */
	Insecure bool              `protobuf:"varint,3,opt,name=insecure,proto3" json:"insecure,omitempty"`
	Timeout  int64             `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
}

func (*OTelEndpointConfig) Descriptor

func (*OTelEndpointConfig) Descriptor() ([]byte, []int)

func (*OTelEndpointConfig) Equal

func (this *OTelEndpointConfig) Equal(that interface{}) bool

func (*OTelEndpointConfig) GetHeaders

func (m *OTelEndpointConfig) GetHeaders() map[string]string

func (*OTelEndpointConfig) GetInsecure

func (m *OTelEndpointConfig) GetInsecure() bool

func (*OTelEndpointConfig) GetTimeout

func (m *OTelEndpointConfig) GetTimeout() int64

func (*OTelEndpointConfig) GetURL

func (m *OTelEndpointConfig) GetURL() string

func (*OTelEndpointConfig) GoString

func (this *OTelEndpointConfig) GoString() string

func (*OTelEndpointConfig) Marshal

func (m *OTelEndpointConfig) Marshal() (dAtA []byte, err error)

func (*OTelEndpointConfig) MarshalTo

func (m *OTelEndpointConfig) MarshalTo(dAtA []byte) (int, error)

func (*OTelEndpointConfig) MarshalToSizedBuffer

func (m *OTelEndpointConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelEndpointConfig) ProtoMessage

func (*OTelEndpointConfig) ProtoMessage()

func (*OTelEndpointConfig) Reset

func (m *OTelEndpointConfig) Reset()

func (*OTelEndpointConfig) Size

func (m *OTelEndpointConfig) Size() (n int)

func (*OTelEndpointConfig) String

func (this *OTelEndpointConfig) String() string

func (*OTelEndpointConfig) Unmarshal

func (m *OTelEndpointConfig) Unmarshal(dAtA []byte) error

func (*OTelEndpointConfig) XXX_DiscardUnknown

func (m *OTelEndpointConfig) XXX_DiscardUnknown()

func (*OTelEndpointConfig) XXX_Marshal

func (m *OTelEndpointConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelEndpointConfig) XXX_Merge

func (m *OTelEndpointConfig) XXX_Merge(src proto.Message)

func (*OTelEndpointConfig) XXX_Size

func (m *OTelEndpointConfig) XXX_Size() int

func (*OTelEndpointConfig) XXX_Unmarshal

func (m *OTelEndpointConfig) XXX_Unmarshal(b []byte) error

type OTelExportSinkOperator

type OTelExportSinkOperator struct {
	EndpointConfig *OTelEndpointConfig `protobuf:"bytes,1,opt,name=endpoint_config,json=endpointConfig,proto3" json:"endpoint_config,omitempty"`
	Resource       *OTelResource       `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	Metrics        []*OTelMetric       `protobuf:"bytes,3,rep,name=metrics,proto3" json:"metrics,omitempty"`
	Spans          []*OTelSpan         `protobuf:"bytes,4,rep,name=spans,proto3" json:"spans,omitempty"`
}

func (*OTelExportSinkOperator) Descriptor

func (*OTelExportSinkOperator) Descriptor() ([]byte, []int)

func (*OTelExportSinkOperator) Equal

func (this *OTelExportSinkOperator) Equal(that interface{}) bool

func (*OTelExportSinkOperator) GetEndpointConfig

func (m *OTelExportSinkOperator) GetEndpointConfig() *OTelEndpointConfig

func (*OTelExportSinkOperator) GetMetrics

func (m *OTelExportSinkOperator) GetMetrics() []*OTelMetric

func (*OTelExportSinkOperator) GetResource

func (m *OTelExportSinkOperator) GetResource() *OTelResource

func (*OTelExportSinkOperator) GetSpans

func (m *OTelExportSinkOperator) GetSpans() []*OTelSpan

func (*OTelExportSinkOperator) GoString

func (this *OTelExportSinkOperator) GoString() string

func (*OTelExportSinkOperator) Marshal

func (m *OTelExportSinkOperator) Marshal() (dAtA []byte, err error)

func (*OTelExportSinkOperator) MarshalTo

func (m *OTelExportSinkOperator) MarshalTo(dAtA []byte) (int, error)

func (*OTelExportSinkOperator) MarshalToSizedBuffer

func (m *OTelExportSinkOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelExportSinkOperator) ProtoMessage

func (*OTelExportSinkOperator) ProtoMessage()

func (*OTelExportSinkOperator) Reset

func (m *OTelExportSinkOperator) Reset()

func (*OTelExportSinkOperator) Size

func (m *OTelExportSinkOperator) Size() (n int)

func (*OTelExportSinkOperator) String

func (this *OTelExportSinkOperator) String() string

func (*OTelExportSinkOperator) Unmarshal

func (m *OTelExportSinkOperator) Unmarshal(dAtA []byte) error

func (*OTelExportSinkOperator) XXX_DiscardUnknown

func (m *OTelExportSinkOperator) XXX_DiscardUnknown()

func (*OTelExportSinkOperator) XXX_Marshal

func (m *OTelExportSinkOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelExportSinkOperator) XXX_Merge

func (m *OTelExportSinkOperator) XXX_Merge(src proto.Message)

func (*OTelExportSinkOperator) XXX_Size

func (m *OTelExportSinkOperator) XXX_Size() int

func (*OTelExportSinkOperator) XXX_Unmarshal

func (m *OTelExportSinkOperator) XXX_Unmarshal(b []byte) error

type OTelMetric

type OTelMetric struct {
	Name            string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description     string           `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Unit            string           `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"`
	Attributes      []*OTelAttribute `protobuf:"bytes,4,rep,name=attributes,proto3" json:"attributes,omitempty"`
	TimeColumnIndex int64            `protobuf:"varint,5,opt,name=time_column_index,json=timeColumnIndex,proto3" json:"time_column_index,omitempty"`
	// Types that are valid to be assigned to Data:
	//
	//	*OTelMetric_Gauge
	//	*OTelMetric_Summary
	Data isOTelMetric_Data `protobuf_oneof:"data"`
}

func (*OTelMetric) Descriptor

func (*OTelMetric) Descriptor() ([]byte, []int)

func (*OTelMetric) Equal

func (this *OTelMetric) Equal(that interface{}) bool

func (*OTelMetric) GetAttributes

func (m *OTelMetric) GetAttributes() []*OTelAttribute

func (*OTelMetric) GetData

func (m *OTelMetric) GetData() isOTelMetric_Data

func (*OTelMetric) GetDescription

func (m *OTelMetric) GetDescription() string

func (*OTelMetric) GetGauge

func (m *OTelMetric) GetGauge() *OTelMetricGauge

func (*OTelMetric) GetName

func (m *OTelMetric) GetName() string

func (*OTelMetric) GetSummary

func (m *OTelMetric) GetSummary() *OTelMetricSummary

func (*OTelMetric) GetTimeColumnIndex

func (m *OTelMetric) GetTimeColumnIndex() int64

func (*OTelMetric) GetUnit

func (m *OTelMetric) GetUnit() string

func (*OTelMetric) GoString

func (this *OTelMetric) GoString() string

func (*OTelMetric) Marshal

func (m *OTelMetric) Marshal() (dAtA []byte, err error)

func (*OTelMetric) MarshalTo

func (m *OTelMetric) MarshalTo(dAtA []byte) (int, error)

func (*OTelMetric) MarshalToSizedBuffer

func (m *OTelMetric) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelMetric) ProtoMessage

func (*OTelMetric) ProtoMessage()

func (*OTelMetric) Reset

func (m *OTelMetric) Reset()

func (*OTelMetric) Size

func (m *OTelMetric) Size() (n int)

func (*OTelMetric) String

func (this *OTelMetric) String() string

func (*OTelMetric) Unmarshal

func (m *OTelMetric) Unmarshal(dAtA []byte) error

func (*OTelMetric) XXX_DiscardUnknown

func (m *OTelMetric) XXX_DiscardUnknown()

func (*OTelMetric) XXX_Marshal

func (m *OTelMetric) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelMetric) XXX_Merge

func (m *OTelMetric) XXX_Merge(src proto.Message)

func (*OTelMetric) XXX_OneofWrappers

func (*OTelMetric) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OTelMetric) XXX_Size

func (m *OTelMetric) XXX_Size() int

func (*OTelMetric) XXX_Unmarshal

func (m *OTelMetric) XXX_Unmarshal(b []byte) error

type OTelMetricGauge

type OTelMetricGauge struct {
	// Types that are valid to be assigned to ValueColumn:
	//
	//	*OTelMetricGauge_FloatColumnIndex
	//	*OTelMetricGauge_IntColumnIndex
	ValueColumn isOTelMetricGauge_ValueColumn `protobuf_oneof:"value_column"`
}

func (*OTelMetricGauge) Descriptor

func (*OTelMetricGauge) Descriptor() ([]byte, []int)

func (*OTelMetricGauge) Equal

func (this *OTelMetricGauge) Equal(that interface{}) bool

func (*OTelMetricGauge) GetFloatColumnIndex

func (m *OTelMetricGauge) GetFloatColumnIndex() int64

func (*OTelMetricGauge) GetIntColumnIndex

func (m *OTelMetricGauge) GetIntColumnIndex() int64

func (*OTelMetricGauge) GetValueColumn

func (m *OTelMetricGauge) GetValueColumn() isOTelMetricGauge_ValueColumn

func (*OTelMetricGauge) GoString

func (this *OTelMetricGauge) GoString() string

func (*OTelMetricGauge) Marshal

func (m *OTelMetricGauge) Marshal() (dAtA []byte, err error)

func (*OTelMetricGauge) MarshalTo

func (m *OTelMetricGauge) MarshalTo(dAtA []byte) (int, error)

func (*OTelMetricGauge) MarshalToSizedBuffer

func (m *OTelMetricGauge) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelMetricGauge) ProtoMessage

func (*OTelMetricGauge) ProtoMessage()

func (*OTelMetricGauge) Reset

func (m *OTelMetricGauge) Reset()

func (*OTelMetricGauge) Size

func (m *OTelMetricGauge) Size() (n int)

func (*OTelMetricGauge) String

func (this *OTelMetricGauge) String() string

func (*OTelMetricGauge) Unmarshal

func (m *OTelMetricGauge) Unmarshal(dAtA []byte) error

func (*OTelMetricGauge) XXX_DiscardUnknown

func (m *OTelMetricGauge) XXX_DiscardUnknown()

func (*OTelMetricGauge) XXX_Marshal

func (m *OTelMetricGauge) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelMetricGauge) XXX_Merge

func (m *OTelMetricGauge) XXX_Merge(src proto.Message)

func (*OTelMetricGauge) XXX_OneofWrappers

func (*OTelMetricGauge) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OTelMetricGauge) XXX_Size

func (m *OTelMetricGauge) XXX_Size() int

func (*OTelMetricGauge) XXX_Unmarshal

func (m *OTelMetricGauge) XXX_Unmarshal(b []byte) error

type OTelMetricGauge_FloatColumnIndex

type OTelMetricGauge_FloatColumnIndex struct {
	FloatColumnIndex int64 `protobuf:"varint,1,opt,name=float_column_index,json=floatColumnIndex,proto3,oneof" json:"float_column_index,omitempty"`
}

func (*OTelMetricGauge_FloatColumnIndex) Equal

func (this *OTelMetricGauge_FloatColumnIndex) Equal(that interface{}) bool

func (*OTelMetricGauge_FloatColumnIndex) GoString

func (this *OTelMetricGauge_FloatColumnIndex) GoString() string

func (*OTelMetricGauge_FloatColumnIndex) MarshalTo

func (m *OTelMetricGauge_FloatColumnIndex) MarshalTo(dAtA []byte) (int, error)

func (*OTelMetricGauge_FloatColumnIndex) MarshalToSizedBuffer

func (m *OTelMetricGauge_FloatColumnIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelMetricGauge_FloatColumnIndex) Size

func (m *OTelMetricGauge_FloatColumnIndex) Size() (n int)

func (*OTelMetricGauge_FloatColumnIndex) String

func (this *OTelMetricGauge_FloatColumnIndex) String() string

type OTelMetricGauge_IntColumnIndex

type OTelMetricGauge_IntColumnIndex struct {
	IntColumnIndex int64 `protobuf:"varint,2,opt,name=int_column_index,json=intColumnIndex,proto3,oneof" json:"int_column_index,omitempty"`
}

func (*OTelMetricGauge_IntColumnIndex) Equal

func (this *OTelMetricGauge_IntColumnIndex) Equal(that interface{}) bool

func (*OTelMetricGauge_IntColumnIndex) GoString

func (this *OTelMetricGauge_IntColumnIndex) GoString() string

func (*OTelMetricGauge_IntColumnIndex) MarshalTo

func (m *OTelMetricGauge_IntColumnIndex) MarshalTo(dAtA []byte) (int, error)

func (*OTelMetricGauge_IntColumnIndex) MarshalToSizedBuffer

func (m *OTelMetricGauge_IntColumnIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelMetricGauge_IntColumnIndex) Size

func (m *OTelMetricGauge_IntColumnIndex) Size() (n int)

func (*OTelMetricGauge_IntColumnIndex) String

func (this *OTelMetricGauge_IntColumnIndex) String() string

type OTelMetricSummary

type OTelMetricSummary struct {
	CountColumnIndex int64                                `protobuf:"varint,1,opt,name=count_column_index,json=countColumnIndex,proto3" json:"count_column_index,omitempty"`
	SumColumnIndex   int64                                `protobuf:"varint,2,opt,name=sum_column_index,json=sumColumnIndex,proto3" json:"sum_column_index,omitempty"`
	QuantileValues   []*OTelMetricSummary_ValueAtQuantile `protobuf:"bytes,3,rep,name=quantile_values,json=quantileValues,proto3" json:"quantile_values,omitempty"`
}

func (*OTelMetricSummary) Descriptor

func (*OTelMetricSummary) Descriptor() ([]byte, []int)

func (*OTelMetricSummary) Equal

func (this *OTelMetricSummary) Equal(that interface{}) bool

func (*OTelMetricSummary) GetCountColumnIndex

func (m *OTelMetricSummary) GetCountColumnIndex() int64

func (*OTelMetricSummary) GetQuantileValues

func (m *OTelMetricSummary) GetQuantileValues() []*OTelMetricSummary_ValueAtQuantile

func (*OTelMetricSummary) GetSumColumnIndex

func (m *OTelMetricSummary) GetSumColumnIndex() int64

func (*OTelMetricSummary) GoString

func (this *OTelMetricSummary) GoString() string

func (*OTelMetricSummary) Marshal

func (m *OTelMetricSummary) Marshal() (dAtA []byte, err error)

func (*OTelMetricSummary) MarshalTo

func (m *OTelMetricSummary) MarshalTo(dAtA []byte) (int, error)

func (*OTelMetricSummary) MarshalToSizedBuffer

func (m *OTelMetricSummary) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelMetricSummary) ProtoMessage

func (*OTelMetricSummary) ProtoMessage()

func (*OTelMetricSummary) Reset

func (m *OTelMetricSummary) Reset()

func (*OTelMetricSummary) Size

func (m *OTelMetricSummary) Size() (n int)

func (*OTelMetricSummary) String

func (this *OTelMetricSummary) String() string

func (*OTelMetricSummary) Unmarshal

func (m *OTelMetricSummary) Unmarshal(dAtA []byte) error

func (*OTelMetricSummary) XXX_DiscardUnknown

func (m *OTelMetricSummary) XXX_DiscardUnknown()

func (*OTelMetricSummary) XXX_Marshal

func (m *OTelMetricSummary) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelMetricSummary) XXX_Merge

func (m *OTelMetricSummary) XXX_Merge(src proto.Message)

func (*OTelMetricSummary) XXX_Size

func (m *OTelMetricSummary) XXX_Size() int

func (*OTelMetricSummary) XXX_Unmarshal

func (m *OTelMetricSummary) XXX_Unmarshal(b []byte) error

type OTelMetricSummary_ValueAtQuantile

type OTelMetricSummary_ValueAtQuantile struct {
	Quantile         float64 `protobuf:"fixed64,1,opt,name=quantile,proto3" json:"quantile,omitempty"`
	ValueColumnIndex int64   `protobuf:"varint,2,opt,name=value_column_index,json=valueColumnIndex,proto3" json:"value_column_index,omitempty"`
}

func (*OTelMetricSummary_ValueAtQuantile) Descriptor

func (*OTelMetricSummary_ValueAtQuantile) Descriptor() ([]byte, []int)

func (*OTelMetricSummary_ValueAtQuantile) Equal

func (this *OTelMetricSummary_ValueAtQuantile) Equal(that interface{}) bool

func (*OTelMetricSummary_ValueAtQuantile) GetQuantile

func (m *OTelMetricSummary_ValueAtQuantile) GetQuantile() float64

func (*OTelMetricSummary_ValueAtQuantile) GetValueColumnIndex

func (m *OTelMetricSummary_ValueAtQuantile) GetValueColumnIndex() int64

func (*OTelMetricSummary_ValueAtQuantile) GoString

func (this *OTelMetricSummary_ValueAtQuantile) GoString() string

func (*OTelMetricSummary_ValueAtQuantile) Marshal

func (m *OTelMetricSummary_ValueAtQuantile) Marshal() (dAtA []byte, err error)

func (*OTelMetricSummary_ValueAtQuantile) MarshalTo

func (m *OTelMetricSummary_ValueAtQuantile) MarshalTo(dAtA []byte) (int, error)

func (*OTelMetricSummary_ValueAtQuantile) MarshalToSizedBuffer

func (m *OTelMetricSummary_ValueAtQuantile) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelMetricSummary_ValueAtQuantile) ProtoMessage

func (*OTelMetricSummary_ValueAtQuantile) ProtoMessage()

func (*OTelMetricSummary_ValueAtQuantile) Reset

func (m *OTelMetricSummary_ValueAtQuantile) Reset()

func (*OTelMetricSummary_ValueAtQuantile) Size

func (m *OTelMetricSummary_ValueAtQuantile) Size() (n int)

func (*OTelMetricSummary_ValueAtQuantile) String

func (this *OTelMetricSummary_ValueAtQuantile) String() string

func (*OTelMetricSummary_ValueAtQuantile) Unmarshal

func (m *OTelMetricSummary_ValueAtQuantile) Unmarshal(dAtA []byte) error

func (*OTelMetricSummary_ValueAtQuantile) XXX_DiscardUnknown

func (m *OTelMetricSummary_ValueAtQuantile) XXX_DiscardUnknown()

func (*OTelMetricSummary_ValueAtQuantile) XXX_Marshal

func (m *OTelMetricSummary_ValueAtQuantile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelMetricSummary_ValueAtQuantile) XXX_Merge

func (m *OTelMetricSummary_ValueAtQuantile) XXX_Merge(src proto.Message)

func (*OTelMetricSummary_ValueAtQuantile) XXX_Size

func (m *OTelMetricSummary_ValueAtQuantile) XXX_Size() int

func (*OTelMetricSummary_ValueAtQuantile) XXX_Unmarshal

func (m *OTelMetricSummary_ValueAtQuantile) XXX_Unmarshal(b []byte) error

type OTelMetric_Gauge

type OTelMetric_Gauge struct {
	Gauge *OTelMetricGauge `protobuf:"bytes,101,opt,name=gauge,proto3,oneof" json:"gauge,omitempty"`
}

func (*OTelMetric_Gauge) Equal

func (this *OTelMetric_Gauge) Equal(that interface{}) bool

func (*OTelMetric_Gauge) GoString

func (this *OTelMetric_Gauge) GoString() string

func (*OTelMetric_Gauge) MarshalTo

func (m *OTelMetric_Gauge) MarshalTo(dAtA []byte) (int, error)

func (*OTelMetric_Gauge) MarshalToSizedBuffer

func (m *OTelMetric_Gauge) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelMetric_Gauge) Size

func (m *OTelMetric_Gauge) Size() (n int)

func (*OTelMetric_Gauge) String

func (this *OTelMetric_Gauge) String() string

type OTelMetric_Summary

type OTelMetric_Summary struct {
	Summary *OTelMetricSummary `protobuf:"bytes,102,opt,name=summary,proto3,oneof" json:"summary,omitempty"`
}

func (*OTelMetric_Summary) Equal

func (this *OTelMetric_Summary) Equal(that interface{}) bool

func (*OTelMetric_Summary) GoString

func (this *OTelMetric_Summary) GoString() string

func (*OTelMetric_Summary) MarshalTo

func (m *OTelMetric_Summary) MarshalTo(dAtA []byte) (int, error)

func (*OTelMetric_Summary) MarshalToSizedBuffer

func (m *OTelMetric_Summary) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelMetric_Summary) Size

func (m *OTelMetric_Summary) Size() (n int)

func (*OTelMetric_Summary) String

func (this *OTelMetric_Summary) String() string

type OTelResource

type OTelResource struct {
	Attributes []*OTelAttribute `protobuf:"bytes,1,rep,name=attributes,proto3" json:"attributes,omitempty"`
}

func (*OTelResource) Descriptor

func (*OTelResource) Descriptor() ([]byte, []int)

func (*OTelResource) Equal

func (this *OTelResource) Equal(that interface{}) bool

func (*OTelResource) GetAttributes

func (m *OTelResource) GetAttributes() []*OTelAttribute

func (*OTelResource) GoString

func (this *OTelResource) GoString() string

func (*OTelResource) Marshal

func (m *OTelResource) Marshal() (dAtA []byte, err error)

func (*OTelResource) MarshalTo

func (m *OTelResource) MarshalTo(dAtA []byte) (int, error)

func (*OTelResource) MarshalToSizedBuffer

func (m *OTelResource) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelResource) ProtoMessage

func (*OTelResource) ProtoMessage()

func (*OTelResource) Reset

func (m *OTelResource) Reset()

func (*OTelResource) Size

func (m *OTelResource) Size() (n int)

func (*OTelResource) String

func (this *OTelResource) String() string

func (*OTelResource) Unmarshal

func (m *OTelResource) Unmarshal(dAtA []byte) error

func (*OTelResource) XXX_DiscardUnknown

func (m *OTelResource) XXX_DiscardUnknown()

func (*OTelResource) XXX_Marshal

func (m *OTelResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelResource) XXX_Merge

func (m *OTelResource) XXX_Merge(src proto.Message)

func (*OTelResource) XXX_Size

func (m *OTelResource) XXX_Size() int

func (*OTelResource) XXX_Unmarshal

func (m *OTelResource) XXX_Unmarshal(b []byte) error

type OTelSpan

type OTelSpan struct {
	// Types that are valid to be assigned to Name:
	//
	//	*OTelSpan_NameString
	//	*OTelSpan_NameColumnIndex
	Name                 isOTelSpan_Name  `protobuf_oneof:"name"`
	Attributes           []*OTelAttribute `protobuf:"bytes,3,rep,name=attributes,proto3" json:"attributes,omitempty"`
	TraceIDColumn        int64            `protobuf:"varint,4,opt,name=trace_id_column_index,json=traceIdColumnIndex,proto3" json:"trace_id_column_index,omitempty"`
	SpanIDColumn         int64            `protobuf:"varint,5,opt,name=span_id_column_index,json=spanIdColumnIndex,proto3" json:"span_id_column_index,omitempty"`
	ParentSpanIDColumn   int64            `` /* 137-byte string literal not displayed */
	StartTimeColumnIndex int64            `` /* 126-byte string literal not displayed */
	EndTimeColumnIndex   int64            `protobuf:"varint,8,opt,name=end_time_column_index,json=endTimeColumnIndex,proto3" json:"end_time_column_index,omitempty"`
	KindValue            int64            `protobuf:"varint,9,opt,name=kind_value,json=kindValue,proto3" json:"kind_value,omitempty"`
}

func (*OTelSpan) Descriptor

func (*OTelSpan) Descriptor() ([]byte, []int)

func (*OTelSpan) Equal

func (this *OTelSpan) Equal(that interface{}) bool

func (*OTelSpan) GetAttributes

func (m *OTelSpan) GetAttributes() []*OTelAttribute

func (*OTelSpan) GetEndTimeColumnIndex

func (m *OTelSpan) GetEndTimeColumnIndex() int64

func (*OTelSpan) GetKindValue

func (m *OTelSpan) GetKindValue() int64

func (*OTelSpan) GetName

func (m *OTelSpan) GetName() isOTelSpan_Name

func (*OTelSpan) GetNameColumnIndex

func (m *OTelSpan) GetNameColumnIndex() int64

func (*OTelSpan) GetNameString

func (m *OTelSpan) GetNameString() string

func (*OTelSpan) GetParentSpanIDColumn

func (m *OTelSpan) GetParentSpanIDColumn() int64

func (*OTelSpan) GetSpanIDColumn

func (m *OTelSpan) GetSpanIDColumn() int64

func (*OTelSpan) GetStartTimeColumnIndex

func (m *OTelSpan) GetStartTimeColumnIndex() int64

func (*OTelSpan) GetTraceIDColumn

func (m *OTelSpan) GetTraceIDColumn() int64

func (*OTelSpan) GoString

func (this *OTelSpan) GoString() string

func (*OTelSpan) Marshal

func (m *OTelSpan) Marshal() (dAtA []byte, err error)

func (*OTelSpan) MarshalTo

func (m *OTelSpan) MarshalTo(dAtA []byte) (int, error)

func (*OTelSpan) MarshalToSizedBuffer

func (m *OTelSpan) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelSpan) ProtoMessage

func (*OTelSpan) ProtoMessage()

func (*OTelSpan) Reset

func (m *OTelSpan) Reset()

func (*OTelSpan) Size

func (m *OTelSpan) Size() (n int)

func (*OTelSpan) String

func (this *OTelSpan) String() string

func (*OTelSpan) Unmarshal

func (m *OTelSpan) Unmarshal(dAtA []byte) error

func (*OTelSpan) XXX_DiscardUnknown

func (m *OTelSpan) XXX_DiscardUnknown()

func (*OTelSpan) XXX_Marshal

func (m *OTelSpan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelSpan) XXX_Merge

func (m *OTelSpan) XXX_Merge(src proto.Message)

func (*OTelSpan) XXX_OneofWrappers

func (*OTelSpan) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*OTelSpan) XXX_Size

func (m *OTelSpan) XXX_Size() int

func (*OTelSpan) XXX_Unmarshal

func (m *OTelSpan) XXX_Unmarshal(b []byte) error

type OTelSpan_NameColumnIndex

type OTelSpan_NameColumnIndex struct {
	NameColumnIndex int64 `protobuf:"varint,2,opt,name=name_column_index,json=nameColumnIndex,proto3,oneof" json:"name_column_index,omitempty"`
}

func (*OTelSpan_NameColumnIndex) Equal

func (this *OTelSpan_NameColumnIndex) Equal(that interface{}) bool

func (*OTelSpan_NameColumnIndex) GoString

func (this *OTelSpan_NameColumnIndex) GoString() string

func (*OTelSpan_NameColumnIndex) MarshalTo

func (m *OTelSpan_NameColumnIndex) MarshalTo(dAtA []byte) (int, error)

func (*OTelSpan_NameColumnIndex) MarshalToSizedBuffer

func (m *OTelSpan_NameColumnIndex) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelSpan_NameColumnIndex) Size

func (m *OTelSpan_NameColumnIndex) Size() (n int)

func (*OTelSpan_NameColumnIndex) String

func (this *OTelSpan_NameColumnIndex) String() string

type OTelSpan_NameString

type OTelSpan_NameString struct {
	NameString string `protobuf:"bytes,1,opt,name=name_string,json=nameString,proto3,oneof" json:"name_string,omitempty"`
}

func (*OTelSpan_NameString) Equal

func (this *OTelSpan_NameString) Equal(that interface{}) bool

func (*OTelSpan_NameString) GoString

func (this *OTelSpan_NameString) GoString() string

func (*OTelSpan_NameString) MarshalTo

func (m *OTelSpan_NameString) MarshalTo(dAtA []byte) (int, error)

func (*OTelSpan_NameString) MarshalToSizedBuffer

func (m *OTelSpan_NameString) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelSpan_NameString) Size

func (m *OTelSpan_NameString) Size() (n int)

func (*OTelSpan_NameString) String

func (this *OTelSpan_NameString) String() string

type Operator

type Operator struct {
	OpType OperatorType `protobuf:"varint,1,opt,name=op_type,json=opType,proto3,enum=px.carnot.planpb.OperatorType" json:"op_type,omitempty"`
	// Types that are valid to be assigned to Op:
	//
	//	*Operator_MemSourceOp
	//	*Operator_MapOp
	//	*Operator_AggOp
	//	*Operator_MemSinkOp
	//	*Operator_FilterOp
	//	*Operator_LimitOp
	//	*Operator_UnionOp
	//	*Operator_GRPCSourceOp
	//	*Operator_GRPCSinkOp
	//	*Operator_JoinOp
	//	*Operator_UdtfSourceOp
	//	*Operator_EmptySourceOp
	//	*Operator_OTelSinkOp
	Op isOperator_Op `protobuf_oneof:"op"`
}

func (*Operator) Descriptor

func (*Operator) Descriptor() ([]byte, []int)

func (*Operator) Equal

func (this *Operator) Equal(that interface{}) bool

func (*Operator) GetAggOp

func (m *Operator) GetAggOp() *AggregateOperator

func (*Operator) GetEmptySourceOp

func (m *Operator) GetEmptySourceOp() *EmptySourceOperator

func (*Operator) GetFilterOp

func (m *Operator) GetFilterOp() *FilterOperator

func (*Operator) GetGRPCSinkOp

func (m *Operator) GetGRPCSinkOp() *GRPCSinkOperator

func (*Operator) GetGRPCSourceOp

func (m *Operator) GetGRPCSourceOp() *GRPCSourceOperator

func (*Operator) GetJoinOp

func (m *Operator) GetJoinOp() *JoinOperator

func (*Operator) GetLimitOp

func (m *Operator) GetLimitOp() *LimitOperator

func (*Operator) GetMapOp

func (m *Operator) GetMapOp() *MapOperator

func (*Operator) GetMemSinkOp

func (m *Operator) GetMemSinkOp() *MemorySinkOperator

func (*Operator) GetMemSourceOp

func (m *Operator) GetMemSourceOp() *MemorySourceOperator

func (*Operator) GetOTelSinkOp

func (m *Operator) GetOTelSinkOp() *OTelExportSinkOperator

func (*Operator) GetOp

func (m *Operator) GetOp() isOperator_Op

func (*Operator) GetOpType

func (m *Operator) GetOpType() OperatorType

func (*Operator) GetUdtfSourceOp

func (m *Operator) GetUdtfSourceOp() *UDTFSourceOperator

func (*Operator) GetUnionOp

func (m *Operator) GetUnionOp() *UnionOperator

func (*Operator) GoString

func (this *Operator) GoString() string

func (*Operator) Marshal

func (m *Operator) Marshal() (dAtA []byte, err error)

func (*Operator) MarshalTo

func (m *Operator) MarshalTo(dAtA []byte) (int, error)

func (*Operator) MarshalToSizedBuffer

func (m *Operator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator) ProtoMessage

func (*Operator) ProtoMessage()

func (*Operator) Reset

func (m *Operator) Reset()

func (*Operator) Size

func (m *Operator) Size() (n int)

func (*Operator) String

func (this *Operator) String() string

func (*Operator) Unmarshal

func (m *Operator) Unmarshal(dAtA []byte) error

func (*Operator) XXX_DiscardUnknown

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal

func (m *Operator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Operator) XXX_Merge

func (m *Operator) XXX_Merge(src proto.Message)

func (*Operator) XXX_OneofWrappers

func (*Operator) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Operator) XXX_Size

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal

func (m *Operator) XXX_Unmarshal(b []byte) error

type OperatorType

type OperatorType int32

const (
	OPERATOR_TYPE_UNKNOWN     OperatorType = 0
	MEMORY_SOURCE_OPERATOR    OperatorType = 1000
	GRPC_SOURCE_OPERATOR      OperatorType = 1100
	UDTF_SOURCE_OPERATOR      OperatorType = 1200
	EMPTY_SOURCE_OPERATOR     OperatorType = 1300
	MAP_OPERATOR              OperatorType = 2000
	AGGREGATE_OPERATOR        OperatorType = 2100
	FILTER_OPERATOR           OperatorType = 2200
	LIMIT_OPERATOR            OperatorType = 2300
	UNION_OPERATOR            OperatorType = 2400
	JOIN_OPERATOR             OperatorType = 2500
	MEMORY_SINK_OPERATOR      OperatorType = 9000
	GRPC_SINK_OPERATOR        OperatorType = 9100
	OTEL_EXPORT_SINK_OPERATOR OperatorType = 9200
)

func (OperatorType) EnumDescriptor

func (OperatorType) EnumDescriptor() ([]byte, []int)

func (OperatorType) String

func (x OperatorType) String() string

type Operator_AggOp

type Operator_AggOp struct {
	AggOp *AggregateOperator `protobuf:"bytes,4,opt,name=agg_op,json=aggOp,proto3,oneof" json:"agg_op,omitempty"`
}

func (*Operator_AggOp) Equal

func (this *Operator_AggOp) Equal(that interface{}) bool

func (*Operator_AggOp) GoString

func (this *Operator_AggOp) GoString() string

func (*Operator_AggOp) MarshalTo

func (m *Operator_AggOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_AggOp) MarshalToSizedBuffer

func (m *Operator_AggOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_AggOp) Size

func (m *Operator_AggOp) Size() (n int)

func (*Operator_AggOp) String

func (this *Operator_AggOp) String() string

type Operator_EmptySourceOp

type Operator_EmptySourceOp struct {
	EmptySourceOp *EmptySourceOperator `protobuf:"bytes,13,opt,name=empty_source_op,json=emptySourceOp,proto3,oneof" json:"empty_source_op,omitempty"`
}

func (*Operator_EmptySourceOp) Equal

func (this *Operator_EmptySourceOp) Equal(that interface{}) bool

func (*Operator_EmptySourceOp) GoString

func (this *Operator_EmptySourceOp) GoString() string

func (*Operator_EmptySourceOp) MarshalTo

func (m *Operator_EmptySourceOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_EmptySourceOp) MarshalToSizedBuffer

func (m *Operator_EmptySourceOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_EmptySourceOp) Size

func (m *Operator_EmptySourceOp) Size() (n int)

func (*Operator_EmptySourceOp) String

func (this *Operator_EmptySourceOp) String() string

type Operator_FilterOp

type Operator_FilterOp struct {
	FilterOp *FilterOperator `protobuf:"bytes,6,opt,name=filter_op,json=filterOp,proto3,oneof" json:"filter_op,omitempty"`
}

func (*Operator_FilterOp) Equal

func (this *Operator_FilterOp) Equal(that interface{}) bool

func (*Operator_FilterOp) GoString

func (this *Operator_FilterOp) GoString() string

func (*Operator_FilterOp) MarshalTo

func (m *Operator_FilterOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_FilterOp) MarshalToSizedBuffer

func (m *Operator_FilterOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_FilterOp) Size

func (m *Operator_FilterOp) Size() (n int)

func (*Operator_FilterOp) String

func (this *Operator_FilterOp) String() string

type Operator_GRPCSinkOp

type Operator_GRPCSinkOp struct {
	GRPCSinkOp *GRPCSinkOperator `protobuf:"bytes,1000,opt,name=grpc_sink_op,json=grpcSinkOp,proto3,oneof" json:"grpc_sink_op,omitempty"`
}

func (*Operator_GRPCSinkOp) Equal

func (this *Operator_GRPCSinkOp) Equal(that interface{}) bool

func (*Operator_GRPCSinkOp) GoString

func (this *Operator_GRPCSinkOp) GoString() string

func (*Operator_GRPCSinkOp) MarshalTo

func (m *Operator_GRPCSinkOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_GRPCSinkOp) MarshalToSizedBuffer

func (m *Operator_GRPCSinkOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_GRPCSinkOp) Size

func (m *Operator_GRPCSinkOp) Size() (n int)

func (*Operator_GRPCSinkOp) String

func (this *Operator_GRPCSinkOp) String() string

type Operator_GRPCSourceOp

type Operator_GRPCSourceOp struct {
	GRPCSourceOp *GRPCSourceOperator `protobuf:"bytes,9,opt,name=grpc_source_op,json=grpcSourceOp,proto3,oneof" json:"grpc_source_op,omitempty"`
}

func (*Operator_GRPCSourceOp) Equal

func (this *Operator_GRPCSourceOp) Equal(that interface{}) bool

func (*Operator_GRPCSourceOp) GoString

func (this *Operator_GRPCSourceOp) GoString() string

func (*Operator_GRPCSourceOp) MarshalTo

func (m *Operator_GRPCSourceOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_GRPCSourceOp) MarshalToSizedBuffer

func (m *Operator_GRPCSourceOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_GRPCSourceOp) Size

func (m *Operator_GRPCSourceOp) Size() (n int)

func (*Operator_GRPCSourceOp) String

func (this *Operator_GRPCSourceOp) String() string

type Operator_JoinOp

type Operator_JoinOp struct {
	JoinOp *JoinOperator `protobuf:"bytes,11,opt,name=join_op,json=joinOp,proto3,oneof" json:"join_op,omitempty"`
}

func (*Operator_JoinOp) Equal

func (this *Operator_JoinOp) Equal(that interface{}) bool

func (*Operator_JoinOp) GoString

func (this *Operator_JoinOp) GoString() string

func (*Operator_JoinOp) MarshalTo

func (m *Operator_JoinOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_JoinOp) MarshalToSizedBuffer

func (m *Operator_JoinOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_JoinOp) Size

func (m *Operator_JoinOp) Size() (n int)

func (*Operator_JoinOp) String

func (this *Operator_JoinOp) String() string

type Operator_LimitOp

type Operator_LimitOp struct {
	LimitOp *LimitOperator `protobuf:"bytes,7,opt,name=limit_op,json=limitOp,proto3,oneof" json:"limit_op,omitempty"`
}

func (*Operator_LimitOp) Equal

func (this *Operator_LimitOp) Equal(that interface{}) bool

func (*Operator_LimitOp) GoString

func (this *Operator_LimitOp) GoString() string

func (*Operator_LimitOp) MarshalTo

func (m *Operator_LimitOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_LimitOp) MarshalToSizedBuffer

func (m *Operator_LimitOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_LimitOp) Size

func (m *Operator_LimitOp) Size() (n int)

func (*Operator_LimitOp) String

func (this *Operator_LimitOp) String() string

type Operator_MapOp

type Operator_MapOp struct {
	MapOp *MapOperator `protobuf:"bytes,3,opt,name=map_op,json=mapOp,proto3,oneof" json:"map_op,omitempty"`
}

func (*Operator_MapOp) Equal

func (this *Operator_MapOp) Equal(that interface{}) bool

func (*Operator_MapOp) GoString

func (this *Operator_MapOp) GoString() string

func (*Operator_MapOp) MarshalTo

func (m *Operator_MapOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_MapOp) MarshalToSizedBuffer

func (m *Operator_MapOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_MapOp) Size

func (m *Operator_MapOp) Size() (n int)

func (*Operator_MapOp) String

func (this *Operator_MapOp) String() string

type Operator_MemSinkOp

type Operator_MemSinkOp struct {
	MemSinkOp *MemorySinkOperator `protobuf:"bytes,5,opt,name=mem_sink_op,json=memSinkOp,proto3,oneof" json:"mem_sink_op,omitempty"`
}

func (*Operator_MemSinkOp) Equal

func (this *Operator_MemSinkOp) Equal(that interface{}) bool

func (*Operator_MemSinkOp) GoString

func (this *Operator_MemSinkOp) GoString() string

func (*Operator_MemSinkOp) MarshalTo

func (m *Operator_MemSinkOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_MemSinkOp) MarshalToSizedBuffer

func (m *Operator_MemSinkOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_MemSinkOp) Size

func (m *Operator_MemSinkOp) Size() (n int)

func (*Operator_MemSinkOp) String

func (this *Operator_MemSinkOp) String() string

type Operator_MemSourceOp

type Operator_MemSourceOp struct {
	MemSourceOp *MemorySourceOperator `protobuf:"bytes,2,opt,name=mem_source_op,json=memSourceOp,proto3,oneof" json:"mem_source_op,omitempty"`
}

func (*Operator_MemSourceOp) Equal

func (this *Operator_MemSourceOp) Equal(that interface{}) bool

func (*Operator_MemSourceOp) GoString

func (this *Operator_MemSourceOp) GoString() string

func (*Operator_MemSourceOp) MarshalTo

func (m *Operator_MemSourceOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_MemSourceOp) MarshalToSizedBuffer

func (m *Operator_MemSourceOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_MemSourceOp) Size

func (m *Operator_MemSourceOp) Size() (n int)

func (*Operator_MemSourceOp) String

func (this *Operator_MemSourceOp) String() string

type Operator_OTelSinkOp

type Operator_OTelSinkOp struct {
	OTelSinkOp *OTelExportSinkOperator `protobuf:"bytes,14,opt,name=otel_sink_op,json=otelSinkOp,proto3,oneof" json:"otel_sink_op,omitempty"`
}

func (*Operator_OTelSinkOp) Equal

func (this *Operator_OTelSinkOp) Equal(that interface{}) bool

func (*Operator_OTelSinkOp) GoString

func (this *Operator_OTelSinkOp) GoString() string

func (*Operator_OTelSinkOp) MarshalTo

func (m *Operator_OTelSinkOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_OTelSinkOp) MarshalToSizedBuffer

func (m *Operator_OTelSinkOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_OTelSinkOp) Size

func (m *Operator_OTelSinkOp) Size() (n int)

func (*Operator_OTelSinkOp) String

func (this *Operator_OTelSinkOp) String() string

type Operator_UdtfSourceOp

type Operator_UdtfSourceOp struct {
	UdtfSourceOp *UDTFSourceOperator `protobuf:"bytes,12,opt,name=udtf_source_op,json=udtfSourceOp,proto3,oneof" json:"udtf_source_op,omitempty"`
}

func (*Operator_UdtfSourceOp) Equal

func (this *Operator_UdtfSourceOp) Equal(that interface{}) bool

func (*Operator_UdtfSourceOp) GoString

func (this *Operator_UdtfSourceOp) GoString() string

func (*Operator_UdtfSourceOp) MarshalTo

func (m *Operator_UdtfSourceOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_UdtfSourceOp) MarshalToSizedBuffer

func (m *Operator_UdtfSourceOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_UdtfSourceOp) Size

func (m *Operator_UdtfSourceOp) Size() (n int)

func (*Operator_UdtfSourceOp) String

func (this *Operator_UdtfSourceOp) String() string

type Operator_UnionOp

type Operator_UnionOp struct {
	UnionOp *UnionOperator `protobuf:"bytes,8,opt,name=union_op,json=unionOp,proto3,oneof" json:"union_op,omitempty"`
}

func (*Operator_UnionOp) Equal

func (this *Operator_UnionOp) Equal(that interface{}) bool

func (*Operator_UnionOp) GoString

func (this *Operator_UnionOp) GoString() string

func (*Operator_UnionOp) MarshalTo

func (m *Operator_UnionOp) MarshalTo(dAtA []byte) (int, error)

func (*Operator_UnionOp) MarshalToSizedBuffer

func (m *Operator_UnionOp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator_UnionOp) Size

func (m *Operator_UnionOp) Size() (n int)

func (*Operator_UnionOp) String

func (this *Operator_UnionOp) String() string

type Plan

type Plan struct {
	Dag                         *DAG                               `protobuf:"bytes,1,opt,name=dag,proto3" json:"dag,omitempty"`
	Nodes                       []*PlanFragment                    `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	PlanOptions                 *PlanOptions                       `protobuf:"bytes,4,opt,name=plan_options,json=planOptions,proto3" json:"plan_options,omitempty"`
	IncomingAgentIDs            []*uuidpb.UUID                     `protobuf:"bytes,5,rep,name=incoming_agent_ids,json=incomingAgentIds,proto3" json:"incoming_agent_ids,omitempty"`
	ExecutionStatusDestinations []*Plan_ExecutionStatusDestination `` /* 144-byte string literal not displayed */
}

func (*Plan) Descriptor

func (*Plan) Descriptor() ([]byte, []int)

func (*Plan) Equal

func (this *Plan) Equal(that interface{}) bool

func (*Plan) GetDag

func (m *Plan) GetDag() *DAG

func (*Plan) GetExecutionStatusDestinations

func (m *Plan) GetExecutionStatusDestinations() []*Plan_ExecutionStatusDestination

func (*Plan) GetIncomingAgentIDs

func (m *Plan) GetIncomingAgentIDs() []*uuidpb.UUID

func (*Plan) GetNodes

func (m *Plan) GetNodes() []*PlanFragment

func (*Plan) GetPlanOptions

func (m *Plan) GetPlanOptions() *PlanOptions

func (*Plan) GoString

func (this *Plan) GoString() string

func (*Plan) Marshal

func (m *Plan) Marshal() (dAtA []byte, err error)

func (*Plan) MarshalTo

func (m *Plan) MarshalTo(dAtA []byte) (int, error)

func (*Plan) MarshalToSizedBuffer

func (m *Plan) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Plan) ProtoMessage

func (*Plan) ProtoMessage()

func (*Plan) Reset

func (m *Plan) Reset()

func (*Plan) Size

func (m *Plan) Size() (n int)

func (*Plan) String

func (this *Plan) String() string

func (*Plan) Unmarshal

func (m *Plan) Unmarshal(dAtA []byte) error

func (*Plan) XXX_DiscardUnknown

func (m *Plan) XXX_DiscardUnknown()

func (*Plan) XXX_Marshal

func (m *Plan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Plan) XXX_Merge

func (m *Plan) XXX_Merge(src proto.Message)

func (*Plan) XXX_Size

func (m *Plan) XXX_Size() int

func (*Plan) XXX_Unmarshal

func (m *Plan) XXX_Unmarshal(b []byte) error

type PlanFragment

type PlanFragment struct {
	Id    uint64      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Dag   *DAG        `protobuf:"bytes,2,opt,name=dag,proto3" json:"dag,omitempty"`
	Nodes []*PlanNode `protobuf:"bytes,3,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

func (*PlanFragment) Descriptor

func (*PlanFragment) Descriptor() ([]byte, []int)

func (*PlanFragment) Equal

func (this *PlanFragment) Equal(that interface{}) bool

func (*PlanFragment) GetDag

func (m *PlanFragment) GetDag() *DAG

func (*PlanFragment) GetId

func (m *PlanFragment) GetId() uint64

func (*PlanFragment) GetNodes

func (m *PlanFragment) GetNodes() []*PlanNode

func (*PlanFragment) GoString

func (this *PlanFragment) GoString() string

func (*PlanFragment) Marshal

func (m *PlanFragment) Marshal() (dAtA []byte, err error)

func (*PlanFragment) MarshalTo

func (m *PlanFragment) MarshalTo(dAtA []byte) (int, error)

func (*PlanFragment) MarshalToSizedBuffer

func (m *PlanFragment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PlanFragment) ProtoMessage

func (*PlanFragment) ProtoMessage()

func (*PlanFragment) Reset

func (m *PlanFragment) Reset()

func (*PlanFragment) Size

func (m *PlanFragment) Size() (n int)

func (*PlanFragment) String

func (this *PlanFragment) String() string

func (*PlanFragment) Unmarshal

func (m *PlanFragment) Unmarshal(dAtA []byte) error

func (*PlanFragment) XXX_DiscardUnknown

func (m *PlanFragment) XXX_DiscardUnknown()

func (*PlanFragment) XXX_Marshal

func (m *PlanFragment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlanFragment) XXX_Merge

func (m *PlanFragment) XXX_Merge(src proto.Message)

func (*PlanFragment) XXX_Size

func (m *PlanFragment) XXX_Size() int

func (*PlanFragment) XXX_Unmarshal

func (m *PlanFragment) XXX_Unmarshal(b []byte) error

type PlanNode

type PlanNode struct {
	Id uint64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Op *Operator `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`
}

func (*PlanNode) Descriptor

func (*PlanNode) Descriptor() ([]byte, []int)

func (*PlanNode) Equal

func (this *PlanNode) Equal(that interface{}) bool

func (*PlanNode) GetId

func (m *PlanNode) GetId() uint64

func (*PlanNode) GetOp

func (m *PlanNode) GetOp() *Operator

func (*PlanNode) GoString

func (this *PlanNode) GoString() string

func (*PlanNode) Marshal

func (m *PlanNode) Marshal() (dAtA []byte, err error)

func (*PlanNode) MarshalTo

func (m *PlanNode) MarshalTo(dAtA []byte) (int, error)

func (*PlanNode) MarshalToSizedBuffer

func (m *PlanNode) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PlanNode) ProtoMessage

func (*PlanNode) ProtoMessage()

func (*PlanNode) Reset

func (m *PlanNode) Reset()

func (*PlanNode) Size

func (m *PlanNode) Size() (n int)

func (*PlanNode) String

func (this *PlanNode) String() string

func (*PlanNode) Unmarshal

func (m *PlanNode) Unmarshal(dAtA []byte) error

func (*PlanNode) XXX_DiscardUnknown

func (m *PlanNode) XXX_DiscardUnknown()

func (*PlanNode) XXX_Marshal

func (m *PlanNode) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlanNode) XXX_Merge

func (m *PlanNode) XXX_Merge(src proto.Message)

func (*PlanNode) XXX_Size

func (m *PlanNode) XXX_Size() int

func (*PlanNode) XXX_Unmarshal

func (m *PlanNode) XXX_Unmarshal(b []byte) error

type PlanOptions

type PlanOptions struct {
	Explain               bool  `protobuf:"varint,2,opt,name=explain,proto3" json:"explain,omitempty"`
	Analyze               bool  `protobuf:"varint,3,opt,name=analyze,proto3" json:"analyze,omitempty"`
	MaxOutputRowsPerTable int64 `` /* 131-byte string literal not displayed */
}

func (*PlanOptions) Descriptor

func (*PlanOptions) Descriptor() ([]byte, []int)

func (*PlanOptions) Equal

func (this *PlanOptions) Equal(that interface{}) bool

func (*PlanOptions) GetAnalyze

func (m *PlanOptions) GetAnalyze() bool

func (*PlanOptions) GetExplain

func (m *PlanOptions) GetExplain() bool

func (*PlanOptions) GetMaxOutputRowsPerTable

func (m *PlanOptions) GetMaxOutputRowsPerTable() int64

func (*PlanOptions) GoString

func (this *PlanOptions) GoString() string

func (*PlanOptions) Marshal

func (m *PlanOptions) Marshal() (dAtA []byte, err error)

func (*PlanOptions) MarshalTo

func (m *PlanOptions) MarshalTo(dAtA []byte) (int, error)

func (*PlanOptions) MarshalToSizedBuffer

func (m *PlanOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PlanOptions) ProtoMessage

func (*PlanOptions) ProtoMessage()

func (*PlanOptions) Reset

func (m *PlanOptions) Reset()

func (*PlanOptions) Size

func (m *PlanOptions) Size() (n int)

func (*PlanOptions) String

func (this *PlanOptions) String() string

func (*PlanOptions) Unmarshal

func (m *PlanOptions) Unmarshal(dAtA []byte) error

func (*PlanOptions) XXX_DiscardUnknown

func (m *PlanOptions) XXX_DiscardUnknown()

func (*PlanOptions) XXX_Marshal

func (m *PlanOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PlanOptions) XXX_Merge

func (m *PlanOptions) XXX_Merge(src proto.Message)

func (*PlanOptions) XXX_Size

func (m *PlanOptions) XXX_Size() int

func (*PlanOptions) XXX_Unmarshal

func (m *PlanOptions) XXX_Unmarshal(b []byte) error

type Plan_ExecutionStatusDestination

type Plan_ExecutionStatusDestination struct {
	GrpcAddress   string `protobuf:"bytes,1,opt,name=grpc_address,json=grpcAddress,proto3" json:"grpc_address,omitempty"`
	SslTargetname string `protobuf:"bytes,2,opt,name=ssl_targetname,json=sslTargetname,proto3" json:"ssl_targetname,omitempty"`
}

func (*Plan_ExecutionStatusDestination) Descriptor

func (*Plan_ExecutionStatusDestination) Descriptor() ([]byte, []int)

func (*Plan_ExecutionStatusDestination) Equal

func (this *Plan_ExecutionStatusDestination) Equal(that interface{}) bool

func (*Plan_ExecutionStatusDestination) GetGrpcAddress

func (m *Plan_ExecutionStatusDestination) GetGrpcAddress() string

func (*Plan_ExecutionStatusDestination) GetSslTargetname

func (m *Plan_ExecutionStatusDestination) GetSslTargetname() string

func (*Plan_ExecutionStatusDestination) GoString

func (this *Plan_ExecutionStatusDestination) GoString() string

func (*Plan_ExecutionStatusDestination) Marshal

func (m *Plan_ExecutionStatusDestination) Marshal() (dAtA []byte, err error)

func (*Plan_ExecutionStatusDestination) MarshalTo

func (m *Plan_ExecutionStatusDestination) MarshalTo(dAtA []byte) (int, error)

func (*Plan_ExecutionStatusDestination) MarshalToSizedBuffer

func (m *Plan_ExecutionStatusDestination) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Plan_ExecutionStatusDestination) ProtoMessage

func (*Plan_ExecutionStatusDestination) ProtoMessage()

func (*Plan_ExecutionStatusDestination) Reset

func (m *Plan_ExecutionStatusDestination) Reset()

func (*Plan_ExecutionStatusDestination) Size

func (m *Plan_ExecutionStatusDestination) Size() (n int)

func (*Plan_ExecutionStatusDestination) String

func (this *Plan_ExecutionStatusDestination) String() string

func (*Plan_ExecutionStatusDestination) Unmarshal

func (m *Plan_ExecutionStatusDestination) Unmarshal(dAtA []byte) error

func (*Plan_ExecutionStatusDestination) XXX_DiscardUnknown

func (m *Plan_ExecutionStatusDestination) XXX_DiscardUnknown()

func (*Plan_ExecutionStatusDestination) XXX_Marshal

func (m *Plan_ExecutionStatusDestination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Plan_ExecutionStatusDestination) XXX_Merge

func (m *Plan_ExecutionStatusDestination) XXX_Merge(src proto.Message)

func (*Plan_ExecutionStatusDestination) XXX_Size

func (m *Plan_ExecutionStatusDestination) XXX_Size() int

func (*Plan_ExecutionStatusDestination) XXX_Unmarshal

func (m *Plan_ExecutionStatusDestination) XXX_Unmarshal(b []byte) error

type ScalarExpression

type ScalarExpression struct {
	// Types that are valid to be assigned to Value:
	//
	//	*ScalarExpression_Constant
	//	*ScalarExpression_Column
	//	*ScalarExpression_Func
	Value isScalarExpression_Value `protobuf_oneof:"value"`
}

func (*ScalarExpression) Descriptor

func (*ScalarExpression) Descriptor() ([]byte, []int)

func (*ScalarExpression) Equal

func (this *ScalarExpression) Equal(that interface{}) bool

func (*ScalarExpression) GetColumn

func (m *ScalarExpression) GetColumn() *Column

func (*ScalarExpression) GetConstant

func (m *ScalarExpression) GetConstant() *ScalarValue

func (*ScalarExpression) GetFunc

func (m *ScalarExpression) GetFunc() *ScalarFunc

func (*ScalarExpression) GetValue

func (m *ScalarExpression) GetValue() isScalarExpression_Value

func (*ScalarExpression) GoString

func (this *ScalarExpression) GoString() string

func (*ScalarExpression) Marshal

func (m *ScalarExpression) Marshal() (dAtA []byte, err error)

func (*ScalarExpression) MarshalTo

func (m *ScalarExpression) MarshalTo(dAtA []byte) (int, error)

func (*ScalarExpression) MarshalToSizedBuffer

func (m *ScalarExpression) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarExpression) ProtoMessage

func (*ScalarExpression) ProtoMessage()

func (*ScalarExpression) Reset

func (m *ScalarExpression) Reset()

func (*ScalarExpression) Size

func (m *ScalarExpression) Size() (n int)

func (*ScalarExpression) String

func (this *ScalarExpression) String() string

func (*ScalarExpression) Unmarshal

func (m *ScalarExpression) Unmarshal(dAtA []byte) error

func (*ScalarExpression) XXX_DiscardUnknown

func (m *ScalarExpression) XXX_DiscardUnknown()

func (*ScalarExpression) XXX_Marshal

func (m *ScalarExpression) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScalarExpression) XXX_Merge

func (m *ScalarExpression) XXX_Merge(src proto.Message)

func (*ScalarExpression) XXX_OneofWrappers

func (*ScalarExpression) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ScalarExpression) XXX_Size

func (m *ScalarExpression) XXX_Size() int

func (*ScalarExpression) XXX_Unmarshal

func (m *ScalarExpression) XXX_Unmarshal(b []byte) error

type ScalarExpression_Column

type ScalarExpression_Column struct {
	Column *Column `protobuf:"bytes,2,opt,name=column,proto3,oneof" json:"column,omitempty"`
}

func (*ScalarExpression_Column) Equal

func (this *ScalarExpression_Column) Equal(that interface{}) bool

func (*ScalarExpression_Column) GoString

func (this *ScalarExpression_Column) GoString() string

func (*ScalarExpression_Column) MarshalTo

func (m *ScalarExpression_Column) MarshalTo(dAtA []byte) (int, error)

func (*ScalarExpression_Column) MarshalToSizedBuffer

func (m *ScalarExpression_Column) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarExpression_Column) Size

func (m *ScalarExpression_Column) Size() (n int)

func (*ScalarExpression_Column) String

func (this *ScalarExpression_Column) String() string

type ScalarExpression_Constant

type ScalarExpression_Constant struct {
	Constant *ScalarValue `protobuf:"bytes,1,opt,name=constant,proto3,oneof" json:"constant,omitempty"`
}

func (*ScalarExpression_Constant) Equal

func (this *ScalarExpression_Constant) Equal(that interface{}) bool

func (*ScalarExpression_Constant) GoString

func (this *ScalarExpression_Constant) GoString() string

func (*ScalarExpression_Constant) MarshalTo

func (m *ScalarExpression_Constant) MarshalTo(dAtA []byte) (int, error)

func (*ScalarExpression_Constant) MarshalToSizedBuffer

func (m *ScalarExpression_Constant) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarExpression_Constant) Size

func (m *ScalarExpression_Constant) Size() (n int)

func (*ScalarExpression_Constant) String

func (this *ScalarExpression_Constant) String() string

type ScalarExpression_Func

type ScalarExpression_Func struct {
	Func *ScalarFunc `protobuf:"bytes,3,opt,name=func,proto3,oneof" json:"func,omitempty"`
}

func (*ScalarExpression_Func) Equal

func (this *ScalarExpression_Func) Equal(that interface{}) bool

func (*ScalarExpression_Func) GoString

func (this *ScalarExpression_Func) GoString() string

func (*ScalarExpression_Func) MarshalTo

func (m *ScalarExpression_Func) MarshalTo(dAtA []byte) (int, error)

func (*ScalarExpression_Func) MarshalToSizedBuffer

func (m *ScalarExpression_Func) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarExpression_Func) Size

func (m *ScalarExpression_Func) Size() (n int)

func (*ScalarExpression_Func) String

func (this *ScalarExpression_Func) String() string

type ScalarFunc

type ScalarFunc struct {
	Name          string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InitArgs      []*ScalarValue      `protobuf:"bytes,2,rep,name=init_args,json=initArgs,proto3" json:"init_args,omitempty"`
	Args          []*ScalarExpression `protobuf:"bytes,3,rep,name=args,proto3" json:"args,omitempty"`
	Id            int64               `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	ArgsDataTypes []typespb.DataType  `` /* 133-byte string literal not displayed */
}

func (*ScalarFunc) Descriptor

func (*ScalarFunc) Descriptor() ([]byte, []int)

func (*ScalarFunc) Equal

func (this *ScalarFunc) Equal(that interface{}) bool

func (*ScalarFunc) GetArgs

func (m *ScalarFunc) GetArgs() []*ScalarExpression

func (*ScalarFunc) GetArgsDataTypes

func (m *ScalarFunc) GetArgsDataTypes() []typespb.DataType

func (*ScalarFunc) GetId

func (m *ScalarFunc) GetId() int64

func (*ScalarFunc) GetInitArgs

func (m *ScalarFunc) GetInitArgs() []*ScalarValue

func (*ScalarFunc) GetName

func (m *ScalarFunc) GetName() string

func (*ScalarFunc) GoString

func (this *ScalarFunc) GoString() string

func (*ScalarFunc) Marshal

func (m *ScalarFunc) Marshal() (dAtA []byte, err error)

func (*ScalarFunc) MarshalTo

func (m *ScalarFunc) MarshalTo(dAtA []byte) (int, error)

func (*ScalarFunc) MarshalToSizedBuffer

func (m *ScalarFunc) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarFunc) ProtoMessage

func (*ScalarFunc) ProtoMessage()

func (*ScalarFunc) Reset

func (m *ScalarFunc) Reset()

func (*ScalarFunc) Size

func (m *ScalarFunc) Size() (n int)

func (*ScalarFunc) String

func (this *ScalarFunc) String() string

func (*ScalarFunc) Unmarshal

func (m *ScalarFunc) Unmarshal(dAtA []byte) error

func (*ScalarFunc) XXX_DiscardUnknown

func (m *ScalarFunc) XXX_DiscardUnknown()

func (*ScalarFunc) XXX_Marshal

func (m *ScalarFunc) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScalarFunc) XXX_Merge

func (m *ScalarFunc) XXX_Merge(src proto.Message)

func (*ScalarFunc) XXX_Size

func (m *ScalarFunc) XXX_Size() int

func (*ScalarFunc) XXX_Unmarshal

func (m *ScalarFunc) XXX_Unmarshal(b []byte) error

type ScalarValue

type ScalarValue struct {
	DataType typespb.DataType `protobuf:"varint,1,opt,name=data_type,json=dataType,proto3,enum=px.types.DataType" json:"data_type,omitempty"`
	// Types that are valid to be assigned to Value:
	//
	//	*ScalarValue_BoolValue
	//	*ScalarValue_Int64Value
	//	*ScalarValue_Float64Value
	//	*ScalarValue_StringValue
	//	*ScalarValue_Time64NsValue
	//	*ScalarValue_Uint128Value
	Value isScalarValue_Value `protobuf_oneof:"value"`
}

func (*ScalarValue) Descriptor

func (*ScalarValue) Descriptor() ([]byte, []int)

func (*ScalarValue) Equal

func (this *ScalarValue) Equal(that interface{}) bool

func (*ScalarValue) GetBoolValue

func (m *ScalarValue) GetBoolValue() bool

func (*ScalarValue) GetDataType

func (m *ScalarValue) GetDataType() typespb.DataType

func (*ScalarValue) GetFloat64Value

func (m *ScalarValue) GetFloat64Value() float64

func (*ScalarValue) GetInt64Value

func (m *ScalarValue) GetInt64Value() int64

func (*ScalarValue) GetStringValue

func (m *ScalarValue) GetStringValue() string

func (*ScalarValue) GetTime64NsValue

func (m *ScalarValue) GetTime64NsValue() int64

func (*ScalarValue) GetUint128Value

func (m *ScalarValue) GetUint128Value() *typespb.UInt128

func (*ScalarValue) GetValue

func (m *ScalarValue) GetValue() isScalarValue_Value

func (*ScalarValue) GoString

func (this *ScalarValue) GoString() string

func (*ScalarValue) Marshal

func (m *ScalarValue) Marshal() (dAtA []byte, err error)

func (*ScalarValue) MarshalTo

func (m *ScalarValue) MarshalTo(dAtA []byte) (int, error)

func (*ScalarValue) MarshalToSizedBuffer

func (m *ScalarValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarValue) ProtoMessage

func (*ScalarValue) ProtoMessage()

func (*ScalarValue) Reset

func (m *ScalarValue) Reset()

func (*ScalarValue) Size

func (m *ScalarValue) Size() (n int)

func (*ScalarValue) String

func (this *ScalarValue) String() string

func (*ScalarValue) Unmarshal

func (m *ScalarValue) Unmarshal(dAtA []byte) error

func (*ScalarValue) XXX_DiscardUnknown

func (m *ScalarValue) XXX_DiscardUnknown()

func (*ScalarValue) XXX_Marshal

func (m *ScalarValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScalarValue) XXX_Merge

func (m *ScalarValue) XXX_Merge(src proto.Message)

func (*ScalarValue) XXX_OneofWrappers

func (*ScalarValue) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ScalarValue) XXX_Size

func (m *ScalarValue) XXX_Size() int

func (*ScalarValue) XXX_Unmarshal

func (m *ScalarValue) XXX_Unmarshal(b []byte) error

type ScalarValue_BoolValue

type ScalarValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof" json:"bool_value,omitempty"`
}

func (*ScalarValue_BoolValue) Equal

func (this *ScalarValue_BoolValue) Equal(that interface{}) bool

func (*ScalarValue_BoolValue) GoString

func (this *ScalarValue_BoolValue) GoString() string

func (*ScalarValue_BoolValue) MarshalTo

func (m *ScalarValue_BoolValue) MarshalTo(dAtA []byte) (int, error)

func (*ScalarValue_BoolValue) MarshalToSizedBuffer

func (m *ScalarValue_BoolValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarValue_BoolValue) Size

func (m *ScalarValue_BoolValue) Size() (n int)

func (*ScalarValue_BoolValue) String

func (this *ScalarValue_BoolValue) String() string

type ScalarValue_Float64Value

type ScalarValue_Float64Value struct {
	Float64Value float64 `protobuf:"fixed64,4,opt,name=float64_value,json=float64Value,proto3,oneof" json:"float64_value,omitempty"`
}

func (*ScalarValue_Float64Value) Equal

func (this *ScalarValue_Float64Value) Equal(that interface{}) bool

func (*ScalarValue_Float64Value) GoString

func (this *ScalarValue_Float64Value) GoString() string

func (*ScalarValue_Float64Value) MarshalTo

func (m *ScalarValue_Float64Value) MarshalTo(dAtA []byte) (int, error)

func (*ScalarValue_Float64Value) MarshalToSizedBuffer

func (m *ScalarValue_Float64Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarValue_Float64Value) Size

func (m *ScalarValue_Float64Value) Size() (n int)

func (*ScalarValue_Float64Value) String

func (this *ScalarValue_Float64Value) String() string

type ScalarValue_Int64Value

type ScalarValue_Int64Value struct {
	Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3,oneof" json:"int64_value,omitempty"`
}

func (*ScalarValue_Int64Value) Equal

func (this *ScalarValue_Int64Value) Equal(that interface{}) bool

func (*ScalarValue_Int64Value) GoString

func (this *ScalarValue_Int64Value) GoString() string

func (*ScalarValue_Int64Value) MarshalTo

func (m *ScalarValue_Int64Value) MarshalTo(dAtA []byte) (int, error)

func (*ScalarValue_Int64Value) MarshalToSizedBuffer

func (m *ScalarValue_Int64Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarValue_Int64Value) Size

func (m *ScalarValue_Int64Value) Size() (n int)

func (*ScalarValue_Int64Value) String

func (this *ScalarValue_Int64Value) String() string

type ScalarValue_StringValue

type ScalarValue_StringValue struct {
	StringValue string `protobuf:"bytes,5,opt,name=string_value,json=stringValue,proto3,oneof" json:"string_value,omitempty"`
}

func (*ScalarValue_StringValue) Equal

func (this *ScalarValue_StringValue) Equal(that interface{}) bool

func (*ScalarValue_StringValue) GoString

func (this *ScalarValue_StringValue) GoString() string

func (*ScalarValue_StringValue) MarshalTo

func (m *ScalarValue_StringValue) MarshalTo(dAtA []byte) (int, error)

func (*ScalarValue_StringValue) MarshalToSizedBuffer

func (m *ScalarValue_StringValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarValue_StringValue) Size

func (m *ScalarValue_StringValue) Size() (n int)

func (*ScalarValue_StringValue) String

func (this *ScalarValue_StringValue) String() string

type ScalarValue_Time64NsValue

type ScalarValue_Time64NsValue struct {
	Time64NsValue int64 `protobuf:"varint,6,opt,name=time64_ns_value,json=time64NsValue,proto3,oneof" json:"time64_ns_value,omitempty"`
}

func (*ScalarValue_Time64NsValue) Equal

func (this *ScalarValue_Time64NsValue) Equal(that interface{}) bool

func (*ScalarValue_Time64NsValue) GoString

func (this *ScalarValue_Time64NsValue) GoString() string

func (*ScalarValue_Time64NsValue) MarshalTo

func (m *ScalarValue_Time64NsValue) MarshalTo(dAtA []byte) (int, error)

func (*ScalarValue_Time64NsValue) MarshalToSizedBuffer

func (m *ScalarValue_Time64NsValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarValue_Time64NsValue) Size

func (m *ScalarValue_Time64NsValue) Size() (n int)

func (*ScalarValue_Time64NsValue) String

func (this *ScalarValue_Time64NsValue) String() string

type ScalarValue_Uint128Value

type ScalarValue_Uint128Value struct {
	Uint128Value *typespb.UInt128 `protobuf:"bytes,7,opt,name=uint128_value,json=uint128Value,proto3,oneof" json:"uint128_value,omitempty"`
}

func (*ScalarValue_Uint128Value) Equal

func (this *ScalarValue_Uint128Value) Equal(that interface{}) bool

func (*ScalarValue_Uint128Value) GoString

func (this *ScalarValue_Uint128Value) GoString() string

func (*ScalarValue_Uint128Value) MarshalTo

func (m *ScalarValue_Uint128Value) MarshalTo(dAtA []byte) (int, error)

func (*ScalarValue_Uint128Value) MarshalToSizedBuffer

func (m *ScalarValue_Uint128Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScalarValue_Uint128Value) Size

func (m *ScalarValue_Uint128Value) Size() (n int)

func (*ScalarValue_Uint128Value) String

func (this *ScalarValue_Uint128Value) String() string

type UDTFSourceOperator

type UDTFSourceOperator struct {
	Name      string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ArgValues []*ScalarValue `protobuf:"bytes,2,rep,name=arg_values,json=argValues,proto3" json:"arg_values,omitempty"`
}

func (*UDTFSourceOperator) Descriptor

func (*UDTFSourceOperator) Descriptor() ([]byte, []int)

func (*UDTFSourceOperator) Equal

func (this *UDTFSourceOperator) Equal(that interface{}) bool

func (*UDTFSourceOperator) GetArgValues

func (m *UDTFSourceOperator) GetArgValues() []*ScalarValue

func (*UDTFSourceOperator) GetName

func (m *UDTFSourceOperator) GetName() string

func (*UDTFSourceOperator) GoString

func (this *UDTFSourceOperator) GoString() string

func (*UDTFSourceOperator) Marshal

func (m *UDTFSourceOperator) Marshal() (dAtA []byte, err error)

func (*UDTFSourceOperator) MarshalTo

func (m *UDTFSourceOperator) MarshalTo(dAtA []byte) (int, error)

func (*UDTFSourceOperator) MarshalToSizedBuffer

func (m *UDTFSourceOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UDTFSourceOperator) ProtoMessage

func (*UDTFSourceOperator) ProtoMessage()

func (*UDTFSourceOperator) Reset

func (m *UDTFSourceOperator) Reset()

func (*UDTFSourceOperator) Size

func (m *UDTFSourceOperator) Size() (n int)

func (*UDTFSourceOperator) String

func (this *UDTFSourceOperator) String() string

func (*UDTFSourceOperator) Unmarshal

func (m *UDTFSourceOperator) Unmarshal(dAtA []byte) error

func (*UDTFSourceOperator) XXX_DiscardUnknown

func (m *UDTFSourceOperator) XXX_DiscardUnknown()

func (*UDTFSourceOperator) XXX_Marshal

func (m *UDTFSourceOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UDTFSourceOperator) XXX_Merge

func (m *UDTFSourceOperator) XXX_Merge(src proto.Message)

func (*UDTFSourceOperator) XXX_Size

func (m *UDTFSourceOperator) XXX_Size() int

func (*UDTFSourceOperator) XXX_Unmarshal

func (m *UDTFSourceOperator) XXX_Unmarshal(b []byte) error

type UnionOperator

type UnionOperator struct {
	ColumnNames    []string                       `protobuf:"bytes,1,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	ColumnMappings []*UnionOperator_ColumnMapping `protobuf:"bytes,2,rep,name=column_mappings,json=columnMappings,proto3" json:"column_mappings,omitempty"`
	RowsPerBatch   uint64                         `protobuf:"varint,3,opt,name=rows_per_batch,json=rowsPerBatch,proto3" json:"rows_per_batch,omitempty"`
}

func (*UnionOperator) Descriptor

func (*UnionOperator) Descriptor() ([]byte, []int)

func (*UnionOperator) Equal

func (this *UnionOperator) Equal(that interface{}) bool

func (*UnionOperator) GetColumnMappings

func (m *UnionOperator) GetColumnMappings() []*UnionOperator_ColumnMapping

func (*UnionOperator) GetColumnNames

func (m *UnionOperator) GetColumnNames() []string

func (*UnionOperator) GetRowsPerBatch

func (m *UnionOperator) GetRowsPerBatch() uint64

func (*UnionOperator) GoString

func (this *UnionOperator) GoString() string

func (*UnionOperator) Marshal

func (m *UnionOperator) Marshal() (dAtA []byte, err error)

func (*UnionOperator) MarshalTo

func (m *UnionOperator) MarshalTo(dAtA []byte) (int, error)

func (*UnionOperator) MarshalToSizedBuffer

func (m *UnionOperator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnionOperator) ProtoMessage

func (*UnionOperator) ProtoMessage()

func (*UnionOperator) Reset

func (m *UnionOperator) Reset()

func (*UnionOperator) Size

func (m *UnionOperator) Size() (n int)

func (*UnionOperator) String

func (this *UnionOperator) String() string

func (*UnionOperator) Unmarshal

func (m *UnionOperator) Unmarshal(dAtA []byte) error

func (*UnionOperator) XXX_DiscardUnknown

func (m *UnionOperator) XXX_DiscardUnknown()

func (*UnionOperator) XXX_Marshal

func (m *UnionOperator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnionOperator) XXX_Merge

func (m *UnionOperator) XXX_Merge(src proto.Message)

func (*UnionOperator) XXX_Size

func (m *UnionOperator) XXX_Size() int

func (*UnionOperator) XXX_Unmarshal

func (m *UnionOperator) XXX_Unmarshal(b []byte) error

type UnionOperator_ColumnMapping

type UnionOperator_ColumnMapping struct {
	ColumnIndexes []int64 `protobuf:"varint,1,rep,packed,name=column_indexes,json=columnIndexes,proto3" json:"column_indexes,omitempty"`
}

func (*UnionOperator_ColumnMapping) Descriptor

func (*UnionOperator_ColumnMapping) Descriptor() ([]byte, []int)

func (*UnionOperator_ColumnMapping) Equal

func (this *UnionOperator_ColumnMapping) Equal(that interface{}) bool

func (*UnionOperator_ColumnMapping) GetColumnIndexes

func (m *UnionOperator_ColumnMapping) GetColumnIndexes() []int64

func (*UnionOperator_ColumnMapping) GoString

func (this *UnionOperator_ColumnMapping) GoString() string

func (*UnionOperator_ColumnMapping) Marshal

func (m *UnionOperator_ColumnMapping) Marshal() (dAtA []byte, err error)

func (*UnionOperator_ColumnMapping) MarshalTo

func (m *UnionOperator_ColumnMapping) MarshalTo(dAtA []byte) (int, error)

func (*UnionOperator_ColumnMapping) MarshalToSizedBuffer

func (m *UnionOperator_ColumnMapping) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnionOperator_ColumnMapping) ProtoMessage

func (*UnionOperator_ColumnMapping) ProtoMessage()

func (*UnionOperator_ColumnMapping) Reset

func (m *UnionOperator_ColumnMapping) Reset()

func (*UnionOperator_ColumnMapping) Size

func (m *UnionOperator_ColumnMapping) Size() (n int)

func (*UnionOperator_ColumnMapping) String

func (this *UnionOperator_ColumnMapping) String() string

func (*UnionOperator_ColumnMapping) Unmarshal

func (m *UnionOperator_ColumnMapping) Unmarshal(dAtA []byte) error

func (*UnionOperator_ColumnMapping) XXX_DiscardUnknown

func (m *UnionOperator_ColumnMapping) XXX_DiscardUnknown()

func (*UnionOperator_ColumnMapping) XXX_Marshal

func (m *UnionOperator_ColumnMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnionOperator_ColumnMapping) XXX_Merge

func (m *UnionOperator_ColumnMapping) XXX_Merge(src proto.Message)

func (*UnionOperator_ColumnMapping) XXX_Size

func (m *UnionOperator_ColumnMapping) XXX_Size() int

func (*UnionOperator_ColumnMapping) XXX_Unmarshal

func (m *UnionOperator_ColumnMapping) XXX_Unmarshal(b []byte) error