timeseries

Documentation

Index

• type Membership
• type Table
  • func New(name string, cluster Membership, monitor monitor.Monitor, ...) *Table
  • func (t *Table) Append(block block.Block) error
  • func (t *Table) Close() error
  • func (t *Table) GetRows(splitID []byte, requestedColumns []string, maxBytes int64) (result *table.PageResult, err error)
  • func (t *Table) GetSplits(desiredColumns []string, outputConstraint *presto.PrestoThriftTupleDomain, ...) ([]table.Split, error)
  • func (t *Table) HashBy() string
  • func (t *Table) Name() string
  • func (t *Table) Schema() (typeof.Schema, bool)
  • func (t *Table) SortBy() string
  • func (t *Table) Stream(row block.Row) error

Types

type Membership

type Membership interface {
	Members() []string
}

Membership represents a contract required for recovering cluster information.

type Table

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

Table represents a timeseries table.

func New

func New(name string, cluster Membership, monitor monitor.Monitor, store storage.Storage, cfg *config.Table, stream storage.Streamer) *Table

New creates a new table implementation.

func (*Table) Append

func (t *Table) Append(block block.Block) error

Append appends a block to the store.

func (*Table) Close

func (t *Table) Close() error

Close implements io.Closer interface.

func (*Table) GetRows

func (t *Table) GetRows(splitID []byte, requestedColumns []string, maxBytes int64) (result *table.PageResult, err error)

GetRows retrieves the data

func (*Table) GetSplits

func (t *Table) GetSplits(desiredColumns []string, outputConstraint *presto.PrestoThriftTupleDomain, maxSplitCount int) ([]table.Split, error)

GetSplits retrieves the splits

func (*Table) HashBy

func (t *Table) HashBy() string

HashBy returns the column by which the table should be hashed.

func (*Table) Name

func (t *Table) Name() string

Name returns the name of the table.

func (*Table) Schema

func (t *Table) Schema() (typeof.Schema, bool)

Schema retrieves the metadata for the table

func (*Table) SortBy

func (t *Table) SortBy() string

SortBy returns the column by which the table should be sorted.

func (*Table) Stream

func (t *Table) Stream(row block.Row) error

Stream will stream the row and return errors if any