table

package

v0.4.0 Latest Latest Go to latest Published: May 5, 2022 License: Apache-2.0 Imports: 31 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/matrixorigin/matrixone

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func MockSegments(meta *metadata.Table, tblData iface.ITableData) []uint64
func NewSimpleSegment(typ base.SegmentType, meta *metadata.Segment, ...) *segment
type BacktrackingBlockIterator
- func NewBacktrackingBlockIterator(blocks []iface.IBlock, col uint16) *BacktrackingBlockIterator
type InstallContext
type Tables
- func NewTables(opts *storage.Options, mu *sync.RWMutex, fsMgr base.IManager, ...) *Tables

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNotExist = errors.New("not exist error")
)

Functions ¶

func MockSegments ¶

func MockSegments(meta *metadata.Table, tblData iface.ITableData) []uint64

func NewSimpleSegment ¶

func NewSimpleSegment(typ base.SegmentType, meta *metadata.Segment, indexHolder index.SegmentIndexHolder, segFile base.ISegmentFile) *segment

Types ¶

type BacktrackingBlockIterator ¶

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

func NewBacktrackingBlockIterator ¶

func NewBacktrackingBlockIterator(blocks []iface.IBlock, col uint16) *BacktrackingBlockIterator

func (*BacktrackingBlockIterator) BlockCount ¶

func (iter *BacktrackingBlockIterator) BlockCount() uint32

func (*BacktrackingBlockIterator) Clear ¶

func (iter *BacktrackingBlockIterator) Clear()

func (*BacktrackingBlockIterator) FetchColumn ¶

func (iter *BacktrackingBlockIterator) FetchColumn() ([]*vector.Vector, error)

func (*BacktrackingBlockIterator) Reset ¶

func (iter *BacktrackingBlockIterator) Reset(col uint16)

type InstallContext ¶

type InstallContext interface {
	HasSegementFile(*common.ID) bool
	HasBlockFile(*common.ID) bool
	PresentedBsiFiles(id common.ID) []string
}

type Tables ¶

type Tables struct {
	*sync.RWMutex
	Data map[uint64]iface.ITableData

	Tombstone map[uint64]iface.ITableData

	Opts                             *storage.Options
	FsMgr                            base.IManager
	MTBufMgr, SSTBufMgr, IndexBufMgr bmgrif.IBufferManager

	MutFactory fb.MutFactory
	Aware      shard.NodeAware
	// contains filtered or unexported fields
}

func NewTables ¶

func NewTables(opts *storage.Options, mu *sync.RWMutex, fsMgr base.IManager, mtBufMgr, sstBufMgr, indexBufMgr bmgrif.IBufferManager, aware shard.NodeAware) *Tables

func (*Tables) CommitInstallTables ¶

func (ts *Tables) CommitInstallTables(tables []iface.ITableData) error

func (*Tables) CreateTableNoLock ¶

func (ts *Tables) CreateTableNoLock(tbl iface.ITableData) (err error)

func (*Tables) DropTable ¶

func (ts *Tables) DropTable(tid uint64) (tbl iface.ITableData, err error)

func (*Tables) DropTableNoLock ¶

func (ts *Tables) DropTableNoLock(tid uint64) (tbl iface.ITableData, err error)

func (*Tables) ForTables ¶

func (ts *Tables) ForTables(fn func(iface.ITableData) error) error

func (*Tables) ForTablesLocked ¶

func (ts *Tables) ForTablesLocked(fn func(iface.ITableData) error) error

func (*Tables) GetTableNoLock ¶

func (ts *Tables) GetTableNoLock(tid uint64) (tbl iface.ITableData, err error)

func (*Tables) InstallTable ¶

func (ts *Tables) InstallTable(table iface.ITableData) error

func (*Tables) InstallTableLocked ¶

func (ts *Tables) InstallTableLocked(table iface.ITableData) error

func (*Tables) MakeTableMutationHandle ¶

func (ts *Tables) MakeTableMutationHandle(id uint64) (handle iface.MutationHandle, err error)

func (*Tables) PrepareInstallTable ¶

func (ts *Tables) PrepareInstallTable(meta *metadata.Table, ctx InstallContext) (iface.ITableData, error)

func (*Tables) PrepareInstallTables ¶

func (ts *Tables) PrepareInstallTables(meta map[uint64]*metadata.Table, ctx InstallContext) (tables []iface.ITableData, err error)

func (*Tables) RegisterTable ¶

func (ts *Tables) RegisterTable(meta *metadata.Table) (iface.ITableData, error)

func (*Tables) String ¶

func (ts *Tables) String() string

func (*Tables) StrongRefTable ¶

func (ts *Tables) StrongRefTable(tid uint64) (tbl iface.ITableData, err error)

func (*Tables) TableIds ¶

func (ts *Tables) TableIds() (ids map[uint64]bool)

func (*Tables) WeakRefTable ¶

func (ts *Tables) WeakRefTable(tid uint64) (tbl iface.ITableData, err error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
col
handle
iface
wrapper

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL