Documentation ¶
Overview ¶
Package stream implements execution operations for querying stream data.
Index ¶
- func Analyze(_ context.Context, criteria *streamv1.QueryRequest, ...) (logical.Plan, error)
- func BuildSchema(sm *databasev1.Stream, indexRules []*databasev1.IndexRule) (logical.Schema, error)
- func DistributedAnalyze(criteria *streamv1.QueryRequest, s logical.Schema) (logical.Plan, error)
- type Parent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Analyze ¶ added in v0.3.0
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 ¶ 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
DistributedAnalyze converts logical expressions to executable operation tree represented by Plan.
Types ¶
Click to show internal directories.
Click to hide internal directories.