feat: derived stream (#4160)

`DerivedStream`, as part of `Pipeline`, enables the use case of querying
an existing stream, `source`, with optional conditions and aggregations.
The resulted data will then be ingested into a new stream,
`destination`.

This PR provides the feature's initial offering. Please follow below
issue to track & suggest future improvements
#4170 

Co-authored-by: omkark06 <omkar@zinclabs.io>
Co-authored-by: hengfei yang <hengfei.yang@gmail.com>

src/cli/basic/cli.rs

@@ -161,7 +161,7 @@ pub async fn cli() -> Result<bool, anyhow::Error> {
                     db::user::reset().await?;
                 }
                 "alert" => {
-                    db::alerts::reset().await?;
+                    db::alerts::alert::reset().await?;
                 }
                 "dashboard" => {
                     db::dashboards::reset().await?;