Merge branch 'users/leminh/LINQGroupByMultiValue' of https://github.com/Azure/azure-cosmos-dotnet-v3 into users/leminh/LINQGroupByMultiValue

Author: leminh98

Microsoft.Azure.Cosmos/src/ChangeFeed/ChangeFeedIteratorCore.cs

@@ -340,11 +340,6 @@ private async Task<ResponseMessage> ReadNextInternalAsync(ITrace trace, Cancella
             return responseMessage;
         }
 
-        public override CosmosElement GetCosmosElementContinuationToken()
-        {
-            throw new NotSupportedException();
-        }
-
         private sealed class ChangeFeedStateFromToChangeFeedCrossFeedRangeState : ChangeFeedStartFromVisitor<TryCatch<ChangeFeedCrossFeedRangeState>>
         {
             public static readonly ChangeFeedStateFromToChangeFeedCrossFeedRangeState Singleton = new ChangeFeedStateFromToChangeFeedCrossFeedRangeState();

Microsoft.Azure.Cosmos/src/ChangeFeed/ChangeFeedPartitionKeyResultSetIteratorCore.cs

@@ -85,11 +85,6 @@ private ChangeFeedPartitionKeyResultSetIteratorCore(
 
         public override bool HasMoreResults => this.hasMoreResultsInternal;
 
-        public override CosmosElement GetCosmosElementContinuationToken()
-        {
-            throw new NotImplementedException();
-        }
-
         /// <summary>
         /// Get the next set of results from the cosmos service
         /// </summary>

Microsoft.Azure.Cosmos/src/ChangeFeed/StandByFeedIteratorCore.cs

@@ -207,10 +207,5 @@ internal virtual Task<ResponseMessage> NextResultSetDelegateAsync(
                 trace: trace,
                 cancellationToken: cancellationToken);
         }
-
-        public override CosmosElement GetCosmosElementContinuationToken()
-        {
-            throw new NotImplementedException();
-        }
     }
 }

Microsoft.Azure.Cosmos/src/Query/Core/Pipeline/Aggregate/AggregateQueryPipelineStage.Client.cs

@@ -28,7 +28,7 @@ private ClientAggregateQueryPipelineStage(
                 // all the work is done in the base constructor.
             }
 
