added query for slice of childorders

finos · Nov 24, 2023 · f9e8f95 · f9e8f95
1 parent 61c7090
commit f9e8f95
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...ple/data-ignite/src/main/scala/org/finos/vuu/data/order/ignite/CacheNodeApplication.scala b/...ple/data-ignite/src/main/scala/org/finos/vuu/data/order/ignite/CacheNodeApplication.scala
@@ -3,7 +3,7 @@ package org.finos.vuu.data.order.ignite
 import org.apache.ignite.Ignition
 
 object CacheNodeApplication extends App {
-  IgniteLocalConfig.setPersistenceEnabled(true)
+  IgniteLocalConfig.setPersistenceEnabled(false)
   val configuration = IgniteLocalConfig.create(false)
 
   val ignite = Ignition.getOrStart(configuration)

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
@@ -98,7 +98,7 @@ class IgniteOrderStore(private val parentOrderCache: IgniteCache[Int, ParentOrde
   }
 
   def findWindow(startIndex: Long, rowCount: Int): Iterable[ChildOrder] = {
-    val query = childOrderCache.query(new SqlFieldsQuery(s"select * from ChildOrder order by id limit $rowCount offset $startIndex"))
+    val query = childOrderCache.query(new SqlFieldsQuery(s"select * from ChildOrder limit $rowCount offset $startIndex"))
 
     val buffer = mutable.ListBuffer[ChildOrder]()
     query.forEach(item => buffer.addOne(toChildOrder(item)))