Documentation
¶
Index ¶
- type Sample
- func GenerateFromPipelineOperator(opr *pipeline.Instruction) *Sample
- func NewArgument() *Sample
- func NewMergeSample(rowSampleArg *Sample, outputRowCount bool) *Sample
- func NewSampleByPercent(percent float64, sampleExprs, groupExprs []*plan.Expr) *Sample
- func NewSampleByRows(rows int, sampleExprs, groupExprs []*plan.Expr, usingRow bool, ...) *Sample
- func (sample *Sample) Call(proc *process.Process) (vm.CallResult, error)
- func (sample *Sample) ConvertToPipelineOperator(in *pipeline.Instruction)
- func (sample *Sample) ExecProjection(proc *process.Process, input *batch.Batch) (*batch.Batch, error)
- func (sample *Sample) Free(proc *process.Process, pipelineFailed bool, err error)
- func (sample *Sample) GetOperatorBase() *vm.OperatorBase
- func (sample *Sample) IsByPercent() bool
- func (sample *Sample) IsMergeSampleByRow() bool
- func (sample *Sample) OpType() vm.OpType
- func (sample *Sample) Prepare(proc *process.Process) (err error)
- func (sample *Sample) Release()
- func (sample *Sample) Reset(proc *process.Process, pipelineFailed bool, err error)
- func (sample *Sample) SampleDup() *Sample
- func (sample *Sample) String(buf *bytes.Buffer)
- func (sample Sample) TypeName() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Sample ¶
type Sample 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
vm.OperatorBase
// contains filtered or unexported fields
}
func GenerateFromPipelineOperator ¶
func GenerateFromPipelineOperator(opr *pipeline.Instruction) *Sample
func NewArgument ¶ added in v1.2.0
func NewArgument() *Sample
func NewMergeSample ¶
func NewSampleByPercent ¶
func NewSampleByRows ¶
func (*Sample) ConvertToPipelineOperator ¶
func (sample *Sample) ConvertToPipelineOperator(in *pipeline.Instruction)
func (*Sample) ExecProjection ¶
func (*Sample) GetOperatorBase ¶
func (sample *Sample) GetOperatorBase() *vm.OperatorBase
func (*Sample) IsByPercent ¶
func (*Sample) IsMergeSampleByRow ¶
Click to show internal directories.
Click to hide internal directories.