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
- type 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
- 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))
Constants ¶
This section is empty.
Variables ¶
View Source
var UnlimitedAllocator = &execute.Allocator{ Limit: math.MaxInt64, }
Functions ¶
func AggFuncBenchmarkHelper ¶
AggFuncBenchmarkHelper benchmarks the aggregate function over data and compares to wantValue
func AggFuncTestHelper ¶
AggFuncTestHelper splits the data in half, runs Do over each split and compares the Value to want.
func ProcessTestHelper ¶
func RandomDatasetID ¶
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 ConvertBlock ¶
func (*Block) Times ¶
func (b *Block) Times() execute.ValueIterator
type Dataset ¶
type Dataset struct { ID execute.DatasetID Retractions []execute.BlockKey ProcessingTimeUpdates []execute.Time WatermarkUpdates []execute.Time Finished bool FinishedErr error }
func NewDataset ¶
func (*Dataset) AddTransformation ¶
func (d *Dataset) AddTransformation(t execute.Transformation)
func (*Dataset) SetTriggerSpec ¶
func (d *Dataset) SetTriggerSpec(t query.TriggerSpec)
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) Swap ¶
func (b SortedBlocks) Swap(i int, j int)
type ValueIterator ¶
type ValueIterator struct {
// contains filtered or unexported fields
}
func (*ValueIterator) Cols ¶
func (v *ValueIterator) Cols() []execute.ColMeta
func (*ValueIterator) DoFloat ¶
func (v *ValueIterator) DoFloat(f func([]float64, execute.RowReader))
func (*ValueIterator) DoString ¶
func (v *ValueIterator) DoString(f func([]string, execute.RowReader))
Click to show internal directories.
Click to hide internal directories.