Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var EOB = errors.New("EOB")
Functions ¶
This section is empty.
Types ¶
type CloseableIterator ¶
type CloseableIterator interface {
Next() bool
Value() ColumnarBatch
Close()
}
type ColumnarBatch ¶
type VolcanoEngine ¶
type VolcanoEngine struct {
}
func (*VolcanoEngine) Process ¶
func (engine *VolcanoEngine) Process(operator *VolcanoOperator) (*CloseableIterator, error)
type VolcanoFilter ¶
type VolcanoFilter struct {
// contains filtered or unexported fields
}
func NewVolcanoFilter ¶
func NewVolcanoFilter(child *VolcanoOperator, condition func(ColumnarBatch) ColumnarBatch) *VolcanoFilter
func (*VolcanoFilter) Close ¶
func (filter *VolcanoFilter) Close() error
func (*VolcanoFilter) Next ¶
func (filter *VolcanoFilter) Next() (ColumnarBatch, error)
func (*VolcanoFilter) Open ¶
func (filter *VolcanoFilter) Open() error
type VolcanoOperator ¶
type VolcanoOperator interface {
Open() error
Next() (ColumnarBatch, error)
Close() error
}
type VolcanoScan ¶
type VolcanoScan struct {
// contains filtered or unexported fields
}
func NewVolcanoScan ¶
func NewVolcanoScan(source *CloseableIterator) *VolcanoScan
func (*VolcanoScan) Close ¶
func (scan *VolcanoScan) Close() error
func (*VolcanoScan) Next ¶
func (scan *VolcanoScan) Next() (ColumnarBatch, error)
func (*VolcanoScan) Open ¶
func (scan *VolcanoScan) Open() error
Source Files
Click to show internal directories.
Click to hide internal directories.