index

package

v0.40.4 Latest Latest Go to latest Published: May 19, 2022 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dolthub/dolt

Links

Open Source Insights

Documentation ¶

Index ¶

func AllRange() *noms.ReadRange
func ClosedRange(tpl1, tpl2 types.Tuple) *noms.ReadRange
func CustomRange(tpl1, tpl2 types.Tuple, bt1, bt2 sql.RangeBoundType) *noms.ReadRange
func DoltIndexesFromTable(ctx context.Context, db, tbl string, t *doltdb.Table) (indexes []sql.Index, err error)
func GetField(td val.TupleDesc, i int, tup val.Tuple) (v interface{}, err error)
func GetGetFuncForMapIter(nbf *types.NomsBinFormat, mapItr types.MapIterator) func(ctx context.Context) (types.Tuple, types.Tuple, error)
func GreaterOrEqualRange(tpl types.Tuple) *noms.ReadRange
func GreaterThanRange(tpl types.Tuple) *noms.ReadRange
func LessOrEqualRange(tpl types.Tuple) *noms.ReadRange
func LessThanRange(tpl types.Tuple) *noms.ReadRange
func NewIndexLookupRowIterAdapter(ctx *sql.Context, idx DoltIndex, tableData durable.Index, keyIter nomsKeyIter) (*indexLookupRowIterAdapter, error)
func NewProllyRowIter(ctx context.Context, sch schema.Schema, rows prolly.Map, iter prolly.MapIter, ...) (sql.RowIter, error)
func NewRangePartitionIter(ctx *sql.Context, t *doltdb.Table, lookup sql.IndexLookup) (sql.PartitionIter, error)
func NomsRangesFromIndexLookup(lookup sql.IndexLookup) []*noms.ReadRange
func NotNullRange() *noms.ReadRange
func NullRange() *noms.ReadRange
func OpenRange(tpl1, tpl2 types.Tuple) *noms.ReadRange
func PartitionIndexedTableRows(ctx *sql.Context, idx sql.Index, part sql.Partition, ...) (sql.RowIter, error)
func ProllyRangesFromIndexLookup(lookup sql.IndexLookup) []prolly.Range
func PutField(tb *val.TupleBuilder, i int, v interface{}) error
func ReadRangesEqual(nr1, nr2 *noms.ReadRange) bool
func RowIterForIndexLookup(ctx *sql.Context, t *doltdb.Table, ilu sql.IndexLookup, ...) (sql.RowIter, error)
func RowIterForNomsRanges(ctx *sql.Context, idx DoltIndex, ranges []*noms.ReadRange, columns []string, ...) (sql.RowIter, error)
func RowIterForProllyRange(ctx *sql.Context, idx DoltIndex, ranges prolly.Range, ...) (sql.RowIter2, error)
type CoveringIndexRowIterAdapter
- func NewCoveringIndexRowIterAdapter(ctx *sql.Context, idx DoltIndex, keyIter *noms.NomsRangeReader, ...) *CoveringIndexRowIterAdapter
- func (ci *CoveringIndexRowIterAdapter) Close(*sql.Context) error
- func (ci *CoveringIndexRowIterAdapter) Next(ctx *sql.Context) (sql.Row, error)
type DoltIndex
- func DoltIndexFromLookup(lookup sql.IndexLookup) DoltIndex
- func IndexFromIndexLookup(lookup sql.IndexLookup) DoltIndex
type DoltMapIter
- func NewDoltMapIter(keyValGet KVGetFunc, closeKVGetter func() error, conv *KVToSqlRowConverter) *DoltMapIter
- func (dmi *DoltMapIter) Close(*sql.Context) error
- func (dmi *DoltMapIter) Next(ctx *sql.Context) (sql.Row, error)
type IndexLookupKeyIterator
type KVGetFunc
type KVToSqlRowConverter
- func NewKVToSqlRowConverter(nbf *types.NomsBinFormat, tagToSqlColIdx map[uint64]int, cols []schema.Column, ...) *KVToSqlRowConverter
- func NewKVToSqlRowConverterForCols(nbf *types.NomsBinFormat, sch schema.Schema) *KVToSqlRowConverter
- func (conv *KVToSqlRowConverter) ConvertKVToSqlRow(k, v types.Value) (sql.Row, error)
- func (conv *KVToSqlRowConverter) ConvertKVTuplesToSqlRow(k, v types.Tuple) (sql.Row, error)
type SinglePartition
- func (sp SinglePartition) Key() []byte
type SinglePartitionIter
- func SinglePartitionIterFromNomsMap(rowData durable.Index) SinglePartitionIter
- func (itr SinglePartitionIter) Close(*sql.Context) error
- func (itr SinglePartitionIter) Next(*sql.Context) (sql.Partition, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AllRange ¶

func AllRange() *noms.ReadRange

func ClosedRange ¶

func ClosedRange(tpl1, tpl2 types.Tuple) *noms.ReadRange

func CustomRange ¶

func CustomRange(tpl1, tpl2 types.Tuple, bt1, bt2 sql.RangeBoundType) *noms.ReadRange

func DoltIndexesFromTable ¶

func DoltIndexesFromTable(ctx context.Context, db, tbl string, t *doltdb.Table) (indexes []sql.Index, err error)

func GetField ¶

func GetField(td val.TupleDesc, i int, tup val.Tuple) (v interface{}, err error)

GetField reads the value from the ith field of the Tuple as an interface{}.

func GetGetFuncForMapIter ¶

func GetGetFuncForMapIter(nbf *types.NomsBinFormat, mapItr types.MapIterator) func(ctx context.Context) (types.Tuple, types.Tuple, error)

func GreaterOrEqualRange ¶

func GreaterOrEqualRange(tpl types.Tuple) *noms.ReadRange

func GreaterThanRange ¶

func GreaterThanRange(tpl types.Tuple) *noms.ReadRange

func LessOrEqualRange ¶

func LessOrEqualRange(tpl types.Tuple) *noms.ReadRange

func LessThanRange ¶

func LessThanRange(tpl types.Tuple) *noms.ReadRange

func NewIndexLookupRowIterAdapter ¶

func NewIndexLookupRowIterAdapter(ctx *sql.Context, idx DoltIndex, tableData durable.Index, keyIter nomsKeyIter) (*indexLookupRowIterAdapter, error)

NewIndexLookupRowIterAdapter returns a new indexLookupRowIterAdapter.

func NewProllyRowIter ¶

func NewProllyRowIter(
	ctx context.Context,
	sch schema.Schema,
	rows prolly.Map,
	iter prolly.MapIter,
	projections []string,
) (sql.RowIter, error)

func NewRangePartitionIter ¶

func NewRangePartitionIter(ctx *sql.Context, t *doltdb.Table, lookup sql.IndexLookup) (sql.PartitionIter, error)

func NomsRangesFromIndexLookup ¶

func NomsRangesFromIndexLookup(lookup sql.IndexLookup) []*noms.ReadRange

func NotNullRange ¶

func NotNullRange() *noms.ReadRange

func NullRange ¶

func NullRange() *noms.ReadRange

func OpenRange ¶

func OpenRange(tpl1, tpl2 types.Tuple) *noms.ReadRange

func PartitionIndexedTableRows ¶

func PartitionIndexedTableRows(ctx *sql.Context, idx sql.Index, part sql.Partition, pkSch sql.PrimaryKeySchema, columns []string) (sql.RowIter, error)

func ProllyRangesFromIndexLookup ¶

func ProllyRangesFromIndexLookup(lookup sql.IndexLookup) []prolly.Range

func PutField ¶

func PutField(tb *val.TupleBuilder, i int, v interface{}) error

PutField writes an interface{} to the ith field of the Tuple being built.

func ReadRangesEqual ¶

func ReadRangesEqual(nr1, nr2 *noms.ReadRange) bool

func RowIterForIndexLookup ¶

func RowIterForIndexLookup(ctx *sql.Context, t *doltdb.Table, ilu sql.IndexLookup, pkSch sql.PrimaryKeySchema, columns []string) (sql.RowIter, error)

func RowIterForNomsRanges ¶

func RowIterForNomsRanges(ctx *sql.Context, idx DoltIndex, ranges []*noms.ReadRange, columns []string, primary, secondary durable.Index) (sql.RowIter, error)

func RowIterForProllyRange ¶

func RowIterForProllyRange(ctx *sql.Context, idx DoltIndex, ranges prolly.Range, pkSch sql.PrimaryKeySchema, columns []string, primary, secondary durable.Index) (sql.RowIter2, error)

Types ¶

type CoveringIndexRowIterAdapter ¶

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

func NewCoveringIndexRowIterAdapter ¶

func NewCoveringIndexRowIterAdapter(ctx *sql.Context, idx DoltIndex, keyIter *noms.NomsRangeReader, resultCols []string) *CoveringIndexRowIterAdapter

func (*CoveringIndexRowIterAdapter) Close ¶

func (ci *CoveringIndexRowIterAdapter) Close(*sql.Context) error

func (*CoveringIndexRowIterAdapter) Next ¶

func (ci *CoveringIndexRowIterAdapter) Next(ctx *sql.Context) (sql.Row, error)

Next returns the next row from the iterator.

type DoltIndex ¶

type DoltIndex interface {
	sql.FilteredIndex
	Schema() schema.Schema
	IndexSchema() schema.Schema
	Format() *types.NomsBinFormat
	GetDurableIndexes(*sql.Context, *doltdb.Table) (durable.Index, durable.Index, error)
}

func DoltIndexFromLookup ¶

func DoltIndexFromLookup(lookup sql.IndexLookup) DoltIndex

func IndexFromIndexLookup ¶

func IndexFromIndexLookup(lookup sql.IndexLookup) DoltIndex

type DoltMapIter ¶

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

DoltMapIter uses a types.MapIterator to iterate over a types.Map and returns sql.Row instances that it reads and converts

func (*DoltMapIter) Close ¶

func (dmi *DoltMapIter) Close(*sql.Context) error

func (*DoltMapIter) Next ¶

func (dmi *DoltMapIter) Next(ctx *sql.Context) (sql.Row, error)

Next returns the next sql.Row until all rows are returned at which point (nil, io.EOF) is returned.

type IndexLookupKeyIterator ¶

type IndexLookupKeyIterator interface {
	// NextKey returns the next key if it exists, and io.EOF if it does not.
	NextKey(ctx *sql.Context) (row.TaggedValues, error)
}

type KVGetFunc ¶

type KVGetFunc func(ctx context.Context) (types.Tuple, types.Tuple, error)

KVGetFunc defines a function that returns a Key Value pair

type KVToSqlRowConverter ¶

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

KVToSqlRowConverter takes noms types.Value key value pairs and converts them directly to a sql.Row. It can be configured to only process a portion of the columns and map columns to desired output columns.

func NewKVToSqlRowConverter ¶

func NewKVToSqlRowConverter(nbf *types.NomsBinFormat, tagToSqlColIdx map[uint64]int, cols []schema.Column, rowSize int) *KVToSqlRowConverter

func NewKVToSqlRowConverterForCols ¶

func NewKVToSqlRowConverterForCols(nbf *types.NomsBinFormat, sch schema.Schema) *KVToSqlRowConverter

NewKVToSqlRowConverterForCols returns a KVToSqlConverter instance based on the list of columns passed in

func (*KVToSqlRowConverter) ConvertKVToSqlRow ¶

func (conv *KVToSqlRowConverter) ConvertKVToSqlRow(k, v types.Value) (sql.Row, error)

ConvertKVToSqlRow returns a sql.Row generated from the key and value provided.

func (*KVToSqlRowConverter) ConvertKVTuplesToSqlRow ¶

func (conv *KVToSqlRowConverter) ConvertKVTuplesToSqlRow(k, v types.Tuple) (sql.Row, error)