Documentation
¶
Index ¶
- type Database
- type Table
- func (t *Table) Delete(ctx *sql.Context, row sql.Row) error
- func (t *Table) Filters() []sql.Expression
- func (t *Table) HandledFilters(filters []sql.Expression) []sql.Expression
- func (t *Table) IndexKeyValues(ctx *sql.Context, colNames []string) (sql.PartitionIndexKeyValueIter, error)
- func (t *Table) IndexLookup() sql.IndexLookup
- func (t *Table) Insert(ctx *sql.Context, row sql.Row) error
- func (t *Table) Name() string
- func (t *Table) PartitionCount(ctx *sql.Context) (int64, error)
- func (t *Table) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)
- func (t *Table) Partitions(ctx *sql.Context) (sql.PartitionIter, error)
- func (t *Table) Projection() []string
- func (t *Table) Schema() sql.Schema
- func (t *Table) String() string
- func (t *Table) WithFilters(filters []sql.Expression) sql.Table
- func (t *Table) WithIndexLookup(lookup sql.IndexLookup) sql.Table
- func (t *Table) WithProjection(colNames []string) sql.Table
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Database ¶
type Database struct {
// contains filtered or unexported fields
}
Database is an in-memory database.
func NewDatabase ¶
NewDatabase creates a new database with the given name.
type Table ¶
type Table struct {
// contains filtered or unexported fields
}
Table represents an in-memory database table.
func NewPartitionedTable ¶
NewPartitionedTable creates a new Table with the given name, schema and number of partitions.
func (*Table) Filters ¶
func (t *Table) Filters() []sql.Expression
Filters implements the sql.FilteredTable interface.
func (*Table) HandledFilters ¶
func (t *Table) HandledFilters(filters []sql.Expression) []sql.Expression
HandledFilters implements the sql.FilteredTable interface.
func (*Table) IndexKeyValues ¶
func (t *Table) IndexKeyValues( ctx *sql.Context, colNames []string, ) (sql.PartitionIndexKeyValueIter, error)
IndexKeyValues implements the sql.IndexableTable interface.
func (*Table) IndexLookup ¶
func (t *Table) IndexLookup() sql.IndexLookup
IndexLookup implements the sql.IndexableTable interface.
func (*Table) PartitionCount ¶
PartitionCount implements the sql.PartitionCounter interface.
func (*Table) PartitionRows ¶
PartitionRows implements the sql.PartitionRows interface.
func (*Table) Partitions ¶
Partitions implements the sql.Table interface.
func (*Table) Projection ¶
Projection implements the sql.ProjectedTable interface.
func (*Table) WithFilters ¶
func (t *Table) WithFilters(filters []sql.Expression) sql.Table
WithFilters implements the sql.FilteredTable interface.
func (*Table) WithIndexLookup ¶
func (t *Table) WithIndexLookup(lookup sql.IndexLookup) sql.Table
WithIndexLookup implements the sql.IndexableTable interface.
Source Files