substrait_extension

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 30, 2024 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_substrait_extension_dist_plan_proto protoreflect.FileDescriptor
View Source 
var File_substrait_extension_promql_plan_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type EmptyMetric 

type EmptyMetric struct {

	// Start timestamp in millisecond
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// End timestamp in millisecond
	End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// Interval in millisecond
	Interval int64 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// contains filtered or unexported fields
}

func (*EmptyMetric) Descriptor deprecated 

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

Deprecated: Use EmptyMetric.ProtoReflect.Descriptor instead.

func (*EmptyMetric) GetEnd 

func (x *EmptyMetric) GetEnd() int64

func (*EmptyMetric) GetInterval 

func (x *EmptyMetric) GetInterval() int64

func (*EmptyMetric) GetStart 

func (x *EmptyMetric) GetStart() int64

func (*EmptyMetric) ProtoMessage 

func (*EmptyMetric) ProtoMessage()

func (*EmptyMetric) ProtoReflect 

func (x *EmptyMetric) ProtoReflect() protoreflect.Message

func (*EmptyMetric) Reset 

func (x *EmptyMetric) Reset()

func (*EmptyMetric) String 

func (x *EmptyMetric) String() string

type InstantManipulate 

type InstantManipulate struct {

	// Start timestamp in millisecond
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// End timestamp in millisecond
	End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// Interval in millisecond
	Interval int64 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// Look-back delta in millisecond
	LookbackDelta int64 `protobuf:"varint,4,opt,name=lookback_delta,json=lookbackDelta,proto3" json:"lookback_delta,omitempty"`
	// Column name of time index column
	TimeIndex string `protobuf:"bytes,5,opt,name=time_index,json=timeIndex,proto3" json:"time_index,omitempty"`
	// Optional field column name for validating staleness
	FieldIndex string `protobuf:"bytes,6,opt,name=field_index,json=fieldIndex,proto3" json:"field_index,omitempty"`
	// contains filtered or unexported fields
}

func (*InstantManipulate) Descriptor deprecated 

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

Deprecated: Use InstantManipulate.ProtoReflect.Descriptor instead.

func (*InstantManipulate) GetEnd 

func (x *InstantManipulate) GetEnd() int64

func (*InstantManipulate) GetFieldIndex 

func (x *InstantManipulate) GetFieldIndex() string

func (*InstantManipulate) GetInterval 

func (x *InstantManipulate) GetInterval() int64

func (*InstantManipulate) GetLookbackDelta 

func (x *InstantManipulate) GetLookbackDelta() int64

func (*InstantManipulate) GetStart 

func (x *InstantManipulate) GetStart() int64

func (*InstantManipulate) GetTimeIndex 

func (x *InstantManipulate) GetTimeIndex() string

func (*InstantManipulate) ProtoMessage 

func (*InstantManipulate) ProtoMessage()

func (*InstantManipulate) ProtoReflect 

func (x *InstantManipulate) ProtoReflect() protoreflect.Message

func (*InstantManipulate) Reset 

func (x *InstantManipulate) Reset()

func (*InstantManipulate) String 

func (x *InstantManipulate) String() string

type MergeScan added in v0.9.0 

