tableutil

Dec 5, 2019

Changes in this version

+ func Values(cr flux.ColReader, j int) array.Interface

+ 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

Dec 2, 2019

Changes in this version

+ func FromBuffer(cr flux.ColReader) flux.Table

+ func Stream(f func(ctx context.Context, fn SendFunc) error) (flux.Table, error)

+ func StreamWithContext(ctx context.Context, f func(ctx context.Context, fn SendFunc) error) (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 SendFunc func(flux.ColReader)