#989 applying sql filter on the virutalised table using ignite example

finos · Jan 23, 2024 · e8d124b · e8d124b
1 parent fb2ca7d
commit e8d124b
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 12 deletions.
diff --git a/example/data-ignite/src/main/scala/org/finos/vuu/data/order/ignite/IgniteOrderStore.scala b/example/data-ignite/src/main/scala/org/finos/vuu/data/order/ignite/IgniteOrderStore.scala
@@ -73,7 +73,7 @@ class IgniteOrderStore(private val parentOrderCache: IgniteCache[Int, ParentOrde
       counter += 1
     })
 
-    logger.info(s"Loaded Ignite ChildOrder for $counter rows, from index : $startIndex")
+    logger.info(s"Loaded Ignite ChildOrder for $counter rows, from index : $startIndex where $whereClause")
 
     buffer
 

diff --git a/.../src/main/scala/org/finos/vuu/example/virtualtable/provider/IgniteOrderDataProvider.scala b/.../src/main/scala/org/finos/vuu/example/virtualtable/provider/IgniteOrderDataProvider.scala
@@ -24,17 +24,17 @@ class IgniteOrderDataProvider(final val igniteStore: IgniteOrderStore)(implicit
     internalTable.setRange(VirtualizedRange(range.from, range.to))
 
 
-//    val sqlFilterClause =
-//      if (viewPort.filterSpec.filter == null || viewPort.filterSpec.filter.isEmpty) {
-//        ""
-//      }
-//      else {
-//        val filterTreeVisitor = new IgniteSqlFilterTreeVisitor
-//        val clause = FilterSpecParser.parse[IgniteSqlFilterClause](viewPort.filterSpec.filter, filterTreeVisitor)
-//        clause.toSql()
-//      }
-
-    val sqlFilterClause = ""
+    val sqlFilterClause =
+      if (viewPort.filterSpec.filter == null || viewPort.filterSpec.filter.isEmpty) {
+        ""
+      }
+      else {
+        val filterTreeVisitor = new IgniteSqlFilterTreeVisitor
+        val clause = FilterSpecParser.parse[IgniteSqlFilterClause](viewPort.filterSpec.filter, filterTreeVisitor)
+        clause.toSql()
+      }
+
+//    val sqlFilterClause = ""
 
     val rowCount = if(range.to > range.from) range.to - range.from else 1
     val iterator = igniteStore.findChildOrder(sqlFilterClause = sqlFilterClause, startIndex = range.from, rowCount = rowCount)
-Original file line number
+Diff line change
@@ Expand Up @@
           counter += 1
         })
-        logger.info(s"Loaded Ignite ChildOrder for $counter rows, from index : $startIndex")
+        logger.info(s"Loaded Ignite ChildOrder for $counter rows, from index : $startIndex where $whereClause")
         buffer
@@ Expand Down @@