executetest

Documentation

Index

• Variables
• func AggFuncBenchmarkHelper(b *testing.B, agg execute.Aggregate, data []float64, want interface{})
• func AggFuncTestHelper(t *testing.T, agg execute.Aggregate, data []float64, want interface{})
• func IndexSelectorFuncBenchmarkHelper(b *testing.B, selector execute.IndexSelector, data execute.Block)
• func IndexSelectorFuncTestHelper(t *testing.T, selector execute.IndexSelector, data execute.Block, want [][]int)
• func ProcessTestHelper(t *testing.T, data []execute.Block, want []*Block, ...)
• func RandomDatasetID() execute.DatasetID
• func RowSelectorFuncBenchmarkHelper(b *testing.B, selector execute.RowSelector, data execute.Block)
• func RowSelectorFuncTestHelper(t *testing.T, selector execute.RowSelector, data execute.Block, ...)
• func TransformationPassThroughTestHelper(t *testing.T, newTr NewTransformation)
• type Block
  • func BlocksFromCache(c execute.DataCache) []*Block
  • func ConvertBlock(b execute.Block) *Block
  • func (b *Block) Bounds() execute.Bounds
  • func (b *Block) Col(c int) execute.ValueIterator
  • func (b *Block) Cols() []execute.ColMeta
  • func (b *Block) RefCount(n int)
  • func (b *Block) Tags() execute.Tags
  • func (b *Block) Times() execute.ValueIterator
  • func (b *Block) Values() (execute.ValueIterator, error)
• type Dataset
  • func NewDataset(id execute.DatasetID) *Dataset
  • func (d *Dataset) AddTransformation(t execute.Transformation)
  • func (d *Dataset) Finish(err error)
  • func (d *Dataset) RetractBlock(key execute.BlockKey) error
  • func (d *Dataset) SetTriggerSpec(t query.TriggerSpec)
  • func (d *Dataset) UpdateProcessingTime(t execute.Time) error
  • func (d *Dataset) UpdateWatermark(mark execute.Time) error
• type NewTransformation
• type SortedBlocks
  • func (b SortedBlocks) Len() int
  • func (b SortedBlocks) Less(i int, j int) bool
  • func (b SortedBlocks) Swap(i int, j int)
• type ValueIterator
  • func (v *ValueIterator) AtBool(i int, j int) bool
  • func (v *ValueIterator) AtFloat(i int, j int) float64
  • func (v *ValueIterator) AtInt(i int, j int) int64
  • func (v *ValueIterator) AtString(i int, j int) string
  • func (v *ValueIterator) AtTime(i int, j int) execute.Time
  • func (v *ValueIterator) AtUInt(i int, j int) uint64
  • func (v *ValueIterator) Cols() []execute.ColMeta
  • func (v *ValueIterator) DoBool(f func([]bool, execute.RowReader))
  • func (v *ValueIterator) DoFloat(f func([]float64, execute.RowReader))
  • func (v *ValueIterator) DoInt(f func([]int64, execute.RowReader))
  • func (v *ValueIterator) DoString(f func([]string, execute.RowReader))
  • func (v *ValueIterator) DoTime(f func([]execute.Time, execute.RowReader))
  • func (v *ValueIterator) DoUInt(f func([]uint64, execute.RowReader))

Variables

var UnlimitedAllocator = &execute.Allocator{
	Limit: math.MaxInt64,
}

Functions

func AggFuncBenchmarkHelper

func AggFuncBenchmarkHelper(b *testing.B, agg execute.Aggregate, data []float64, want interface{})

AggFuncBenchmarkHelper benchmarks the aggregate function over data and compares to wantValue

func AggFuncTestHelper

func AggFuncTestHelper(t *testing.T, agg execute.Aggregate, data []float64, want interface{})

AggFuncTestHelper splits the data in half, runs Do over each split and compares the Value to want.

func IndexSelectorFuncBenchmarkHelper

func IndexSelectorFuncBenchmarkHelper(b *testing.B, selector execute.IndexSelector, data execute.Block)

func IndexSelectorFuncTestHelper

func IndexSelectorFuncTestHelper(t *testing.T, selector execute.IndexSelector, data execute.Block, want [][]int)

func ProcessTestHelper

func ProcessTestHelper(
	t *testing.T,
	data []execute.Block,
	want []*Block,
	create func(d execute.Dataset, c execute.BlockBuilderCache) execute.Transformation,
)

