Github user chenliang613 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2265#discussion_r196773919
--- Diff:
integration/presto/src/main/java/org/apache/carbondata/presto/CarbondataPageSourceProvider.java
---
@@ -129,23 +135,31 @@ private QueryModel createQueryModel(CarbondataSplit
carbondataSplit,
String carbonTablePath =
carbonTable.getAbsoluteTableIdentifier().getTablePath();
conf.set(CarbonTableInputFormat.INPUT_DIR, carbonTablePath);
+ conf.set("query.id", queryId);
JobConf jobConf = new JobConf(conf);
CarbonTableInputFormat carbonTableInputFormat =
createInputFormat(jobConf, carbonTable,
PrestoFilterUtil.parseFilterExpression(carbondataSplit.getConstraints()),
carbonProjection);
TaskAttemptContextImpl hadoopAttemptContext =
new TaskAttemptContextImpl(jobConf, new TaskAttemptID("", 1,
TaskType.MAP, 0, 0));
- CarbonInputSplit carbonInputSplit =
-
CarbonLocalInputSplit.convertSplit(carbondataSplit.getLocalInputSplit());
+ CarbonMultiBlockSplit carbonInputSplit =
+
CarbonLocalMultiBlockSplit.convertSplit(carbondataSplit.getLocalInputSplit());
QueryModel queryModel =
carbonTableInputFormat.createQueryModel(carbonInputSplit,
hadoopAttemptContext);
+ queryModel.setQueryId(queryId);
queryModel.setVectorReader(true);
+ queryModel.setStatisticsRecorder(
+
CarbonTimeStatisticsFactory.createExecutorRecorder(queryModel.getQueryId()));
+ /*
List<CarbonInputSplit> splitList = new ArrayList<>(1);
- splitList.add(carbonInputSplit);
- List<TableBlockInfo> tableBlockInfoList =
CarbonInputSplit.createBlocks(splitList);
--- End diff --
please remove these dummy code.
---
