Skip to content
Merged
Changes from 1 commit
Commits
Show all changes
36 commits
Select commit Hold shift + click to select a range
2d90f0f
Initial prep for adding a non streaming order by query pipline stage
neildsh Mar 9, 2024
92a0625
Change TracingAsyncEnumerator to be an adapter class between ITracing…
neildsh Mar 11, 2024
0eff840
Move TracingAsyncEnumerator to product code
neildsh Mar 11, 2024
3ae0b62
Change ITracingAsyncEnumerator.MoveNext to take a CancellationToken, …
neildsh Mar 11, 2024
0ff0687
draft implementation of non streaming order by pipeline stage
neildsh Mar 14, 2024
b252123
Fix bug that drops first record on an initialized page
neildsh Mar 14, 2024
163f31f
Add a test class for non streaming order by unit tests
neildsh Mar 14, 2024
83e1726
remove unnecessary usings
neildsh Mar 14, 2024
bf2e7dd
Add an emulator test for non streaming order by. Also lay groundwork …
neildsh Mar 18, 2024
275b063
Remove the ResponseLengthInBytes property from QueryPage. This was be…
neildsh Mar 18, 2024
94e3125
Add an ItemCount property to the Page class
neildsh Mar 18, 2024
9eb7809
Add a multi level heap implementation for non streaming order by
neildsh Mar 20, 2024
ce69f9d
Add infrastructure for writing parity tests
neildsh Mar 20, 2024
702c7ad
Fix a bug that caused the page enumerator to be dropped when we reach…
neildsh Mar 20, 2024
cb874da
When cloning OrderByQueryPartitionRangePageAsyncEnumerator as a fully…
neildsh Mar 20, 2024
97d93d9
Simplify the non streaming pipeline stage, and add performance test
neildsh Mar 22, 2024
075cb46
Revert the changes for Headers.ItemCount Keep it as a string
neildsh Mar 22, 2024
1d02ee8
Avoid an allocation each time the OrderByItems property of OrderByQue…
neildsh Mar 22, 2024
5f464d0
Fix up the OrderByPipelineSatgeBenchmark to use fully materialized Co…
neildsh Mar 22, 2024
8089fdf
Add a few more unit tests for non streaming order by
neildsh Mar 22, 2024
6e5a807
Add emulator tests for non streaming order by
neildsh Mar 25, 2024
82bde9b
Add a few more integration test cases
neildsh Mar 26, 2024
be3fb81
Fix up broken unit test
neildsh Mar 26, 2024
c54e89b
Add more test coverage for the non streaming order by
neildsh Mar 27, 2024
8babdb7
If there is no continuationtoken, assume that the response is streaming
neildsh Mar 27, 2024
784295a
Add stronger validation to the non streaming order by unit tests
neildsh Mar 27, 2024
98218bb
Fix up broken unit tests to account for ItemCount
neildsh Mar 27, 2024
6b66ad2
fix up plumbing for index utilization, and incorporate code review fe…
neildsh Mar 27, 2024
6abe501
Minor clean up
neildsh Mar 27, 2024
cf6f04b
revert bug introduced in pursuit of more elegant code :)
neildsh Mar 28, 2024
3065ed1
fix up broken unit test
neildsh Mar 28, 2024
b966a8a
Fix up broken perf test
neildsh Mar 28, 2024
3661c36
Fix up broken IndexMetricsParserBaselineTest
neildsh Mar 29, 2024
74f3eff
Minor bug fixes for OrderByCrossPartitionEnumerator
neildsh Mar 29, 2024
05befa6
Merge branch 'master' into users/ndeshpan/nonStreamingOrderBy
neildsh Mar 29, 2024
2942dd1
Merge branch 'master' into users/ndeshpan/nonStreamingOrderBy
neildsh Mar 30, 2024
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
revert bug introduced in pursuit of more elegant code :)
  • Loading branch information
neildsh committed Mar 28, 2024
commit cf6f04bdf9dc0eae00f884818c5eb3f668faeb40
Original file line number Diff line number Diff line change
Expand Up @@ -153,7 +153,10 @@ public async ValueTask<bool> MoveNextAsync(ITrace trace, CancellationToken cance
if (this.bufferedPages.Count > 0)
{
this.bufferedPages.Dequeue();
return this.bufferedPages.Count > 0;
if (this.bufferedPages.Count > 0)
{
return true;
}
}

TryCatch<bool> hasNext = await this.inner.TryAsync(pipelineStage => pipelineStage.MoveNextAsync(trace, cancellationToken));
Expand Down