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 NewLimitransform(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 Limitransform
  • func (t *Limitransform) Execute()
  • func (t *Limitransform) 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 NewLimitransform

func NewLimitransform(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
}

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 Limitransform

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

func (*Limitransform) Execute

func (t *Limitransform) Execute()

func (*Limitransform) Stats

func (t *Limitransform) 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
}

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
}

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
}

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))