proxy.golang.org : github.com/rulego/streamsql
Package streamsql is a lightweight, SQL-based IoT edge stream processing engine. StreamSQL provides efficient unbounded data stream processing and analysis capabilities, supporting multiple window types, aggregate functions, custom functions, and seamless integration with the RuleGo ecosystem. • Lightweight design - Pure in-memory operations, no external dependencies • SQL syntax support - Process stream data using familiar SQL syntax • Multiple window types - Sliding, tumbling, counting, and session windows • Rich aggregate functions - MAX, MIN, AVG, SUM, STDDEV, MEDIAN, PERCENTILE, etc. • Plugin-based custom functions - Runtime dynamic registration, supports 8 function types • RuleGo ecosystem integration - Extend input/output sources using RuleGo components Basic stream data processing: StreamSQL supports multiple window types: StreamSQL supports plugin-based custom functions with runtime dynamic registration: Supported custom function types: • TypeMath - Mathematical calculation functions • TypeString - String processing functions • TypeConversion - Type conversion functions • TypeDateTime - Date and time functions • TypeAggregation - Aggregate functions • TypeAnalytical - Analytical functions • TypeWindow - Window functions • TypeCustom - General custom functions StreamSQL provides flexible log configuration options: StreamSQL provides deep integration with the RuleGo rule engine through two dedicated components for stream data processing: • streamTransform (x/streamTransform) - Stream transformer, handles non-aggregation SQL queries • streamAggregator (x/streamAggregator) - Stream aggregator, handles aggregation SQL queries Basic integration example:
Registry
-
Source
- Documentation
- JSON
- codemeta.json
purl: pkg:golang/github.com/rulego/streamsql
Keywords:
edge-analytics
, edge-computing
, iot
, rulego
, sql
, stats
, stream
License: Apache-2.0
Latest release: 2 months ago
First release: 3 months ago
Namespace: github.com/rulego
Stars: 46 on GitHub
Forks: 4 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: about 1 month ago