From 5caf6d806651ac89dedec4ab0c95fc6c6f4c976b Mon Sep 17 00:00:00 2001 From: Frank Nodes Date: Sun, 6 Oct 2024 11:54:15 +0200 Subject: [PATCH] back to file streaming as default (prob memleakfix) --- FKala.Core/KalaQl/Op_BaseQuery.cs | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/FKala.Core/KalaQl/Op_BaseQuery.cs b/FKala.Core/KalaQl/Op_BaseQuery.cs index 954dc56..9c5c170 100644 --- 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;