back to file streaming as default (prob memleakfix)

naxan6 · Oct 6, 2024 · 5caf6d8 · 5caf6d8
1 parent bb88484
commit 5caf6d8
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/FKala.Core/KalaQl/Op_BaseQuery.cs b/FKala.Core/KalaQl/Op_BaseQuery.cs
@@ -37,7 +37,8 @@ public override bool CanExecute(KalaQlContext context)
 
         public override void Execute(KalaQlContext context)
         {
-            var result = context.DataLayer.LoadData(this.Measurement, this.StartTime, this.EndTime, CacheResolution, NewestOnly, context, DontInvalidateCache_ForUseWhileCacheRebuild).ToList();
+            //in-mem copy probably mem-leak
+            //var result = context.DataLayer.LoadData(this.Measurement, this.StartTime, this.EndTime, CacheResolution, NewestOnly, context, DontInvalidateCache_ForUseWhileCacheRebuild).ToList();
 
             context.IntermediateDatasources.Add(
                 new ResultPromise()
@@ -49,11 +50,11 @@ public override void Execute(KalaQlContext context)
                     ResultsetFactory = () =>
                     {
                         // source file streaming
-                        //var result = context.DataLayer.LoadData(this.Measurement, this.StartTime, this.EndTime, CacheResolution, NewestOnly, context, DontInvalidateCache_ForUseWhileCacheRebuild);
-                        //return result;
+                        var result = context.DataLayer.LoadData(this.Measurement, this.StartTime, this.EndTime, CacheResolution, NewestOnly, context, DontInvalidateCache_ForUseWhileCacheRebuild);
+                        return result;
 
-                        //in-mem copy
-                        return Clone(result);
+                        //in-mem copy probably mem-leak
+                        //return Clone(result);
                     }
                 });
             this.hasExecuted = true;