Documentation
¶
Index ¶
- type Output
- func (output *Output) Call(proc *process.Process) (vm.CallResult, error)
- func (output *Output) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
- func (output *Output) Free(proc *process.Process, pipelineFailed bool, err error)
- func (output *Output) GetOperatorBase() *vm.OperatorBase
- func (output *Output) OpType() vm.OpType
- func (output *Output) Prepare(_ *process.Process) error
- func (output *Output) Release()
- func (output *Output) Reset(proc *process.Process, pipelineFailed bool, err error)
- func (output *Output) String(buf *bytes.Buffer)
- func (output Output) TypeName() string
- func (output *Output) WithAdaptive(isAdaptive bool) *Output
- func (output *Output) WithBlock(block bool) *Output
- func (output *Output) WithData(data interface{}) *Output
- func (output *Output) WithFunc(Func func(*batch.Batch, *perfcounter.CounterSet) error) *Output
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Output ¶
type Output struct {
Data interface{}
Func func(*batch.Batch, *perfcounter.CounterSet) error
// IsAdaptive enables the adaptive vector search fallback mechanism.
// When set to true and the query completes with zero results (rowCount == 0),
// the Output operator will return ErrVectorNeedRetryWithPreMode error,
// signaling that the query should be retried with 'pre' (pre-filter) mode.
//
// This is part of the vector search adaptive mode optimization (Phase 5),
// which automatically falls back from 'post' mode to 'pre' mode when
// post-filtering returns empty results due to high filter selectivity.
//
// IMPORTANT: We only trigger retry when rowCount == 0 (not when rowCount < limit)
// to avoid merging partial results from the original query with retry results,
// which would cause duplicate rows in the final output.
IsAdaptive bool
vm.OperatorBase
// contains filtered or unexported fields
}
func NewArgument ¶ added in v1.2.0
func NewArgument() *Output
func (*Output) ExecProjection ¶
func (*Output) GetOperatorBase ¶
func (output *Output) GetOperatorBase() *vm.OperatorBase
func (*Output) WithAdaptive ¶
WithAdaptive sets the adaptive vector search fallback mode. When enabled, the Output operator will trigger a retry with pre-filter mode if the query completes with zero results. See IsAdaptive field documentation for details.
func (*Output) WithBlock ¶
WithBlocck set the output is blocked. If true output will block the current pipeline, and cache all input batches. And wait for all the input's batch to be locked before outputting the cached batch to the downstream operator. E.g. select for update, only we get all lock result, then select can be performed, otherwise, if we need retry in RC mode, we may get wrong result.
func (*Output) WithFunc ¶
func (output *Output) WithFunc(Func func(*batch.Batch, *perfcounter.CounterSet) error) *Output
Source Files
Click to show internal directories.
Click to hide internal directories.