nodes

Documentation

Index

• type Membership
• type Table
  • func New(cluster Membership) *Table
  • func (t *Table) Close() error
  • func (t *Table) GetRows(splitID []byte, columns []string, maxBytes int64) (*table.PageResult, error)
  • func (t *Table) GetSplits(desiredColumns []string, outputConstraint *presto.PrestoThriftTupleDomain, ...) ([]table.Split, error)
  • func (t *Table) Name() string
  • func (t *Table) Schema() (typeof.Schema, error)

Types

type Membership

type Membership interface {
	Members() []string
	Addr() string
}

Membership represents a contract required for recovering cluster information.

type Table

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

Table represents a nodes table.

func New

func New(cluster Membership) *Table

New creates a new table implementation.

func (*Table) Close

func (t *Table) Close() error

Close implements io.Closer interface.

func (*Table) GetRows

func (t *Table) GetRows(splitID []byte, columns []string, maxBytes int64) (*table.PageResult, 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) Name

func (t *Table) Name() string

Name returns the name of the table.

func (*Table) Schema

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

Schema retrieves the metadata for the table