spill

Mar 26, 2022

Changes in this version

+ const TempPrefix

+ func TempDir() (string, error)

+ func TempFile() (*os.File, error)

+ type File struct

+ func NewFile(f *os.File) *File

+ func NewFileWithPath(path string, zctx *zed.Context) (*File, error)

+ func NewTempFile() (*File, error)

+ func (f *File) Rewind(zctx *zed.Context) error

+ func (f *File) Size() (int64, error)

+ func (r *File) CloseAndRemove() error

+ type MergeSort struct

+ func NewMergeSort(comparator *expr.Comparator) (*MergeSort, error)

+ func (r *MergeSort) Cleanup()

+ func (r *MergeSort) Len() int

+ func (r *MergeSort) Less(i, j int) bool

+ func (r *MergeSort) Peek() (*zed.Value, error)

+ func (r *MergeSort) Pop() interface{}

+ func (r *MergeSort) Push(x interface{})

+ func (r *MergeSort) Read() (*zed.Value, error)

+ func (r *MergeSort) Spill(ctx context.Context, vals []zed.Value) error

+ func (r *MergeSort) SpillSize() int64

+ func (r *MergeSort) Swap(i, j int)