fix table name

getdozer · Sep 28, 2023 · 5c86e60 · 5c86e60
1 parent 731d608
commit 5c86e60
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/dozer-sql/src/pipeline_builder/from_builder.rs b/dozer-sql/src/pipeline_builder/from_builder.rs
@@ -361,6 +361,9 @@ pub fn is_table_operator(
 ) -> Result<Option<TableOperatorDescriptor>, PipelineError> {
     match relation {
         TableFactor::Table { name, args, .. } => {
+            if args.is_none() {
+                return Ok(None);
+            }
             let operator = get_table_operator_descriptor(name, args)?;
 
             Ok(operator)

diff --git a/dozer-sql/src/tests/builder_test.rs b/dozer-sql/src/tests/builder_test.rs
@@ -111,7 +111,7 @@ impl Source for TestSource {
         fw: &mut dyn SourceChannelForwarder,
         _last_checkpoint: SourceState,
     ) -> Result<(), BoxedError> {
-        for n in 0..10000 {
+        for n in 0..10 {
             fw.send(
                 IngestionMessage::OperationEvent {
                     table_index: 0,
@@ -194,9 +194,9 @@ impl Sink for TestSink {
 async fn test_pipeline_builder() {
     let mut pipeline = AppPipeline::new_with_default_flags();
     let context = statement_to_pipeline(
-        "SELECT Spending  \
-        FROM TTL(TUMBLE(users, timestamp, '5 MINUTES'), timestamp, '1 MINUTE') \
-         WHERE Spending >= 1",
+        "SELECT t.Spending  \
+        FROM TTL(TUMBLE(users, timestamp, '5 MINUTES'), timestamp, '1 MINUTE') t JOIN users u on t.CustomerID=u.CustomerID \
+         WHERE t.Spending >= 1",
         &mut pipeline,
         Some("results".to_string()),
         vec![],