operator

Documentation

Index

• type Operator
  • func NewDataFamilyRead(executeCtx *flow.ShardExecuteContext, family tsdb.DataFamily) Operator
  • func NewDataLoad(executeCtx *flow.DataLoadContext, segmentRS *flow.TimeSegmentResultSet, ...) Operator
  • func NewFieldSuggest(ctx *context.LeafMetadataContext) Operator
  • func NewGroupingContextBuild(executeCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator
  • func NewGroupingTagsLookup(executeCtx *flow.DataLoadContext) Operator
  • func NewLeafReduce(leafExecuteCtx *context.LeafExecuteContext, executeCtx *flow.DataLoadContext) Operator
  • func NewMetadataLookup(executeCtx *flow.StorageExecuteContext, database tsdb.Database) Operator
  • func NewMetricAllSeries(executeCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator
  • func NewMetricSuggest(ctx *context.LeafMetadataContext) Operator
  • func NewNamespaceSuggest(ctx *context.LeafMetadataContext) Operator
  • func NewPhysicalPlan(ctx context.TaskContext) Operator
  • func NewSeriesFiltering(executeCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator
  • func NewSeriesLimit(executeCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator
  • func NewTagKeyIDLookup(ctx *context.LeafMetadataContext) Operator
  • func NewTagKeySuggest(ctx *context.LeafMetadataContext) Operator
  • func NewTagValueCollect(executeCtx *context.LeafMetadataContext, ...) Operator
  • func NewTagValueSuggest(ctx *context.LeafMetadataContext) Operator
  • func NewTagValuesLookup(executeCtx *flow.StorageExecuteContext, database tsdb.Database) Operator
  • func NewTaskSender(taskCtx context.TaskContext, target string, req *protoCommonV1.TaskRequest) Operator
• type TrackableOperator

Types

type Operator

type Operator interface {
	// Identifier returns identifier value of the operator.
	Identifier() string
	// Execute executes current query operator, return error if failure.
	Execute() error
}

Operator represents the query operator.

func NewDataFamilyRead

func NewDataFamilyRead(executeCtx *flow.ShardExecuteContext, family tsdb.DataFamily) Operator

NewDataFamilyRead creates a dataFamilyRead instance.

func NewDataLoad

func NewDataLoad(executeCtx *flow.DataLoadContext,
	segmentRS *flow.TimeSegmentResultSet, rs flow.FilterResultSet,
) Operator

NewDataLoad creates a dataLoad instance.

func NewFieldSuggest

func NewFieldSuggest(ctx *context.LeafMetadataContext) Operator

NewFieldSuggest creates a fieldSuggest operator.

func NewGroupingContextBuild

func NewGroupingContextBuild(executeCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator

NewGroupingContextBuild creates a groupingContextBuild instance.

func NewGroupingTagsLookup

func NewGroupingTagsLookup(executeCtx *flow.DataLoadContext) Operator

NewGroupingTagsLookup creates a groupingTagsLookup instance.

func NewLeafReduce

func NewLeafReduce(leafExecuteCtx *context.LeafExecuteContext, executeCtx *flow.DataLoadContext) Operator

NewLeafReduce creates a leafReduce instance.

func NewMetadataLookup

func NewMetadataLookup(executeCtx *flow.StorageExecuteContext, database tsdb.Database) Operator

NewMetadataLookup creates a metadataLookup instance.

func NewMetricAllSeries

func NewMetricAllSeries(executeCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator

NewMetricAllSeries creates a metricAllSeries instance.

func NewMetricSuggest

func NewMetricSuggest(ctx *context.LeafMetadataContext) Operator

NewMetricSuggest creates a metricSuggest instance.

func NewNamespaceSuggest

func NewNamespaceSuggest(ctx *context.LeafMetadataContext) Operator

NewNamespaceSuggest creates a namespaceSuggest instance.

func NewPhysicalPlan

func NewPhysicalPlan(ctx context.TaskContext) Operator

NewPhysicalPlan creates a physicalPlan instance.

func NewSeriesFiltering

func NewSeriesFiltering(executeCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator

NewSeriesFiltering creates a seriesFiltering instance.

func NewSeriesLimit

func NewSeriesLimit(executeCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator

NewSeriesLimit creates a seriesLimit instance.

func NewTagKeyIDLookup

func NewTagKeyIDLookup(ctx *context.LeafMetadataContext) Operator

NewTagKeyIDLookup create a tagKeyIDLookup instance.

func NewTagKeySuggest

func NewTagKeySuggest(ctx *context.LeafMetadataContext) Operator

NewTagKeySuggest create a tagKeySuggest instance.

func NewTagValueCollect

func NewTagValueCollect(executeCtx *context.LeafMetadataContext, shardExecuteCtx *flow.ShardExecuteContext, shard tsdb.Shard) Operator

NewTagValueCollect create a tagValueCollect instance.

func NewTagValueSuggest

func NewTagValueSuggest(ctx *context.LeafMetadataContext) Operator

NewTagValueSuggest creates a tagValueSuggest instance.

func NewTagValuesLookup

func NewTagValuesLookup(executeCtx *flow.StorageExecuteContext, database tsdb.Database) Operator

NewTagValuesLookup creates a tagValuesLookup instance.

func NewTaskSender

func NewTaskSender(taskCtx context.TaskContext, target string, req *protoCommonV1.TaskRequest) Operator

NewTaskSender creates a taskSender instance.

type TrackableOperator

type TrackableOperator interface {
	// Stats returns the stats of operator.
	Stats() interface{}
}

TrackableOperator represents operator can be tracked.