Skip to content

Commit

Permalink
Reverted reformat.
Browse files Browse the repository at this point in the history
  • Loading branch information
bziobrowski committed Jan 10, 2025
1 parent c06caef commit 94f20d6
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down

0 comments on commit 94f20d6

Please sign in to comment.