You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by si...@apache.org on 2022/09/08 19:56:27 UTC
[pinot] branch master updated: support table type routing (#9346)
This is an automated email from the ASF dual-hosted git repository.
siddteotia 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 8925ee85e9 support table type routing (#9346)
8925ee85e9 is described below
commit 8925ee85e9665dcc6cb9f81980211f2dd5765510
Author: Rong Rong <ro...@apache.org>
AuthorDate: Thu Sep 8 12:56:21 2022 -0700
support table type routing (#9346)
Co-authored-by: Rong Rong <ro...@startree.ai>
---
.../src/main/java/org/apache/pinot/query/routing/WorkerManager.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/pinot-query-planner/src/main/java/org/apache/pinot/query/routing/WorkerManager.java b/pinot-query-planner/src/main/java/org/apache/pinot/query/routing/WorkerManager.java
index aa19d3bf63..03f4ddcd9c 100644
--- a/pinot-query-planner/src/main/java/org/apache/pinot/query/routing/WorkerManager.java
+++ b/pinot-query-planner/src/main/java/org/apache/pinot/query/routing/WorkerManager.java
@@ -88,8 +88,10 @@ public class WorkerManager {
private RoutingTable getRoutingTable(String tableName) {
String rawTableName = TableNameBuilder.extractRawTableName(tableName);
- // TODO: support both offline and realtime, now we hard code offline table.
- String tableNameWithType = TableNameBuilder.forType(TableType.OFFLINE).tableNameWithType(rawTableName);
+ TableType tableType = TableNameBuilder.getTableTypeFromTableName(tableName);
+ // TODO: support both offline and realtime, now default only query the OFFLINE table.
+ tableType = tableType == null ? TableType.OFFLINE : tableType;
+ String tableNameWithType = TableNameBuilder.forType(tableType).tableNameWithType(rawTableName);
return _routingManager.getRoutingTable(CalciteSqlCompiler.compileToBrokerRequest(
"SELECT * FROM " + tableNameWithType));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org