change streaming_window -> window

probably-nothing-labs · Aug 12, 2024 · e1234dd · e1234dd
1 parent 56e2dd1
commit e1234dd
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 3 deletions.
diff --git a/crates/core/src/datastream.rs b/crates/core/src/datastream.rs
@@ -19,6 +19,9 @@ pub struct DataStream {
 }
 
 impl DataStream {
+    pub fn schema(&self) -> Result<Self> {
+    }
+
     pub fn filter(&self, predicate: Expr) -> Result<Self> {
         let (session_state, plan) = self.df.as_ref().clone().into_parts();
 
@@ -33,7 +36,7 @@ impl DataStream {
     // drop_columns, sync, columns: &[&str]
     // count
 
-    pub fn streaming_window(
+    pub fn window(
         &self,
         group_expr: Vec<Expr>,
         aggr_expr: Vec<Expr>,

diff --git a/examples/examples/kafka_rideshare.rs b/examples/examples/kafka_rideshare.rs
@@ -69,7 +69,7 @@ async fn main() -> Result<()> {
         ]))
         .await?;
 
-    let ds = ctx.from_topic(source_topic).await?.streaming_window(
+    let ds = ctx.from_topic(source_topic).await?.window(
         vec![],
         vec![
             max(col("imu_measurement").field("gps").field("speed")),

diff --git a/examples/examples/simple_aggregation.rs b/examples/examples/simple_aggregation.rs
@@ -33,7 +33,7 @@ async fn main() -> Result<()> {
     let ds = ctx
         .from_topic(source_topic)
         .await?
-        .streaming_window(
+        .window(
             vec![],
             vec![
                 min(col("temperature")).alias("min"),