-
Notifications
You must be signed in to change notification settings - Fork 62
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Retrieving query info using new query plan retriever #111
Conversation
Retrieving query info using new query plan retriever
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Approved assuming Brandon signs off. Also left 2 comments.
sdk/src/test/java/com/microsoft/azure/cosmosdb/rx/ParallelDocumentQueryTest.java
Show resolved
Hide resolved
Also, please create an issue/PR to track the v3 port of this change before we merge. |
.../java/com/microsoft/azure/cosmosdb/rx/internal/query/ProxyDocumentQueryExecutionContext.java
Show resolved
Hide resolved
...ava/com/microsoft/azure/cosmosdb/rx/internal/query/DocumentQueryExecutionContextFactory.java
Show resolved
Hide resolved
Please see if you can remove the multiple addition single toObservable in the new block of code. If you could rely on Single.toFlatMap() that would be better and you can do less transformation. Also you have test failure. other than that looks good. |
...ava/com/microsoft/azure/cosmosdb/rx/internal/query/DocumentQueryExecutionContextFactory.java
Show resolved
Hide resolved
...ava/com/microsoft/azure/cosmosdb/rx/internal/query/DocumentQueryExecutionContextFactory.java
Outdated
Show resolved
Hide resolved
...ava/com/microsoft/azure/cosmosdb/rx/internal/query/DocumentQueryExecutionContextFactory.java
Outdated
Show resolved
Hide resolved
...ava/com/microsoft/azure/cosmosdb/rx/internal/query/DocumentQueryExecutionContextFactory.java
Show resolved
Hide resolved
...ava/com/microsoft/azure/cosmosdb/rx/internal/query/DocumentQueryExecutionContextFactory.java
Outdated
Show resolved
Hide resolved
...ava/com/microsoft/azure/cosmosdb/rx/internal/query/DocumentQueryExecutionContextFactory.java
Outdated
Show resolved
Hide resolved
gateway/src/main/java/com/microsoft/azure/cosmosdb/rx/internal/query/QueryFeature.java
Show resolved
Hide resolved
gateway/src/main/java/com/microsoft/azure/cosmosdb/rx/internal/query/QueryPlanRetriever.java
Outdated
Show resolved
Hide resolved
|
sdk/src/test/java/com/microsoft/azure/cosmosdb/rx/ParallelDocumentQueryTest.java
Show resolved
Hide resolved
…o appropriate partition ranges
...ay/src/main/java/com/microsoft/azure/cosmosdb/internal/routing/RoutingMapProviderHelper.java
Show resolved
Hide resolved
...ay/src/main/java/com/microsoft/azure/cosmosdb/internal/routing/RoutingMapProviderHelper.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
does ReadMyWrite test pass?
...ay/src/main/java/com/microsoft/azure/cosmosdb/internal/routing/RoutingMapProviderHelper.java
Outdated
Show resolved
Hide resolved
gateway/src/main/java/com/microsoft/azure/cosmosdb/rx/internal/query/QueryPlanRetriever.java
Show resolved
Hide resolved
sdk/src/test/java/com/microsoft/azure/cosmosdb/rx/AggregateQueryTests.java
Show resolved
Hide resolved
gateway/src/main/java/com/microsoft/azure/cosmosdb/rx/internal/query/QueryPlanRetriever.java
Show resolved
Hide resolved
gateway/src/main/java/com/microsoft/azure/cosmosdb/rx/internal/query/QueryPlanRetriever.java
Outdated
Show resolved
Hide resolved
...om/microsoft/azure/cosmosdb/rx/internal/query/ParallelDocumentQueryExecutionContextBase.java
Show resolved
Hide resolved
...ay/src/main/java/com/microsoft/azure/cosmosdb/internal/routing/RoutingMapProviderHelper.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
please address/respond to the comments.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you Bhaskar for addressing the comments.
Removing proxy execution context
Retrieving query info using new query plan retriever
This change is