times

Documentation

Index

• Constants
• Variables
• func Call(proc *process.Process, arg interface{}) (bool, error)
• func Prepare(proc *process.Process, arg interface{}) error
• func String(_ interface{}, buf *bytes.Buffer)
• type Argument
• type Container

Constants

const (
	H0 = iota
	H8
	H24
	H32
	H40
	HStr
)

attributes's size of join result: (not include aggregation)

	H0:  size == 0 bytes
 H8:  0 < size <= 8 bytes
 H24: 8 < size <= 24 bytes
 H32: 24 < size <= 32 bytes
 H40: 32 < size <= 40 bytes
 HStr: size > 40 bytes

const (
	UnitLimit = 256
)

size limit on the number of tuples to be processed at a time

Variables

var OneInt64s []int64

OneInt64s is a slice whose size is equal to UnitLimit and whose value is all 1

Functions

func Call

func Call(proc *process.Process, arg interface{}) (bool, error)

Call is used to do times

func Prepare

func Prepare(proc *process.Process, arg interface{}) error

Prepare the times operator

func String

func String(_ interface{}, buf *bytes.Buffer)

String is used to format times operator

Types

type Argument

type Argument struct {
	// attributes of join result
	Result []string
	// join key of dimension tables
	Vars [][]string

	// tuples of dimension tables
	Bats []*batch.Batch
	// contains filtered or unexported fields
}

Argument is the argument of times operator

type Container

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

Container is used for times operator