binlog

Documentation

Index

• func NewL0Reader(ctx context.Context, cm storage.ChunkManager, pkField *schemapb.FieldSchema, ...) (*l0Reader, error)
• func NewReader(ctx context.Context, cm storage.ChunkManager, ...) (*reader, error)
• type Filter
  • func FilterWithDelete(r *reader) (Filter, error)
  • func FilterWithTimeRange(tsStart, tsEnd uint64) Filter
• type L0Reader

Functions

func NewL0Reader

func NewL0Reader(ctx context.Context,
	cm storage.ChunkManager,
	pkField *schemapb.FieldSchema,
	importFile *internalpb.ImportFile,
	bufferSize int,
) (*l0Reader, error)

func NewReader

func NewReader(ctx context.Context,
	cm storage.ChunkManager,
	schema *schemapb.CollectionSchema,
	paths []string,
	tsStart,
	tsEnd uint64,
) (*reader, error)

Types

type Filter

type Filter func(row map[int64]interface{}) bool

func FilterWithDelete

func FilterWithDelete(r *reader) (Filter, error)

func FilterWithTimeRange

func FilterWithTimeRange(tsStart, tsEnd uint64) Filter

type L0Reader

type L0Reader interface {
	Read() (*storage.DeleteData, error)
}