This is an automated email from the ASF dual-hosted git repository.
gortiz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 9302f186d6 Fix null literal handling for null intolerant functions in
multi-stage query engine (#13255)
add 3b5711686b Serialize V2 Plan using Protobufs instead of reflection.
(#13221)
No new revisions were added by this update.
Summary of changes:
pinot-common/src/main/proto/expressions.proto | 80 +++++
pinot-common/src/main/proto/plan.proto | 247 ++++++++++---
.../planner/logical/RelToPlanNodeConverter.java | 9 +-
.../query/planner/plannode/AbstractPlanNode.java | 15 +-
.../query/planner/plannode/AggregateNode.java | 10 +
.../pinot/query/planner/plannode/ExchangeNode.java | 14 +
.../pinot/query/planner/plannode/FilterNode.java | 5 +
.../pinot/query/planner/plannode/JoinNode.java | 13 +
.../query/planner/plannode/MailboxReceiveNode.java | 19 +
.../query/planner/plannode/MailboxSendNode.java | 17 +-
.../pinot/query/planner/plannode/ProjectNode.java | 9 +-
.../pinot/query/planner/plannode/SortNode.java | 10 +
.../planner/plannode/StageNodeSerDeUtils.java | 97 -----
.../query/planner/plannode/TableScanNode.java | 8 +
.../pinot/query/planner/plannode/ValueNode.java | 5 +
.../pinot/query/planner/plannode/WindowNode.java | 16 +
.../query/planner/serde/PlanNodeSerializer.java | 392 +++++++++++++++++++++
.../serde/ProtoExpressionToRexExpression.java | 149 ++++++++
.../query/planner/serde/ProtoSerializable.java | 49 ---
.../planner/serde/ProtoSerializationUtils.java | 280 ---------------
.../serde/RexExpressionToProtoExpression.java | 145 ++++++++
.../query/planner/serde/StageNodeDeserializer.java | 384 ++++++++++++++++++++
.../pinot/query/routing/QueryPlanSerDeUtils.java | 5 +-
.../query/planner/plannode/SerDeUtilsTest.java | 6 +-
.../planner/serde/ProtoSerializationUtilsTest.java | 62 ----
.../query/service/dispatch/QueryDispatcher.java | 7 +-
.../query/service/server/QueryServerTest.java | 4 +-
27 files changed, 1487 insertions(+), 570 deletions(-)
create mode 100644 pinot-common/src/main/proto/expressions.proto
delete mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/plannode/StageNodeSerDeUtils.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/PlanNodeSerializer.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/ProtoExpressionToRexExpression.java
delete mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/ProtoSerializable.java
delete mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/ProtoSerializationUtils.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/RexExpressionToProtoExpression.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/StageNodeDeserializer.java
delete mode 100644
pinot-query-planner/src/test/java/org/apache/pinot/query/planner/serde/ProtoSerializationUtilsTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
