bigtable

package
v0.170.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 2, 2022 License: MIT Imports: 14 Imported by: 1

Documentation

Index

Constants

View Source
const FromBigtableKind = "fromBigtable"

Variables

This section is empty.

Functions

func AddFilterToNode

func AddFilterToNode(queryNode plan.Node, filterNode plan.Node) (plan.Node, bool)

func AddLimitToNode

func AddLimitToNode(queryNode plan.Node, limitNode plan.Node) (plan.Node, bool)

func NewBigtableRowReader

func NewBigtableRowReader(ctx context.Context, c *BigtableDecoder) (execute.RowReader, error)

Types

type BigtableDecoder

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

func NewBigtableDecoder added in v0.129.0

func NewBigtableDecoder(reader *execute.RowReader, administration execute.Administration) *BigtableDecoder

func (*BigtableDecoder) Close

func (c *BigtableDecoder) Close() error

func (*BigtableDecoder) Connect

func (c *BigtableDecoder) Connect(ctx context.Context) error

func (*BigtableDecoder) Decode

func (c *BigtableDecoder) Decode(ctx context.Context) (flux.Table, error)

func (*BigtableDecoder) Fetch

func (c *BigtableDecoder) Fetch(ctx context.Context) (bool, error)

type BigtableFilterRewriteRule

type BigtableFilterRewriteRule struct{}

func (BigtableFilterRewriteRule) Name

func (BigtableFilterRewriteRule) Pattern

func (BigtableFilterRewriteRule) Rewrite

func (r BigtableFilterRewriteRule) Rewrite(ctx context.Context, filter plan.Node) (plan.Node, bool, error)

type BigtableLimitRewriteRule

type BigtableLimitRewriteRule struct{}

func (BigtableLimitRewriteRule) Name

func (BigtableLimitRewriteRule) Pattern

func (BigtableLimitRewriteRule) Rewrite

func (r BigtableLimitRewriteRule) Rewrite(ctx context.Context, limit plan.Node) (plan.Node, bool, error)

type BigtableRowReader

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

func (*BigtableRowReader) Close added in v0.49.0

func (m *BigtableRowReader) Close() error

func (*BigtableRowReader) ColumnNames

func (m *BigtableRowReader) ColumnNames() []string

func (*BigtableRowReader) ColumnTypes

func (m *BigtableRowReader) ColumnTypes() []flux.ColType

func (*BigtableRowReader) GetNextRow

func (m *BigtableRowReader) GetNextRow() ([]values.Value, error)

func (*BigtableRowReader) Next

func (m *BigtableRowReader) Next() bool

func (*BigtableRowReader) SetColumns

func (m *BigtableRowReader) SetColumns([]interface{})

type FamilyRow

type FamilyRow []bigtable.ReadItem

type FromBigtableOpSpec

type FromBigtableOpSpec struct {
	Token    string `json:"token,omitempty"`
	Project  string `json:"project,omitempty"`
	Instance string `json:"instance,omitempty"`
	Table    string `json:"table,omitempty"`
}

func (*FromBigtableOpSpec) Kind

type FromBigtableProcedureSpec

type FromBigtableProcedureSpec struct {
	plan.DefaultCost
	Token    string
	Project  string
	Instance string
	Table    string

	// Used by BigtableFilterRewriteRule
	RowSet      bigtable.RowSet
	Filter      bigtable.Filter
	ReadOptions []bigtable.ReadOption
}

func (*FromBigtableProcedureSpec) Copy

func (*FromBigtableProcedureSpec) Kind

Jump to

Keyboard shortcuts

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