octosql: github.com/cube2222/octosql/execution/tvf Index | Files | Directories

package tvf

import "github.com/cube2222/octosql/execution/tvf"

Index

Package Files

range.go tumble.go

type Range Uses

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

func NewRange Uses

func NewRange(start, end execution.Expression) *Range

func (*Range) Document Uses

func (r *Range) Document() docs.Documentation

func (*Range) Get Uses

func (r *Range) Get(ctx context.Context, variables octosql.Variables) (execution.RecordStream, error)

type RangeStream Uses

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

func (*RangeStream) Close Uses

func (s *RangeStream) Close() error

func (*RangeStream) Next Uses

func (s *RangeStream) Next(ctx context.Context) (*execution.Record, error)

type Tumble Uses

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

func NewTumble Uses

func NewTumble(source execution.Node, timeField octosql.VariableName, windowLength, offset execution.Expression) *Tumble

func (*Tumble) Document Uses

func (r *Tumble) Document() docs.Documentation

func (*Tumble) Get Uses

func (r *Tumble) Get(ctx context.Context, variables octosql.Variables) (execution.RecordStream, error)

type TumbleStream Uses

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

func (*TumbleStream) Close Uses

func (s *TumbleStream) Close() error

func (*TumbleStream) Next Uses

func (s *TumbleStream) Next(ctx context.Context) (*execution.Record, error)

Directories

PathSynopsis
docgen

Package tvf imports 7 packages (graph) and is imported by 2 packages. Updated 2020-01-20. Refresh now. Tools for package owners.