diff --git a/extensions-core/multi-stage-query/src/test/java/org/apache/druid/sql/avatica/MSQDruidMeta.java b/extensions-core/multi-stage-query/src/test/java/org/apache/druid/sql/avatica/MSQDruidMeta.java index 0c9bea30e8f..9f32008b1aa 100644 --- a/extensions-core/multi-stage-query/src/test/java/org/apache/druid/sql/avatica/MSQDruidMeta.java +++ b/extensions-core/multi-stage-query/src/test/java/org/apache/druid/sql/avatica/MSQDruidMeta.java @@ -18,7 +18,6 @@ */ package org.apache.druid.sql.avatica; -//package org.apache.druid.msq.exec; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; @@ -55,8 +54,7 @@ public class MSQDruidMeta extends DruidMeta final ErrorHandler errorHandler, final AuthenticatorMapper authMapper, final MSQTestOverlordServiceClient overlordClient, - final ObjectMapper objectMapper - ) + final ObjectMapper objectMapper) { super(sqlStatementFactory, config, errorHandler, authMapper); this.overlordClient = overlordClient; @@ -86,23 +84,17 @@ public class MSQDruidMeta extends DruidMeta if (resultRows == null) { throw new ISE("Results report not present in the task's report payload"); } -// extractedResults.add( -// results.withSignatureAndResults( -// convertColumnAndTypeToRowSignature(payload.getResults().getSignature()), resultRows -// ) -// ); try { String str = objectMapper .writerWithDefaultPrettyPrinter() .writeValueAsString(payload.getStages()); - str=str.replaceAll(taskId, ""); + str = str.replaceAll(taskId, ""); DruidHook.dispatch(DruidHook.MSQ_PLAN, str); } catch (JsonProcessingException e) { DruidHook.dispatch(DruidHook.MSQ_PLAN, "error happened during json serialization"); } - Signature signature = makeSignature(druidStatement, payload.getResults().getSignature()); @SuppressWarnings("unchecked") Frame firstFrame = Frame.create(0, true, (List) resultRows); @@ -137,10 +129,11 @@ public class MSQDruidMeta extends DruidMeta { return RowSignatures.toRelDataType(sig, DruidTypeSystem.TYPE_FACTORY); -// typeFactory.createStructType( -// signature.stream() -// .map(columnAndType -> relDataTypeFactory.createJavaType(columnAndType.getType())) -// .toArray(RelDataType[]::new)); + // typeFactory.createStructType( + // signature.stream() + // .map(columnAndType -> + // relDataTypeFactory.createJavaType(columnAndType.getType())) + // .toArray(RelDataType[]::new)); }