soumyakanti3578 commented on code in PR #6067:
URL: https://github.com/apache/hive/pull/6067#discussion_r2396371312
##########
ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/HiveRelOptUtil.java:
##########
@@ -1079,15 +1106,110 @@ public static Pair<RelOptTable, List<Integer>>
getColumnOriginSet(RelNode rel, I
* to parse the string back.
*/
public static String toJsonString(final RelNode rel) {
+ return serializeWithPlanWriter(rel, new HiveRelJsonImplWithStats());
+ }
+
+ private static String serializeWithPlanWriter(RelNode rel, HiveRelJsonImpl
planWriter) {
if (rel == null) {
return null;
}
-
- final HiveRelJsonImpl planWriter = new HiveRelJsonImpl();
rel.explain(planWriter);
return planWriter.asString();
}
+ public static Optional<String> serializeToJSON(RelNode plan) {
+ if (!isSerializable(plan)) {
+ return Optional.empty();
+ }
+
+ JSONObject outJSONObject = new JSONObject(new LinkedHashMap<>());
+ outJSONObject.put("CBOPlan", serializeWithPlanWriter(plan, new
HiveRelJsonImpl()));
+ String jsonPlan = outJSONObject.toString();
+
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Plan to serialize: \n{}", RelOptUtil.toString(plan));
+ LOG.debug("JSON plan: \n{}", jsonPlan);
+ }
Review Comment:
Yeah this will not be in the final commit. I will remove it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