type MergeScan struct {

	// the input logical plan
	Input []byte `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	// whether this plan is a placeholder
	IsPlaceholder bool `protobuf:"varint,2,opt,name=is_placeholder,json=isPlaceholder,proto3" json:"is_placeholder,omitempty"`
	// contains filtered or unexported fields
}

func (*MergeScan) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use MergeScan.ProtoReflect.Descriptor instead.

func (*MergeScan) GetInput added in v0.9.0 

func (x *MergeScan) GetInput() []byte

func (*MergeScan) GetIsPlaceholder added in v0.9.0 

func (x *MergeScan) GetIsPlaceholder() bool

func (*MergeScan) ProtoMessage added in v0.9.0 

func (*MergeScan) ProtoMessage()

func (*MergeScan) ProtoReflect added in v0.9.0 

func (x *MergeScan) ProtoReflect() protoreflect.Message

func (*MergeScan) Reset added in v0.9.0 

func (x *MergeScan) Reset()

func (*MergeScan) String added in v0.9.0 

func (x *MergeScan) String() string

type RangeManipulate 

type RangeManipulate struct {

	// Start timestamp in millisecond
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// End timestamp in millisecond
	End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// Interval in millisecond
	Interval int64 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// Range in millisecond
	Range int64 `protobuf:"varint,4,opt,name=range,proto3" json:"range,omitempty"`
	// Column name of time index column
	TimeIndex string `protobuf:"bytes,5,opt,name=time_index,json=timeIndex,proto3" json:"time_index,omitempty"`
	// Names of tag columns
	TagColumns []string `protobuf:"bytes,6,rep,name=tag_columns,json=tagColumns,proto3" json:"tag_columns,omitempty"`
	// contains filtered or unexported fields
}

func (*RangeManipulate) Descriptor deprecated 

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

Deprecated: Use RangeManipulate.ProtoReflect.Descriptor instead.

func (*RangeManipulate) GetEnd 

func (x *RangeManipulate) GetEnd() int64

func (*RangeManipulate) GetInterval 

func (x *RangeManipulate) GetInterval() int64

func (*RangeManipulate) GetRange 

func (x *RangeManipulate) GetRange() int64

func (*RangeManipulate) GetStart 

func (x *RangeManipulate) GetStart() int64

func (*RangeManipulate) GetTagColumns 

func (x *RangeManipulate) GetTagColumns() []string

func (*RangeManipulate) GetTimeIndex 

func (x *RangeManipulate) GetTimeIndex() string

func (*RangeManipulate) ProtoMessage 

func (*RangeManipulate) ProtoMessage()

func (*RangeManipulate) ProtoReflect 

func (x *RangeManipulate) ProtoReflect() protoreflect.Message

func (*RangeManipulate) Reset 

func (x *RangeManipulate) Reset()

func (*RangeManipulate) String 

func (x *RangeManipulate) String() string

type ScalarCalculate added in v0.7.0 

type ScalarCalculate struct {

	// Start timestamp in millisecond
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// End timestamp in millisecond
	End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// Interval in millisecond
	Interval int64 `protobuf:"varint,3,opt,name=interval,proto3" json:"interval,omitempty"`
	// Column name of time index column
	TimeIndex string `protobuf:"bytes,5,opt,name=time_index,json=timeIndex,proto3" json:"time_index,omitempty"`
	// Names of tag columns
	TagColumns []string `protobuf:"bytes,6,rep,name=tag_columns,json=tagColumns,proto3" json:"tag_columns,omitempty"`
	// Column name of field column
	FieldColumn string `protobuf:"bytes,7,opt,name=field_column,json=fieldColumn,proto3" json:"field_column,omitempty"`
	// contains filtered or unexported fields
}

func (*ScalarCalculate) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use ScalarCalculate.ProtoReflect.Descriptor instead.

func (*ScalarCalculate) GetEnd added in v0.7.0 

func (x *ScalarCalculate) GetEnd() int64

func (*ScalarCalculate) GetFieldColumn added in v0.7.0 

func (x *ScalarCalculate) GetFieldColumn() string

func (*ScalarCalculate) GetInterval added in v0.7.0 

func (x *ScalarCalculate) GetInterval() int64

func (*ScalarCalculate) GetStart added in v0.7.0 

func (x *ScalarCalculate) GetStart() int64

func (*ScalarCalculate) GetTagColumns added in v0.7.0 

func (x *ScalarCalculate) GetTagColumns() []string

func (*ScalarCalculate) GetTimeIndex added in v0.7.0 

func (x *ScalarCalculate) GetTimeIndex() string

func (*ScalarCalculate) ProtoMessage added in v0.7.0 

func (*ScalarCalculate) ProtoMessage()

func (*ScalarCalculate) ProtoReflect added in v0.7.0 

func (x *ScalarCalculate) ProtoReflect() protoreflect.Message

func (*ScalarCalculate) Reset added in v0.7.0 

func (x *ScalarCalculate) Reset()

func (*ScalarCalculate) String added in v0.7.0 

func (x *ScalarCalculate) String() string

type SeriesDivide 

type SeriesDivide struct {

	// Names of tag columns
	TagColumns []string `protobuf:"bytes,1,rep,name=tag_columns,json=tagColumns,proto3" json:"tag_columns,omitempty"`
	// contains filtered or unexported fields
}

func (*SeriesDivide) Descriptor deprecated 

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

Deprecated: Use SeriesDivide.ProtoReflect.Descriptor instead.

func (*SeriesDivide) GetTagColumns 

func (x *SeriesDivide) GetTagColumns() []string

func (*SeriesDivide) ProtoMessage 

func (*SeriesDivide) ProtoMessage()

func (*SeriesDivide) ProtoReflect 

func (x *SeriesDivide) ProtoReflect() protoreflect.Message

func (*SeriesDivide) Reset 

func (x *SeriesDivide) Reset()

func (*SeriesDivide) String 

func (x *SeriesDivide) String() string

type SeriesNormalize 

type SeriesNormalize struct {

	// Offset in millisecond
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// Column name of time index column
	TimeIndex string `protobuf:"bytes,2,opt,name=time_index,json=timeIndex,proto3" json:"time_index,omitempty"`
	// Whether to filter out NaN value
	FilterNan bool `protobuf:"varint,3,opt,name=filter_nan,json=filterNan,proto3" json:"filter_nan,omitempty"`
	// contains filtered or unexported fields
}

func (*SeriesNormalize) Descriptor deprecated 

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

Deprecated: Use SeriesNormalize.ProtoReflect.Descriptor instead.

func (*SeriesNormalize) GetFilterNan 

func (x *SeriesNormalize) GetFilterNan() bool

func (*SeriesNormalize) GetOffset 

func (x *SeriesNormalize) GetOffset() int64

func (*SeriesNormalize) GetTimeIndex 

func (x *SeriesNormalize) GetTimeIndex() string

func (*SeriesNormalize) ProtoMessage 

func (*SeriesNormalize) ProtoMessage()

func (*SeriesNormalize) ProtoReflect 

func (x *SeriesNormalize) ProtoReflect() protoreflect.Message

func (*SeriesNormalize) Reset 

func (x *SeriesNormalize) Reset()

func (*SeriesNormalize) String 

func (x *SeriesNormalize) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.