INNER CODE UNIT · C#

RunCreatedAtQueryAsync

ZoneTree/ZoneTree · benchmarks/zonetree-scan-lab/Program.cs:371

  public Task RunCreatedAtQueryAsync(CreatedAtQuery[] queries) =>
      ScanExecution.RunPartitionedAsync(
          "query created-at",
          queries.Length,
          config.Parallelism,
          (start, count, checksum) =>
          {
            for (var i = start; i < start + count; i++)
            {
              var query = queries[i];
              var startKey = ProfileKeys.CreatedAt(query.FromUnixMs, 0);
              var endKey = ProfileKeys.CreatedAt(query.ToUnixMs, long.MaxValue);
              ScanStringIndexProfiles(
                  CreatedAtIndex!,
                  startKey,
                  key => string.CompareOrdinal(key, endKey) <= 0,
                  checksum);
            }

View source record →