ingest

Documentation

Index

• func IndexTable(db objects.Store, tblSum []byte, tbl *objects.Table) error
• func IngestTable(db objects.Store, f io.ReadCloser, pk []string, sortRunSize uint64, ...) ([]byte, error)
• func IngestTableFromBlocks(db objects.Store, columns []string, pk []uint32, rowsCount uint32, ...) ([]byte, error)
• type ProgressBar

Functions

func IndexTable

func IndexTable(db objects.Store, tblSum []byte, tbl *objects.Table) error

func IngestTable

func IngestTable(db objects.Store, f io.ReadCloser, pk []string, sortRunSize uint64, numWorkers int, sortPT, blkPT ProgressBar) ([]byte, error)

func IngestTableFromBlocks

func IngestTableFromBlocks(db objects.Store, columns []string, pk []uint32, rowsCount uint32, blocks <-chan *sorter.Block, numWorkers int, pt ProgressBar) ([]byte, error)

Types

type ProgressBar

type ProgressBar interface {
	Add(int) error
	Finish() error
}