INNER CODE UNIT · C#

RunCreatedAtScanAsync

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

  public Task RunCreatedAtScanAsync(CreatedAtQuery[] queries) =>
      ScanExecution.RunPartitionedAsync(
          "scan 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);
              ScanStringIndexValues(
                  CreatedAtIndex!,
                  startKey,
                  key => string.CompareOrdinal(key, endKey) <= 0,
                  checksum);
            }

View source record →