stream

package

v0.3.0 Latest Latest Go to latest Published: Feb 6, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Package stream implements execution operations for querying stream data.

This section is empty.

This section is empty.

func Analyze(_ context.Context, criteria *streamv1.QueryRequest, metadata *commonv1.Metadata, s logical.Schema) (logical.Plan, error)

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

func BuildSchema(streamSchema stream.Stream) (logical.Schema, error)

BuildSchema returns Schema loaded from the metadata repository.

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

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