stream

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Nov 24, 2025 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Overview

Package stream implements execution operations for querying stream data.

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ENode is an empty node.
	ENode = new(emptyNode)
)

Functions

func Analyze added in v0.3.0 

func Analyze(criteria *streamv1.QueryRequest, metadata []*commonv1.Metadata, ss []logical.Schema, ecc []executor.StreamExecutionContext) (logical.Plan, error)

Analyze converts logical expressions to executable operation tree represented by Plan.

func BuildElementsFromStreamResult added in v0.6.1 

func BuildElementsFromStreamResult(ctx context.Context, result model.StreamQueryResult) (elements []*streamv1.Element, err error)

BuildElementsFromStreamResult builds a slice of elements from the given stream query result.

func BuildSchema added in v0.3.0 

func BuildSchema(sm *databasev1.Stream, indexRules []*databasev1.IndexRule) (logical.Schema, error)

BuildSchema returns Schema loaded from the metadata repository.

func DistributedAnalyze added in v0.5.0 

func DistributedAnalyze(criteria *streamv1.QueryRequest, ss []logical.Schema) (logical.Plan, error)

DistributedAnalyze converts logical expressions to executable operation tree represented by Plan.

Types

type Parent added in v0.3.0 

type Parent struct {
	UnresolvedInput logical.UnresolvedPlan
	Input           logical.Plan
}

Parent refers to a parent node in the execution tree(plan).

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.