hybridqp

type Catalog interface {
	GetColumnNames() []string
	GetQueryFields() influxql.Fields
	CloneField(f *influxql.Field) *influxql.Field
	HasCall() bool
	HasRowCount() bool
	HasMath() bool
	HasString() bool
	HasNonPreCall() bool
	CountField() map[int]bool
	HasMeanCall() bool
	HasBlankRowCall() bool
	HasInterval() bool
	HasFieldCondition() bool
	HasAuxTag() bool
	HasPercentileOGSketch() bool
	Options() Options
	Symbols() map[string]influxql.VarRef
	Mapping() map[influxql.Expr]influxql.VarRef
	Refs() map[string]*influxql.VarRef
	DerivedOrigCall(call *influxql.Call) influxql.VarRef
	DerivedRef(ref *influxql.VarRef) influxql.VarRef
	MakeRefs() []influxql.VarRef
	OrigCalls() map[string]*influxql.Call
	SetOpt(opt Options)
	Calls() map[string]*influxql.Call
	SlidingWindow() map[string]*influxql.Call
	HoltWinters() []*influxql.Field
	CompositeCall() map[string]*OGSketchCompositeOperator
	Binarys() map[string]*influxql.BinaryExpr
	Fields() influxql.Fields
	FieldsRef() influxql.VarRefs
	CountDistinct() *influxql.Call
	OnlyOneCallRef() *influxql.VarRef
	LimitType() LimitType
	HasLimit() bool
	HasCastorCall() bool
	LimitAndOffset() (int, int)
	MatchPreAgg() bool
	HasInSeriesAgg() bool
	CanSeqAggPushDown() bool
	CanCallsPushdown() bool
	CanAggPushDown() bool
	ContainSeriesIgnoreCall() bool
	IsRefInQueryFields(ref *influxql.VarRef) bool
	IsRefInSymbolFields(ref *influxql.VarRef) bool
	IsTimeZero() bool
	HasStreamCall() bool
	HasSlidingWindowCall() bool
	HasHoltWintersCall() bool
	IsMultiMeasurements() bool
	HasGroupBy() bool
	Sources() influxql.Sources
	HasSubQuery() bool
	HasOptimizeAgg() bool
	HasOptimizeCall() bool
	GetSourcesNames() []string
	GetFieldType(i int) (int64, error)
	GetJoinCaseCount() int
	GetJoinCases() []*influxql.Join
	IsHoltWinters(val string) bool
	GetSortFields() influxql.SortFields
	SetUnnests(unnests []*influxql.Unnest)
	GetUnnests() influxql.Unnests
	HasUnnests() bool
	GetTimeRangeByTC() util.TimeRange
}

type CatalogCreator interface {
	Create(fields influxql.Fields, columnNames []string, opt Options) Catalog
}

type CatalogCreatorFactory struct {
	// contains filtered or unexported fields
}

type Executor interface {
}

type ExecutorBuilderCreator func() PipelineExecutorBuilder

type ExecutorBuilderOptimizer func() Planner

type ExprOptions struct {
	Expr influxql.Expr
	Ref  influxql.VarRef
}

type FlattenQueryNodeVisitor struct {
	// contains filtered or unexported fields
}

type HintType int64

type IShardsFragments interface{}

type Interval struct {
	Duration time.Duration
	Offset   time.Duration
}

type LimitType int

type LogicalPlanCost struct {
	// The total number of shards that are touched by this Logical.
	NumShards int64

	// The total number of non-unique series that are accessed by this Logical.
	// This number matches the number of cursors created by the Logical since
	// one cursor is created for every series.
	NumSeries int64

	// CachedValues returns the number of cached values that may be read by this
	// Logical.
	CachedValues int64

	// The total number of non-unique files that may be accessed by this Logical.
	// This will count the number of files accessed by each series so files
	// will likely be double counted.
	NumFiles int64

	// The number of blocks that had the potential to be accessed.
	BlocksRead int64

	// The amount of data that can be potentially read.
	BlockSize int64
}

