Documentation
¶
Index ¶
- type Argument
- func GenerateFromPipelineOperator(opr *pipeline.Instruction) *Argument
- func NewArgument() *Argument
- func NewMergeSample(rowSampleArg *Argument, outputRowCount bool) *Argument
- func NewSampleByPercent(percent float64, sampleExprs, groupExprs []*plan.Expr) *Argument
- func NewSampleByRows(rows int, sampleExprs, groupExprs []*plan.Expr, usingRow bool, ...) *Argument
- 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) GetOperatorBase() *vm.OperatorBase
- func (arg *Argument) IsByPercent() bool
- func (arg *Argument) IsMergeSampleByRow() bool
- func (arg *Argument) Prepare(proc *process.Process) (err error)
- func (arg *Argument) Release()
- func (arg *Argument) SimpleDup() *Argument
- func (arg *Argument) String(buf *bytes.Buffer)
- func (arg Argument) TypeName() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Argument ¶
type Argument struct {
// it determines which sample action (random sample by rows / percents, sample by order and so on) to take.
Type int
// UsingBlock is used to speed up the sample process but will cause centroids skewed.
// If true, the sample action will randomly stop the sample process after it has sampled enough rows.
UsingBlock bool
// NeedOutputRowSeen indicates whether the sample operator needs to output the count of row seen as the last column.
NeedOutputRowSeen bool
Rows int
Percents float64
// sample(expression1, expression2, ..., number)'s expression.
SampleExprs []*plan.Expr
// group by expr1, expr2 ...
GroupExprs []*plan.Expr
IBucket, NBucket int
vm.OperatorBase
// contains filtered or unexported fields
}
func GenerateFromPipelineOperator ¶
func GenerateFromPipelineOperator(opr *pipeline.Instruction) *Argument
func NewArgument ¶ added in v1.2.0
func NewArgument() *Argument
func NewMergeSample ¶
func NewSampleByPercent ¶
func NewSampleByRows ¶
func (*Argument) ConvertToPipelineOperator ¶
func (arg *Argument) ConvertToPipelineOperator(in *pipeline.Instruction)
func (*Argument) GetOperatorBase ¶ added in v1.2.0
func (arg *Argument) GetOperatorBase() *vm.OperatorBase
func (*Argument) IsByPercent ¶
func (*Argument) IsMergeSampleByRow ¶
Click to show internal directories.
Click to hide internal directories.