func RandomDatasetID

func RandomDatasetID() execute.DatasetID

func RowSelectorFuncBenchmarkHelper

func RowSelectorFuncBenchmarkHelper(b *testing.B, selector execute.RowSelector, data execute.Block)

func RowSelectorFuncTestHelper

func RowSelectorFuncTestHelper(t *testing.T, selector execute.RowSelector, data execute.Block, want []execute.Row)

func TransformationPassThroughTestHelper

func TransformationPassThroughTestHelper(t *testing.T, newTr NewTransformation)

Types

type Block

type Block struct {
	Bnds    execute.Bounds
	ColMeta []execute.ColMeta
	// Data is a list of rows, i.e. Data[row][col]
	// Each row must be a list with length equal to len(ColMeta)
	Data [][]interface{}
}

func BlocksFromCache

func BlocksFromCache(c execute.DataCache) []*Block

func ConvertBlock

func ConvertBlock(b execute.Block) *Block

func (*Block) Bounds

func (b *Block) Bounds() execute.Bounds

func (*Block) Col

func (b *Block) Col(c int) execute.ValueIterator

func (*Block) Cols

func (b *Block) Cols() []execute.ColMeta

func (*Block) RefCount

func (b *Block) RefCount(n int)

func (*Block) Tags

func (b *Block) Tags() execute.Tags

func (*Block) Times

func (b *Block) Times() execute.ValueIterator

func (*Block) Values

func (b *Block) Values() (execute.ValueIterator, error)

type Dataset

type Dataset struct {
	ID                    execute.DatasetID
	Retractions           []execute.BlockKey
	ProcessingTimeUpdates []execute.Time
	WatermarkUpdates      []execute.Time
	Finished              bool
	FinishedErr           error
}

func NewDataset

func NewDataset(id execute.DatasetID) *Dataset

func (*Dataset) AddTransformation

func (d *Dataset) AddTransformation(t execute.Transformation)

func (*Dataset) Finish

func (d *Dataset) Finish(err error)

func (*Dataset) RetractBlock

func (d *Dataset) RetractBlock(key execute.BlockKey) error

func (*Dataset) SetTriggerSpec

func (d *Dataset) SetTriggerSpec(t query.TriggerSpec)

func (*Dataset) UpdateProcessingTime

func (d *Dataset) UpdateProcessingTime(t execute.Time) error

func (*Dataset) UpdateWatermark

func (d *Dataset) UpdateWatermark(mark execute.Time) error

type NewTransformation

type NewTransformation func(execute.Dataset, execute.BlockBuilderCache) execute.Transformation

type SortedBlocks

type SortedBlocks []*Block

func (SortedBlocks) Len

func (b SortedBlocks) Len() int

func (SortedBlocks) Less

func (b SortedBlocks) Less(i int, j int) bool

func (SortedBlocks) Swap

func (b SortedBlocks) Swap(i int, j int)

type ValueIterator

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

func (*ValueIterator) AtBool

func (v *ValueIterator) AtBool(i int, j int) bool

func (*ValueIterator) AtFloat

func (v *ValueIterator) AtFloat(i int, j int) float64

func (*ValueIterator) AtInt

func (v *ValueIterator) AtInt(i int, j int) int64

func (*ValueIterator) AtString

func (v *ValueIterator) AtString(i int, j int) string

func (*ValueIterator) AtTime

func (v *ValueIterator) AtTime(i int, j int) execute.Time

func (*ValueIterator) AtUInt

func (v *ValueIterator) AtUInt(i int, j int) uint64

func (*ValueIterator) Cols

func (v *ValueIterator) Cols() []execute.ColMeta

func (*ValueIterator) DoBool

func (v *ValueIterator) DoBool(f func([]bool, execute.RowReader))

func (*ValueIterator) DoFloat

func (v *ValueIterator) DoFloat(f func([]float64, execute.RowReader))

func (*ValueIterator) DoInt

func (v *ValueIterator) DoInt(f func([]int64, execute.RowReader))

func (*ValueIterator) DoString

func (v *ValueIterator) DoString(f func([]string, execute.RowReader))

func (*ValueIterator) DoTime

func (v *ValueIterator) DoTime(f func([]execute.Time, execute.RowReader))

func (*ValueIterator) DoUInt

func (v *ValueIterator) DoUInt(f func([]uint64, execute.RowReader))