bigtable

Documentation

Index

• Constants
• func AddFilterToNode(queryNode plan.Node, filterNode plan.Node) (plan.Node, bool)
• func AddLimitToNode(queryNode plan.Node, limitNode plan.Node) (plan.Node, bool)
• func NewBigtableRowReader(ctx context.Context, c *BigtableDecoder) (execute.RowReader, error)
• type BigtableDecoder
  • func NewBigtableDecoder(reader *execute.RowReader, administration execute.Administration) *BigtableDecoder
  • func (c *BigtableDecoder) Close() error
  • func (c *BigtableDecoder) Connect(ctx context.Context) error
  • func (c *BigtableDecoder) Decode(ctx context.Context) (flux.Table, error)
  • func (c *BigtableDecoder) Fetch(ctx context.Context) (bool, error)
• type BigtableFilterRewriteRule
  • func (r BigtableFilterRewriteRule) Name() string
  • func (r BigtableFilterRewriteRule) Pattern() plan.Pattern
  • func (r BigtableFilterRewriteRule) Rewrite(ctx context.Context, filter plan.Node) (plan.Node, bool, error)
• type BigtableLimitRewriteRule
  • func (r BigtableLimitRewriteRule) Name() string
  • func (r BigtableLimitRewriteRule) Pattern() plan.Pattern
  • func (r BigtableLimitRewriteRule) Rewrite(ctx context.Context, limit plan.Node) (plan.Node, bool, error)
• type BigtableRowReader
  • func (m *BigtableRowReader) Close() error
  • func (m *BigtableRowReader) ColumnNames() []string
  • func (m *BigtableRowReader) ColumnTypes() []flux.ColType
  • func (m *BigtableRowReader) GetNextRow() ([]values.Value, error)
  • func (m *BigtableRowReader) Next() bool
  • func (m *BigtableRowReader) SetColumns([]interface{})
• type FamilyRow
• type FromBigtableOpSpec
  • func (s *FromBigtableOpSpec) Kind() flux.OperationKind
• type FromBigtableProcedureSpec
  • func (s *FromBigtableProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *FromBigtableProcedureSpec) Kind() plan.ProcedureKind

Constants

const FromBigtableKind = "fromBigtable"

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

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 (r BigtableFilterRewriteRule) Name() string

func (BigtableFilterRewriteRule) Pattern

func (r BigtableFilterRewriteRule) Pattern() plan.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 (r BigtableLimitRewriteRule) Name() string

func (BigtableLimitRewriteRule) Pattern

func (r BigtableLimitRewriteRule) Pattern() plan.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

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

func (s *FromBigtableOpSpec) Kind() flux.OperationKind

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 (s *FromBigtableProcedureSpec) Copy() plan.ProcedureSpec

func (*FromBigtableProcedureSpec) Kind

func (s *FromBigtableProcedureSpec) Kind() plan.ProcedureKind