Versions in this module Expand all Collapse all v1 v1.2.4 Sep 20, 2024 v1.2.3 Sep 10, 2024 v1.2.3-hotfix-20241101 Oct 31, 2024 v1.2.3-hotfix-20241016 Oct 16, 2024 v1.2.3-hotfix-20241010 Oct 11, 2024 v1.2.3-hotfix-20240916 Sep 14, 2024 v1.2.2 Jul 11, 2024 v1.2.2-20240715 Jul 15, 2024 v1.2.1 Jun 28, 2024 v1.2.1-20240709 Jul 9, 2024 v1.2.0 May 17, 2024 Changes in this version type Argument + NeedOutputRowSeen bool + UsingBlock bool + func NewArgument() *Argument + func (arg *Argument) GetOperatorBase() *vm.OperatorBase + func (arg *Argument) Release() + func (arg Argument) TypeName() string v1.1.3 Apr 15, 2024 v1.1.2 Apr 2, 2024 v1.1.1 Feb 2, 2024 v1.1.0 Dec 29, 2023 Changes in this version + type Argument struct + GroupExprs []*plan.Expr + IBucket int + NBucket int + Percents float64 + Rows int + SampleExprs []*plan.Expr + Type int + func GenerateFromPipelineOperator(opr *pipeline.Instruction) *Argument + func NewMergeSample(rowSampleArg *Argument) *Argument + func NewSampleByPercent(percent float64, sampleExprs, groupExprs []*plan.Expr) *Argument + func NewSampleByRows(rows int, sampleExprs, groupExprs []*plan.Expr) *Argument + func (arg *Argument) AppendChild(child vm.Operator) + func (arg *Argument) Call(proc *process.Process) (vm.CallResult, error) + func (arg *Argument) ConvertToPipelineOperator(in *pipeline.Instruction) + func (arg *Argument) Free(proc *process.Process, pipelineFailed bool, err error) + func (arg *Argument) IsByPercent() bool + func (arg *Argument) IsMergeSampleByRow() bool + func (arg *Argument) Prepare(proc *process.Process) (err error) + func (arg *Argument) SetInfo(info *vm.OperatorInfo) + func (arg *Argument) SimpleDup() *Argument + func (arg *Argument) String(buf *bytes.Buffer)