-            public static TryCatch<IQueryPipelineStage> MonadicCreate(
+            public static new TryCatch<IQueryPipelineStage> MonadicCreate(
                 IReadOnlyList<AggregateOperator> aggregates,
                 IReadOnlyDictionary<string, AggregateOperator?> aliasToAggregateType,
                 IReadOnlyList<string> orderedAliases,

Microsoft.Azure.Cosmos/src/Query/Core/Pipeline/Aggregate/AggregateQueryPipelineStage.Compute.cs

@@ -58,30 +58,21 @@ public AggregateQueryPipelineStage(
         }
 
         public static TryCatch<IQueryPipelineStage> MonadicCreate(
-            ExecutionEnvironment executionEnvironment,
             IReadOnlyList<AggregateOperator> aggregates,
             IReadOnlyDictionary<string, AggregateOperator?> aliasToAggregateType,
             IReadOnlyList<string> orderedAliases,
             bool hasSelectValue,
             CosmosElement continuationToken,
-            MonadicCreatePipelineStage monadicCreatePipelineStage) => executionEnvironment switch
-            {
-                ExecutionEnvironment.Client => ClientAggregateQueryPipelineStage.MonadicCreate(
-                    aggregates,
-                    aliasToAggregateType,
-                    orderedAliases,
-                    hasSelectValue,
-                    continuationToken,
-                    monadicCreatePipelineStage),
-                ExecutionEnvironment.Compute => ComputeAggregateQueryPipelineStage.MonadicCreate(
+            MonadicCreatePipelineStage monadicCreatePipelineStage)
+        {
+            return ClientAggregateQueryPipelineStage.MonadicCreate(
                     aggregates,
                     aliasToAggregateType,
                     orderedAliases,
                     hasSelectValue,
                     continuationToken,
-                    monadicCreatePipelineStage),
-                _ => throw new ArgumentException($"Unknown {nameof(ExecutionEnvironment)}: {executionEnvironment}."),
-            };
+                    monadicCreatePipelineStage);
+        }
 
         /// <summary>
         /// Struct for getting the payload out of the rewritten projection.

Microsoft.Azure.Cosmos/src/Query/Core/Pipeline/Aggregate/AggregateQueryPipelineStage.cs

@@ -407,7 +407,6 @@ private static TryCatch<IQueryPipelineStage> TryCreateSpecializedDocumentQueryEx
                     inputParameters.PartitionKey,
                     inputParameters.Properties,
                     inputParameters.PartitionedQueryExecutionInfo,
-                    inputParameters.ExecutionEnvironment,
                     inputParameters.ReturnResultsInDeterministicOrder,
                     inputParameters.EnableOptimisticDirectExecution,
                     inputParameters.IsNonStreamingOrderByQueryFeatureDisabled,
@@ -559,7 +558,6 @@ private static TryCatch<IQueryPipelineStage> TryCreateSpecializedDocumentQueryEx
                 $"Invalid MaxItemCount {optimalPageSize}");
 
             return PipelineFactory.MonadicCreate(
-                executionEnvironment: inputParameters.ExecutionEnvironment,
                 documentContainer: documentContainer,
                 sqlQuerySpec: inputParameters.SqlQuerySpec,
                 targetRanges: targetRanges
@@ -831,7 +829,6 @@ public sealed class InputParameters
             private const int DefaultMaxItemCount = 1000;
             private const int DefaultMaxBufferedItemCount = 1000;
             private const bool DefaultReturnResultsInDeterministicOrder = true;
-            private const ExecutionEnvironment DefaultExecutionEnvironment = ExecutionEnvironment.Client;
 
             public InputParameters(
                 SqlQuerySpec sqlQuerySpec,
@@ -843,7 +840,6 @@ public InputParameters(
                 PartitionKey? partitionKey,
                 IReadOnlyDictionary<string, object> properties,
                 PartitionedQueryExecutionInfo partitionedQueryExecutionInfo,
-                ExecutionEnvironment? executionEnvironment,
                 bool? returnResultsInDeterministicOrder,
                 bool enableOptimisticDirectExecution,
                 bool isNonStreamingOrderByQueryFeatureDisabled,
@@ -877,7 +873,6 @@ public InputParameters(
                 this.PartitionKey = partitionKey;
                 this.Properties = properties;
                 this.PartitionedQueryExecutionInfo = partitionedQueryExecutionInfo;
-                this.ExecutionEnvironment = executionEnvironment.GetValueOrDefault(InputParameters.DefaultExecutionEnvironment);
                 this.ReturnResultsInDeterministicOrder = returnResultsInDeterministicOrder.GetValueOrDefault(InputParameters.DefaultReturnResultsInDeterministicOrder);
                 this.EnableOptimisticDirectExecution = enableOptimisticDirectExecution;
                 this.IsNonStreamingOrderByQueryFeatureDisabled = isNonStreamingOrderByQueryFeatureDisabled;
@@ -893,7 +888,6 @@ public InputParameters(
             public PartitionKey? PartitionKey { get; }
             public IReadOnlyDictionary<string, object> Properties { get; }
             public PartitionedQueryExecutionInfo PartitionedQueryExecutionInfo { get; }
-            public ExecutionEnvironment ExecutionEnvironment { get; }
             public bool ReturnResultsInDeterministicOrder { get; }
             public TestInjections TestInjections { get; }
             public bool EnableOptimisticDirectExecution { get; }
@@ -911,7 +905,6 @@ public InputParameters WithContinuationToken(CosmosElement token)
                     this.PartitionKey,
                     this.Properties,
                     this.PartitionedQueryExecutionInfo,
-                    this.ExecutionEnvironment,
                     this.ReturnResultsInDeterministicOrder,
                     this.EnableOptimisticDirectExecution,
                     this.IsNonStreamingOrderByQueryFeatureDisabled,