package bigtable

import "github.com/influxdata/flux/stdlib/experimental/bigtable"

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

Source Files ¶

bigtable_rewrite.go from.go rowreader.go