Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Range ¶
type Range struct {
// contains filtered or unexported fields
}
func NewRange ¶
func NewRange(start, end execution.Expression) *Range
func (*Range) Document ¶
func (r *Range) Document() docs.Documentation
type RangeStream ¶
type RangeStream struct {
// contains filtered or unexported fields
}
func (*RangeStream) Close ¶
func (s *RangeStream) Close() error
type Tumble ¶
type Tumble struct {
// contains filtered or unexported fields
}
func NewTumble ¶
func NewTumble(source execution.Node, timeField octosql.VariableName, windowLength, offset execution.Expression) *Tumble
func (*Tumble) Document ¶
func (r *Tumble) Document() docs.Documentation
type TumbleStream ¶
type TumbleStream struct {
// contains filtered or unexported fields
}
func (*TumbleStream) Close ¶
func (s *TumbleStream) Close() error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.