This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 074634155e9 Remove APIs deprecated in 1.2.0 (#19142)
074634155e9 is described below
commit 074634155e9f092d0b5cc64b637f222b9eec9de5
Author: Xiang Fu <[email protected]>
AuthorDate: Sun Aug 2 14:30:43 2026 -0700
Remove APIs deprecated in 1.2.0 (#19142)
- Remove deprecated controller endpoint GET /tables/{tableName}/livebrokers
(PinotTableInstances); the plural GET /tables/livebrokers?tables=...
endpoint remains.
- Remove deprecated RequestUtils.getFunctionExpression(String) (no-operand
variant); all callers already use the Function or name+operands overloads.
- Remove deprecated RequestUtils.getOptionsFromJson(JsonNode, String);
no callers.
- Remove deprecated BrokerResponse.getProcessingExceptions() default method;
use getExceptions() instead.
---
.../pinot/common/response/BrokerResponse.java | 6 ------
.../pinot/common/utils/request/RequestUtils.java | 14 -------------
.../api/resources/PinotTableInstances.java | 23 ----------------------
3 files changed, 43 deletions(-)
diff --git
a/pinot-common/src/main/java/org/apache/pinot/common/response/BrokerResponse.java
b/pinot-common/src/main/java/org/apache/pinot/common/response/BrokerResponse.java
index 0d4c67d057b..0b1eb3ed068 100644
---
a/pinot-common/src/main/java/org/apache/pinot/common/response/BrokerResponse.java
+++
b/pinot-common/src/main/java/org/apache/pinot/common/response/BrokerResponse.java
@@ -110,12 +110,6 @@ public interface BrokerResponse {
/// Returns the processing exceptions encountered during the query execution.
List<QueryProcessingException> getExceptions();
- @Deprecated
- @JsonIgnore
- default List<QueryProcessingException> getProcessingExceptions() {
- return getExceptions();
- }
-
@JsonIgnore
default int getExceptionsSize() {
return getExceptions().size();
diff --git
a/pinot-common/src/main/java/org/apache/pinot/common/utils/request/RequestUtils.java
b/pinot-common/src/main/java/org/apache/pinot/common/utils/request/RequestUtils.java
index c01c25e87ab..9545275d820 100644
---
a/pinot-common/src/main/java/org/apache/pinot/common/utils/request/RequestUtils.java
+++
b/pinot-common/src/main/java/org/apache/pinot/common/utils/request/RequestUtils.java
@@ -524,15 +524,6 @@ public class RequestUtils {
return getFunctionExpression(getFunction(canonicalName, operands));
}
- @Deprecated
- public static Expression getFunctionExpression(String canonicalName) {
- assert
canonicalName.equalsIgnoreCase(canonicalizeFunctionNamePreservingSpecialKey(canonicalName));
- Expression expression = new Expression(ExpressionType.FUNCTION);
- Function function = new Function(canonicalName);
- expression.setFunctionCall(function);
- return expression;
- }
-
/// Converts the function name into its canonical form.
public static String canonicalizeFunctionName(String functionName) {
return StringUtils.remove(functionName, '_').toLowerCase();
@@ -684,11 +675,6 @@ public class RequestUtils {
return getTableNames(pinotQuery.getDataSource());
}
- @Deprecated
- public static Map<String, String> getOptionsFromJson(JsonNode request,
String optionsKey) {
- return getOptionsFromString(request.get(optionsKey).asText());
- }
-
public static Map<String, String> getOptionsFromString(String optionStr) {
return
Splitter.on(';').omitEmptyStrings().trimResults().withKeyValueSeparator('=').split(optionStr);
}
diff --git
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotTableInstances.java
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotTableInstances.java
index 979fb5a43e7..1d2c9fb2aff 100644
---
a/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotTableInstances.java
+++
b/pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotTableInstances.java
@@ -50,7 +50,6 @@ import javax.ws.rs.core.HttpHeaders;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import org.apache.commons.collections4.CollectionUtils;
-import org.apache.pinot.common.exception.TableNotFoundException;
import org.apache.pinot.common.utils.DatabaseUtils;
import org.apache.pinot.common.utils.SimpleHttpResponse;
import org.apache.pinot.common.utils.http.HttpClient;
@@ -158,28 +157,6 @@ public class PinotTableInstances {
return ret.toString();
}
- @Deprecated
- @GET
- @Path("/tables/{tableName}/livebrokers")
- @Authorize(targetType = TargetType.TABLE, paramName = "tableName", action =
Actions.Table.GET_BROKER)
- @Produces(MediaType.APPLICATION_JSON)
- @ApiOperation(value = "List the brokers serving a table", notes = "List live
brokers of the given table based on EV")
- @ApiResponses(value = {
- @ApiResponse(code = 200, message = "Success"),
- @ApiResponse(code = 404, message = "Table not found"),
- @ApiResponse(code = 500, message = "Internal server error")
- })
- public List<String> getLiveBrokersForTable(
- @ApiParam(value = "Table name (with or without type)", required = true)
- @PathParam("tableName") String tableName, @Context HttpHeaders headers) {
- tableName = DatabaseUtils.translateTableName(tableName, headers);
- try {
- return _pinotHelixResourceManager.getLiveBrokersForTable(tableName);
- } catch (TableNotFoundException e) {
- throw new ControllerApplicationException(LOGGER, e.getMessage(),
Response.Status.NOT_FOUND);
- }
- }
-
@GET
@Path("/tables/livebrokers")
@Authorize(targetType = TargetType.CLUSTER, action =
Actions.Cluster.GET_BROKER)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
