transforms

Documentation

Index

• func NewAggregateSelectionTransform(ctx *TransformContext, plan *planners.SelectionPlan) processors.IProcessor
• func NewDataSourceTransform(ctx *TransformContext, input datastreams.IDataBlockInputStream) processors.IProcessor
• func NewFilterTransform(ctx *TransformContext, filter *planners.FilterPlan) processors.IProcessor
• func NewGroupBySelectionTransform(ctx *TransformContext, plan *planners.SelectionPlan) processors.IProcessor
• func NewLimitTransform(ctx *TransformContext, plan *planners.LimitPlan) processors.IProcessor
• func NewNormalSelectionTransform(ctx *TransformContext, plan *planners.SelectionPlan) processors.IProcessor
• func NewOrderByTransform(ctx *TransformContext, plan *planners.OrderByPlan) processors.IProcessor
• func NewProjectionTransform(ctx *TransformContext, plan *planners.ProjectionPlan) processors.IProcessor
• type AggregateSelectionTransform
  • func (t *AggregateSelectionTransform) Execute()
  • func (t *AggregateSelectionTransform) Stats() sessions.ProgressValues
• type DataSourceTransform
  • func (t *DataSourceTransform) Execute()
  • func (t *DataSourceTransform) Stats() sessions.ProgressValues
• type FilterTransform
  • func (t *FilterTransform) Execute()
  • func (t *FilterTransform) Stats() sessions.ProgressValues
• type GroupBySelectionTransform
  • func (t *GroupBySelectionTransform) Execute()
  • func (t *GroupBySelectionTransform) Stats() sessions.ProgressValues
• type LimitTransform
  • func (t *LimitTransform) Execute()
  • func (t *LimitTransform) Stats() sessions.ProgressValues
• type NormalSelectionTransform
  • func (t *NormalSelectionTransform) Execute()
  • func (t *NormalSelectionTransform) Stats() sessions.ProgressValues
• type OrderByTransform
  • func (t *OrderByTransform) Execute()
  • func (t *OrderByTransform) Stats() sessions.ProgressValues
• type ProjectionTransform
  • func (t *ProjectionTransform) Execute()
  • func (t *ProjectionTransform) Stats() sessions.ProgressValues
• type TransformContext
  • func NewTransformContext(ctx context.Context, log *xlog.Log, conf *config.Config) *TransformContext
  • func (ctx *TransformContext) SetProgressCallback(fn func(pv *sessions.ProgressValues))

Functions

func NewAggregateSelectionTransform

func NewAggregateSelectionTransform(ctx *TransformContext, plan *planners.SelectionPlan) processors.IProcessor

func NewDataSourceTransform

func NewDataSourceTransform(ctx *TransformContext, input datastreams.IDataBlockInputStream) processors.IProcessor

func NewFilterTransform

func NewFilterTransform(ctx *TransformContext, filter *planners.FilterPlan) processors.IProcessor

func NewGroupBySelectionTransform

func NewGroupBySelectionTransform(ctx *TransformContext, plan *planners.SelectionPlan) processors.IProcessor

func NewLimitTransform

func NewLimitTransform(ctx *TransformContext, plan *planners.LimitPlan) processors.IProcessor

func NewNormalSelectionTransform

func NewNormalSelectionTransform(ctx *TransformContext, plan *planners.SelectionPlan) processors.IProcessor

func NewOrderByTransform

func NewOrderByTransform(ctx *TransformContext, plan *planners.OrderByPlan) processors.IProcessor

func NewProjectionTransform

func NewProjectionTransform(ctx *TransformContext, plan *planners.ProjectionPlan) processors.IProcessor

Types

type AggregateSelectionTransform

type AggregateSelectionTransform struct {
	processors.BaseProcessor
	// contains filtered or unexported fields
}

func (*AggregateSelectionTransform) Execute

func (t *AggregateSelectionTransform) Execute()

func (*AggregateSelectionTransform) Stats

func (t *AggregateSelectionTransform) Stats() sessions.ProgressValues

type DataSourceTransform

type DataSourceTransform struct {
	processors.BaseProcessor
	// contains filtered or unexported fields
}

DataSourceTransform 转换器可以认为是一种特殊的处理器，用来对数据流做变换的

func (*DataSourceTransform) Execute

func (t *DataSourceTransform) Execute()

func (*DataSourceTransform) Stats

func (t *DataSourceTransform) Stats() sessions.ProgressValues

type FilterTransform

type FilterTransform struct {
	processors.BaseProcessor
	// contains filtered or unexported fields
}

func (*FilterTransform) Execute

func (t *FilterTransform) Execute()

func (*FilterTransform) Stats

func (t *FilterTransform) Stats() sessions.ProgressValues

type GroupBySelectionTransform

type GroupBySelectionTransform struct {
	processors.BaseProcessor
	// contains filtered or unexported fields
}

func (*GroupBySelectionTransform) Execute

func (t *GroupBySelectionTransform) Execute()

func (*GroupBySelectionTransform) Stats

func (t *GroupBySelectionTransform) Stats() sessions.ProgressValues

type LimitTransform

type LimitTransform struct {
	processors.BaseProcessor
	// contains filtered or unexported fields
}

LimitTransform 名字修改为正常的了，不要黑客文化了... 限制返回的结果条数

func (*LimitTransform) Execute

func (t *LimitTransform) Execute()

func (*LimitTransform) Stats

func (t *LimitTransform) Stats() sessions.ProgressValues

type NormalSelectionTransform

type NormalSelectionTransform struct {
	processors.BaseProcessor
	// contains filtered or unexported fields
}

func (*NormalSelectionTransform) Execute

func (t *NormalSelectionTransform) Execute()

func (*NormalSelectionTransform) Stats

func (t *NormalSelectionTransform) Stats() sessions.ProgressValues

type OrderByTransform

type OrderByTransform struct {
	processors.BaseProcessor
	// contains filtered or unexported fields
}

OrderByTransform 排序处理器

func (*OrderByTransform) Execute

func (t *OrderByTransform) Execute()

func (*OrderByTransform) Stats

func (t *OrderByTransform) Stats() sessions.ProgressValues

type ProjectionTransform

type ProjectionTransform struct {
	processors.BaseProcessor
	// contains filtered or unexported fields
}

ProjectionTransform 选择列的处理器，用于收缩结果的规模

func (*ProjectionTransform) Execute

func (t *ProjectionTransform) Execute()

func (*ProjectionTransform) Stats

func (t *ProjectionTransform) Stats() sessions.ProgressValues

type TransformContext

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

TransformContext 转换器的上下文，似乎也没啥需要特别关注的东西...

func NewTransformContext

func NewTransformContext(ctx context.Context, log *xlog.Log, conf *config.Config) *TransformContext

func (*TransformContext) SetProgressCallback

func (ctx *TransformContext) SetProgressCallback(fn func(pv *sessions.ProgressValues))