From 94f20d680409bf5f89fefdbceaa1a506ad86d23c Mon Sep 17 00:00:00 2001
From: Bolek Ziobrowski <26925920+bziobrowski@users.noreply.github.com>
Date: Fri, 10 Jan 2025 13:58:02 +0100
Subject: [PATCH] Reverted reformat.

---
 .../pinot/core/query/reduce/BrokerReduceService.java     | 3 +--
 .../pinot/core/query/reduce/GroupByDataTableReducer.java | 9 +++------
 2 files changed, 4 insertions(+), 8 deletions(-)

diff --git a/pinot-core/src/main/java/org/apache/pinot/core/query/reduce/BrokerReduceService.java b/pinot-core/src/main/java/org/apache/pinot/core/query/reduce/BrokerReduceService.java
index 3bf174e7c648..d10e0811ede9 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/query/reduce/BrokerReduceService.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/query/reduce/BrokerReduceService.java
@@ -59,8 +59,7 @@ public BrokerReduceService(PinotConfiguration config) {
   }
 
   public BrokerResponseNative reduceOnDataTable(BrokerRequest brokerRequest, BrokerRequest serverBrokerRequest,
-                                                Map<ServerRoutingInstance, DataTable> dataTableMap,
-                                                long reduceTimeOutMs, BrokerMetrics brokerMetrics) {
+      Map<ServerRoutingInstance, DataTable> dataTableMap, long reduceTimeOutMs, BrokerMetrics brokerMetrics) {
     if (dataTableMap.isEmpty()) {
       // Empty response.
       return BrokerResponseNative.empty();
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/query/reduce/GroupByDataTableReducer.java b/pinot-core/src/main/java/org/apache/pinot/core/query/reduce/GroupByDataTableReducer.java
index d06778538a03..c53be31ed518 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/query/reduce/GroupByDataTableReducer.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/query/reduce/GroupByDataTableReducer.java
@@ -141,12 +141,9 @@ public void reduceAndSetResults(String tableName, DataSchema dataSchema,
    * @param brokerMetrics broker metrics (meters)
    * @throws TimeoutException If unable complete within timeout.
    */
-  private void reduceResult(BrokerResponseNative brokerResponseNative,
-                            DataSchema dataSchema,
-                            Collection<DataTable> dataTables,
-                            DataTableReducerContext reducerContext,
-                            String rawTableName,
-                            BrokerMetrics brokerMetrics)
+  private void reduceResult(BrokerResponseNative brokerResponseNative, DataSchema dataSchema,
+      Collection<DataTable> dataTables, DataTableReducerContext reducerContext, String rawTableName,
+      BrokerMetrics brokerMetrics)
       throws TimeoutException {
     // NOTE: This step will modify the data schema and also return final aggregate results.
     IndexedTable indexedTable = getIndexedTable(dataSchema, dataTables, reducerContext);