Versions in this module Expand all Collapse all v0 v0.99.3 Jan 3, 2021 v0.99.2 Jan 3, 2021 Changes in this version + func Diff(want, got flux.TableIterator, opts ...DiffOption) string + func FromBuffer(cr flux.ColReader) flux.Table + func Mask(tbl flux.Table, columns []string) flux.Table + func NewDataset(id execute.DatasetID, cache *BuilderCache) execute.Dataset + func Sort(tables flux.TableIterator) (flux.TableIterator, error) + func Stream(key flux.GroupKey, cols []flux.ColMeta, ...) (flux.Table, error) + func StreamWithContext(ctx context.Context, key flux.GroupKey, cols []flux.ColMeta, ...) (flux.Table, error) + func Stringify(t flux.Table) string + func Values(cr flux.ColReader, j int) array.Interface + type ArrowBuilder struct + Allocator memory.Allocator + Builders []array.Builder + Columns []flux.ColMeta + GroupKey flux.GroupKey + func GetArrowBuilder(key flux.GroupKey, cache *BuilderCache) (builder *ArrowBuilder, created bool) + func NewArrowBuilder(key flux.GroupKey, mem memory.Allocator) *ArrowBuilder + func (a *ArrowBuilder) AddCol(c flux.ColMeta) (int, error) + func (a *ArrowBuilder) CheckCol(c flux.ColMeta) (int, error) + func (a *ArrowBuilder) Cols() []flux.ColMeta + func (a *ArrowBuilder) Key() flux.GroupKey + func (a *ArrowBuilder) Release() + func (a *ArrowBuilder) Table() (flux.Table, error) + type BufferedBuilder struct + Allocator memory.Allocator + Buffers []*arrow.TableBuffer + Columns []flux.ColMeta + GroupKey flux.GroupKey + func GetBufferedBuilder(key flux.GroupKey, cache *BuilderCache) (builder *BufferedBuilder, created bool) + func NewBufferedBuilder(key flux.GroupKey, mem memory.Allocator) *BufferedBuilder + func (b *BufferedBuilder) AppendBuffer(cr flux.ColReader) error + func (b *BufferedBuilder) AppendTable(tbl flux.Table) error + func (b *BufferedBuilder) Release() + func (b *BufferedBuilder) Table() (flux.Table, error) + type BufferedTable struct + Buffers []flux.ColReader + Columns []flux.ColMeta + GroupKey flux.GroupKey + func (b *BufferedTable) Cols() []flux.ColMeta + func (b *BufferedTable) Do(f func(flux.ColReader) error) error + func (b *BufferedTable) Done() + func (b *BufferedTable) Empty() bool + func (b *BufferedTable) Key() flux.GroupKey + type Builder interface + Release func() + Table func() (flux.Table, error) + type BuilderCache struct + New func(key flux.GroupKey) Builder + Tables KeyLookup + func (d *BuilderCache) DiscardTable(key flux.GroupKey) + func (d *BuilderCache) ExpireTable(key flux.GroupKey) + func (d *BuilderCache) ForEach(f func(key flux.GroupKey, builder Builder) error) error + func (d *BuilderCache) Get(key flux.GroupKey, b interface{}) bool + func (d *BuilderCache) Table(key flux.GroupKey) (flux.Table, error) + type DiffOption = table.DiffOption + func DiffContext(n int) DiffOption + type Iterator = table.Iterator + type KeyLookup interface + Clear func() + Delete func(key flux.GroupKey) (v interface{}, found bool) + Lookup func(key flux.GroupKey) (interface{}, bool) + LookupOrCreate func(key flux.GroupKey, fn func() interface{}) interface{} + Range func(f func(key flux.GroupKey, value interface{})) + Set func(key flux.GroupKey, value interface{}) + type SendFunc func(flux.ColReader) + type StreamWriter struct + func (s *StreamWriter) Cols() []flux.ColMeta + func (s *StreamWriter) Key() flux.GroupKey + func (s *StreamWriter) UnsafeWrite(vs []array.Interface) error + func (s *StreamWriter) UnsafeWriteBuffer(cr flux.ColReader) error + func (s *StreamWriter) Write(vs []array.Interface) error
Go to main page