table

Documentation

Index

• Variables
• type Appender
• type PageResult
• type Split
• type Table

Variables

var (
	ErrSchemaMismatch = errors.New("mismatch between internal schema and requested columns")
)

Errors commonly occuring in tables

Types

type Appender

type Appender interface {
	Append(block.Block) error
	HashBy() string
}

Appender represents an appender of data to the table.

type PageResult

type PageResult struct {
	Columns   []presto.Column // The list of columns returned
	NextToken []byte          // The next token if the result is incomplete
}

PageResult represents a result

type Split

type Split struct {
	Key   []byte   // The key of the split (SplitID).
	Addrs []string // The list of hosts
}

Split represents a split

type Table

type Table interface {
	io.Closer
	Name() string
	Schema() (typeof.Schema, bool)
	GetSplits(desiredColumns []string, outputConstraint *presto.PrestoThriftTupleDomain, maxSplitCount int) ([]Split, error)
	GetRows(splitID []byte, columns []string, maxBytes int64) (*PageResult, error)
	HashBy() string
	SortBy() string
}

Table represents a table storage contract.