Help us shape the future of Go! Take the 2026 Go Developer Survey

bigtable

package
v0.174.0 Latest Latest
Warning

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

Go to latest
Published: Jul 5, 2022 License: MIT Imports: 14 Imported by: 0

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