Documentation
¶
Index ¶
- type Connector
- func (connector *Connector) Call(proc *process.Process) (vm.CallResult, error)
- func (connector *Connector) CleanupDeferredSpool()
- func (connector *Connector) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
- func (connector *Connector) Free(proc *process.Process, pipelineFailed bool, err error)
- func (connector *Connector) GetOperatorBase() *vm.OperatorBase
- func (connector *Connector) OpType() vm.OpType
- func (connector *Connector) Prepare(proc *process.Process) error
- func (connector *Connector) Release()
- func (connector *Connector) Reset(proc *process.Process, pipelineFailed bool, err error)
- func (connector *Connector) String(buf *bytes.Buffer)
- func (connector Connector) TypeName() string
- func (connector *Connector) WithReg(reg *process.WaitRegister) *Connector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connector ¶
type Connector struct {
Reg *process.WaitRegister
vm.OperatorBase
// contains filtered or unexported fields
}
Connector pipe connector
func NewArgument ¶ added in v1.2.0
func NewArgument() *Connector
func (*Connector) CleanupDeferredSpool ¶
func (connector *Connector) CleanupDeferredSpool()
CleanupDeferredSpool reclaims spool cache memory after the paired Merge cleanup has returned on a normal End path. The normal path drains queued GetFromSpool signals; a cleanup-time timeout releases the current reference and leaves no receiver goroutine that can read pending signals later.
func (*Connector) ExecProjection ¶
func (*Connector) GetOperatorBase ¶
func (connector *Connector) GetOperatorBase() *vm.OperatorBase
Source Files
Click to show internal directories.
Click to hide internal directories.