type MapConvert struct {
}

type OGSketchCompositeOperator struct {
	// contains filtered or unexported fields
}

type Options interface {
	GetLimit() int
	GetOffset() int
	HasInterval() bool
	GetCondition() influxql.Expr
	GetLocation() *time.Location
	GetOptDimension() []string
	GetHintType() HintType
	ISChunked() bool
	SetHintType(HintType)
	OptionsName() string
	IsAscending() bool
	SetAscending(bool)
	ChunkSizeNum() int
	GetStartTime() int64
	GetEndTime() int64
	GetMaxParallel() int
	Window(t int64) (start, end int64)
	GetGroupBy() map[string]struct{}
	GetInterval() time.Duration
	IsGroupByAllDims() bool
	GetSourcesNames() []string
	GetMeasurements() []*influxql.Measurement
	HaveOnlyCSStore() bool
	GetDimensions() []string
	SetFill(influxql.FillOption)
	IsTimeSorted() bool
	IsUnifyPlan() bool
	SetSortFields(influxql.SortFields)
	GetSortFields() influxql.SortFields
	FieldWildcard() bool
	GetStmtId() int
	GetLogQueryCurrId() string
	GetIterId() int32
	IsIncQuery() bool
}

type PipelineExecutorBuilder interface {
	Analyze(span *tracing.Span)

	Build(node QueryNode) (Executor, error)
}

type Planner interface {
	SetRoot(QueryNode)
	FindBestExp() QueryNode
}

type QueryNode interface {
	ID() uint64
	Digest() string
	Children() []QueryNode
	String() string
	Type() string
	ReplaceChild(int, QueryNode)
	ReplaceChildren([]QueryNode)
	Clone() QueryNode
	RowDataType() RowDataType
	RowExprOptions() []ExprOptions
	Dummy() bool
	DeriveOperations()
	Schema() Catalog
	Trait() Trait
	ApplyTrait(Trait)

	SetInputs([]QueryNode)
	SetSchema(Catalog)
	New(inputs []QueryNode, schema Catalog, eTrait []Trait) QueryNode
}

type QueryNodeVisitor interface {
	Visit(QueryNode) QueryNodeVisitor
}

type RowDataType interface {
	Aux() []int
	Equal(RowDataType) bool
	Fields() influxql.Fields
	MakeRefs() []influxql.VarRef
	Field(int) *influxql.Field
	FieldIndex(string) int
	NumColumn() int
	SlimFields(ridIdx []int) RowDataType
	CopyTo(dst *RowDataTypeImpl)

	IndexByName() map[string]int
	UpdateByDownSampleFields(map[string]string)
	SetDataType(i int, t influxql.DataType)
}

type RowDataTypeImpl struct {
	// contains filtered or unexported fields
}

type SelectDuration struct {
	TotalDuration    int64
	PrepareDuration  int64
	IteratorDuration int64
	LocalDuration    ShardSelectDuration
	RemoteDuration   ShardSelectDuration
	EmitDuration     int64
	Query            string
	DB               string
	QueryBatch       int
}

type ShardSelectDuration struct {
	IteratorDuration int64
	TagSetDuration   int64
	LocationDuration int64
}

type StoreEngine interface {
	ReportLoad()
	CreateLogicPlan(ctx context.Context, db string, ptId uint32, shardID uint64, sources influxql.Sources, schema Catalog) (QueryNode, error)
	ScanWithSparseIndex(ctx context.Context, db string, ptId uint32, shardIDS []uint64, schema Catalog) (IShardsFragments, error)
	GetIndexInfo(db string, ptId uint32, shardID uint64, schema Catalog) (interface{}, error)
	RowCount(db string, ptId uint32, shardIDS []uint64, schema Catalog) (int64, error)
	UnrefEngineDbPt(db string, ptId uint32)
	GetShardDownSampleLevel(db string, ptId uint32, shardID uint64) int
}

type Trait interface{}