aoe

Documentation

Index

• Constants
• type Block
• type CatalogInfo
• type ColumnInfo
• type IndexInfo
• type IndexT
• type Property
• type SchemaInfo
• type SchemaState
• type Segment
• type SegmentInfo
• type SparseFilter
• type Store
• type TableInfo
• type TabletInfo

Constants

const (
	SharedShardUnique = "###shared"
)

Types

type Block

type Block interface {
	engine.Statistics

	ID() string
	Prefetch([]string)
	Read([]uint64, []string, []*bytes.Buffer, []*bytes.Buffer) (*batch.Batch, error) // read only arguments
}

type CatalogInfo

type CatalogInfo struct {
	Id   uint64
	Name string
}

type ColumnInfo

type ColumnInfo struct {
	SchemaId    uint64             `json:"schema_id"`
	TableID     uint64             `json:"table_id"`
	Id          uint64             `json:"column_id"`
	Name        string             `json:"name"`
	Type        types.Type         `json:"type"`
	Default     engine.DefaultExpr `json:"default"`
	Alg         int                `json:"alg"`
	Epoch       uint64             `json:"epoch"`
	PrimaryKey  bool               `json:"primary_key"` // PrimaryKey is the name of the column of the primary key
	NullAbility bool               `json:"nullability"`
}

ColumnInfo stores the information of a column.

type IndexInfo

type IndexInfo struct {
	SchemaId uint64   `json:"schema_id"`
	TableId  uint64   `json:"table_id"`
	Columns  []uint64 `json:"columns"`
	// Id          uint64   `json:"id"`
	Name        string   `json:"index_names"`
	ColumnNames []string `json:"column_names"`
	Type        IndexT   `json:"type"`
}

type IndexT

type IndexT uint16

const (
	ZoneMap IndexT = iota
	Bsi
	NumBsi
	FixStrBsi
	Invalid
)

type Property

type Property struct {
	Key   string
	Value string
}

type SchemaInfo

type SchemaInfo struct {
	CatalogId uint64       `json:"catalog_id"`
	Id        uint64       `json:"id"`
	Name      string       `json:"name"`
	Tables    []*TableInfo `json:"tables"` // Tables in the DBName.
	State     SchemaState  `json:"state"`
	Type      int          `json:"type"` // Engine type of schema: RSE、AOE、Spill
	Epoch     uint64       `json:"epoch"`
}

SchemaInfo stores the information of a schema(database).

type SchemaState

type SchemaState byte

const (
	// StateNone means this schema element is absent and can't be used.
	StateNone SchemaState = iota
	// StateDeleteOnly means we can only delete items for this schema element.
	StateDeleteOnly
	// StatePublic means this schema element is ok for all write and read operations.
	StatePublic
)

type Segment

type Segment interface {
	engine.Statistics

	ID() string
	Blocks() []string
	Block(string) Block
	NewSparseFilter() SparseFilter
}

type SegmentInfo

type SegmentInfo struct {
	TableId     uint64 `json:"table_id"`
	Id          uint64 `json:"id"`
	GroupId     uint64 `json:"group_id"`
	TabletId    string `json:"tablet_id"`
	PartitionId string `json:"partition_id"`
	Epoch       uint64 `json:"epoch"`
}

type SparseFilter

type SparseFilter interface {
	Eq(string, interface{}) ([]string, error)
	Ne(string, interface{}) ([]string, error)
	Lt(string, interface{}) ([]string, error)
	Le(string, interface{}) ([]string, error)
	Gt(string, interface{}) ([]string, error)
	Ge(string, interface{}) ([]string, error)
	Btw(string, interface{}, interface{}) ([]string, error)
}

type Store

type Store interface {
	Blocks() []Block
	SparseFilterBlocks() []Block
}

type TableInfo

type TableInfo struct {
	SchemaId   uint64       `json:"schema_id"`
	Id         uint64       `json:"id"`
	Name       string       `json:"name"`
	Type       uint64       `json:"type"` // Type of the table: BASE TABLE for a normal table, VIEW for a view, etc.
	Indices    []IndexInfo  `json:"indices"`
	Columns    []ColumnInfo `json:"columns"` // Column is listed in order in which they appear in schema
	Comment    []byte       `json:"comment"`
	State      SchemaState  `json:"state"`
	Partition  []byte       `json:"partition"`
	Properties []Property
	Epoch      uint64 `json:"epoch"`
}

TableInfo stores the information of a table or view.

type TabletInfo

type TabletInfo struct {
	Name    string
	ShardId uint64
	Table   TableInfo
}