Documentation
¶
Index ¶
- type TableScan
- func (tableScan *TableScan) Call(proc *process.Process) (vm.CallResult, error)
- func (tableScan *TableScan) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
- func (tableScan *TableScan) Free(proc *process.Process, pipelineFailed bool, err error)
- func (tableScan *TableScan) GetOperatorBase() *vm.OperatorBase
- func (tableScan *TableScan) OpType() vm.OpType
- func (tableScan *TableScan) Prepare(proc *process.Process) (err error)
- func (tableScan *TableScan) Release()
- func (tableScan *TableScan) Reset(proc *process.Process, pipelineFailed bool, err error)
- func (tableScan *TableScan) String(buf *bytes.Buffer)
- func (tableScan TableScan) TypeName() string
- func (tableScan *TableScan) WithTypes(types []plan.Type) *TableScan
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TableScan ¶
type TableScan struct {
TopValueMsgTag int32
Reader engine.Reader
// letter case: origin
Attrs []string
Types []plan.Type
TableID uint64
FilterExprs []*plan.Expr // static inline filters (from plan.Node.FilterList, set at compile time)
RuntimeFilterExprs []*plan.Expr // runtime inline filters (set by handleRuntimeFilters before Prepare)
vm.OperatorBase
colexec.Projection
// contains filtered or unexported fields
}
func NewArgument ¶ added in v1.2.0
func NewArgument() *TableScan
func (*TableScan) ExecProjection ¶
func (*TableScan) GetOperatorBase ¶
func (tableScan *TableScan) GetOperatorBase() *vm.OperatorBase
Click to show internal directories.
Click to hide internal directories.