planner

Documentation

Overview

Package planner provides functionality for planning the execution of queries.

Index

• func Plan(sqlString string, opts *Opts) (core.FlatRowSource, error)
• type Opts
• type QueryClusterFN
• type Table

Functions

func Plan

func Plan(sqlString string, opts *Opts) (core.FlatRowSource, error)

Types

type Opts

type Opts struct {
	GetTable        func(table string, includedFields func(tableFields core.Fields) (core.Fields, error)) (Table, error)
	Now             func(table string) time.Time
	IsSubQuery      bool
	SubQueryResults [][]interface{}
	QueryCluster    QueryClusterFN
}

type QueryClusterFN

type QueryClusterFN func(ctx context.Context, sqlString string, isSubQuery bool, subQueryResults [][]interface{}, unflat bool, onFields core.OnFields, onRow core.OnRow, onFlatRow core.OnFlatRow) (interface{}, error)

type Table

type Table interface {
	core.RowSource
	GetPartitionBy() []string
}