flush

Documentation

Index

• type Flusher
  • func ForCompaction(monitor monitor.Monitor, writer Writer, ...) (*Flusher, error)
  • func (s *Flusher) Close() error
  • func (s *Flusher) WriteBlock(blocks []block.Block, schema typeof.Schema) error
  • func (s *Flusher) WriteRow(r block.Row) error
• type Writer

Types

type Flusher

type Flusher struct {
	// contains filtered or unexported fields
}

Flusher represents a flusher/merger.

func ForCompaction

func ForCompaction(monitor monitor.Monitor, writer Writer, fileNameFunc func(map[string]interface{}) (string, error)) (*Flusher, error)

ForCompaction creates a new storage implementation.

func (*Flusher) Close

func (s *Flusher) Close() error

Close is used to gracefully close storage.

func (*Flusher) WriteBlock

func (s *Flusher) WriteBlock(blocks []block.Block, schema typeof.Schema) error

WriteBlock writes a one or multiple blocks to the underlying writer.

func (*Flusher) WriteRow

func (s *Flusher) WriteRow(r block.Row) error

WriteRow writes a single row to the underlying writer (i.e. streamer).

type Writer

type Writer interface {
	Write(key key.Key, blocks []block.Block) error
}

Writer represents a sink for the flusher.