reduce

Documentation

Index

• func ShouldStopWhenDrained(reduceType IReduceType) bool
• func ShouldUseInputLimit(reduceType IReduceType) bool
• type IReduceType
  • func ToReduceType(val int32) IReduceType
• type ResultInfo
  • func NewReduceSearchResultInfo(nq int64, topK int64) *ResultInfo
  • func (r *ResultInfo) GetGroupByFieldId() int64
  • func (r *ResultInfo) GetGroupSize() int64
  • func (r *ResultInfo) GetIsAdvance() bool
  • func (r *ResultInfo) GetMetricType() string
  • func (r *ResultInfo) GetNq() int64
  • func (r *ResultInfo) GetOffset() int64
  • func (r *ResultInfo) GetPkType() schemapb.DataType
  • func (r *ResultInfo) GetTopK() int64
  • func (r *ResultInfo) SetMetricType(metricType string)
  • func (r *ResultInfo) WithAdvance(advance bool) *ResultInfo
  • func (r *ResultInfo) WithGroupByField(groupByField int64) *ResultInfo
  • func (r *ResultInfo) WithGroupSize(groupSize int64) *ResultInfo
  • func (r *ResultInfo) WithMetricType(metricType string) *ResultInfo
  • func (r *ResultInfo) WithOffset(offset int64) *ResultInfo
  • func (r *ResultInfo) WithPkType(pkType schemapb.DataType) *ResultInfo

Functions

func ShouldStopWhenDrained

func ShouldStopWhenDrained(reduceType IReduceType) bool

func ShouldUseInputLimit

func ShouldUseInputLimit(reduceType IReduceType) bool

Types

type IReduceType

type IReduceType int32

const (
	IReduceNoOrder IReduceType = iota
	IReduceInOrder
	IReduceInOrderForBest
)

func ToReduceType

func ToReduceType(val int32) IReduceType

type ResultInfo

type ResultInfo struct {
	// contains filtered or unexported fields
}

func NewReduceSearchResultInfo

func NewReduceSearchResultInfo(
	nq int64,
	topK int64,
) *ResultInfo

func (*ResultInfo) GetGroupByFieldId

func (r *ResultInfo) GetGroupByFieldId() int64

func (*ResultInfo) GetGroupSize

func (r *ResultInfo) GetGroupSize() int64

func (*ResultInfo) GetIsAdvance

func (r *ResultInfo) GetIsAdvance() bool

func (*ResultInfo) GetMetricType

func (r *ResultInfo) GetMetricType() string

func (*ResultInfo) GetNq

func (r *ResultInfo) GetNq() int64

func (*ResultInfo) GetOffset

func (r *ResultInfo) GetOffset() int64

func (*ResultInfo) GetPkType

func (r *ResultInfo) GetPkType() schemapb.DataType

func (*ResultInfo) GetTopK

func (r *ResultInfo) GetTopK() int64

func (*ResultInfo) SetMetricType

func (r *ResultInfo) SetMetricType(metricType string)

func (*ResultInfo) WithAdvance

func (r *ResultInfo) WithAdvance(advance bool) *ResultInfo

func (*ResultInfo) WithGroupByField

func (r *ResultInfo) WithGroupByField(groupByField int64) *ResultInfo

func (*ResultInfo) WithGroupSize

func (r *ResultInfo) WithGroupSize(groupSize int64) *ResultInfo

func (*ResultInfo) WithMetricType

func (r *ResultInfo) WithMetricType(metricType string) *ResultInfo

func (*ResultInfo) WithOffset

func (r *ResultInfo) WithOffset(offset int64) *ResultInfo

func (*ResultInfo) WithPkType

func (r *ResultInfo) WithPkType(pkType schemapb.DataType) *ResultInfo