本文整理了Java中org.apache.carbondata.core.scan.model.QueryModelBuilder
类的一些代码示例,展示了QueryModelBuilder
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryModelBuilder
类的具体详情如下:
包路径:org.apache.carbondata.core.scan.model.QueryModelBuilder
类名称:QueryModelBuilder
暂无
代码示例来源:origin: org.apache.carbondata/carbondata-search
private QueryModel createQueryModel(CarbonTable table, SearchRequest request) {
String[] projectColumns = request.projectColumns();
Expression filter = null;
if (request.filterExpression() != null) {
filter = request.filterExpression();
}
return new QueryModelBuilder(table)
.projectColumns(projectColumns)
.filterExpression(filter)
.build();
}
代码示例来源:origin: org.apache.carbondata/carbondata-processing
public List<PartitionSpliterRawResultIterator> processDataBlocks(
String segmentId, DataTypeConverter converter, Configuration configuration)
throws QueryExecutionException, IOException {
List<TableBlockInfo> list = null;
queryModel = new QueryModelBuilder(carbonTable)
.projectAllColumns()
.dataConverter(converter)
.enableForcedDetailRawQuery()
.build();
List<PartitionSpliterRawResultIterator> resultList
= new ArrayList<>(CarbonCommonConstants.DEFAULT_COLLECTION_SIZE);
TaskBlockInfo taskBlockInfo = segmentMapping.get(segmentId);
Set<String> taskBlockListMapping = taskBlockInfo.getTaskSet();
for (String task : taskBlockListMapping) {
list = taskBlockInfo.getTableBlockInfoList(task);
LOGGER.info("for task -" + task + "-block size is -" + list.size());
queryModel.setTableBlockInfos(list);
resultList.add(new PartitionSpliterRawResultIterator(executeBlockList(list, configuration)));
}
return resultList;
}
}
代码示例来源:origin: org.apache.carbondata/carbondata-core
private List<CarbonDimension> mergeChildColumns(List<Integer> childOrdinals) {
// Check If children if they are in the path of not.
List<CarbonDimension> mergedChild = new ArrayList<>();
List<CarbonDimension> dimList = table.getDimensions();
for (int i = 0; i < childOrdinals.size(); i++) {
for (int j = i; j < childOrdinals.size(); j++) {
CarbonDimension parentDimension = getDimensionBasedOnOrdinal(dimList, childOrdinals.get(i));
CarbonDimension childDimension = getDimensionBasedOnOrdinal(dimList, childOrdinals.get(j));
if (!mergedChild.contains(childOrdinals.get(j)) && checkChildsInSamePath(parentDimension,
childDimension)) {
mergedChild.add(childDimension);
}
}
}
return mergedChild;
}
代码示例来源:origin: org.apache.carbondata/carbondata-core
private boolean checkChildsInSamePath(CarbonDimension parentDimension,
CarbonDimension childDimension) {
if (parentDimension.getColName().equals(childDimension.getColName())) {
return false;
} else if (checkForChildColumns(parentDimension, childDimension)) {
return true;
} else {
return false;
}
}
代码示例来源:origin: org.apache.carbondata/carbondata-core
private boolean checkForChildColumns(CarbonDimension parentDimension,
CarbonDimension childDimension) {
boolean output = false;
if (parentDimension.getOrdinal() == childDimension.getOrdinal()) {
output = true;
} else if (parentDimension.getNumberOfChild() > 0) {
for (int i = 0; i < parentDimension.getNumberOfChild() && !output; i++) {
output =
checkForChildColumns(parentDimension.getListOfChildDimensions().get(i), childDimension);
}
} else {
output = false;
}
return output;
}
代码示例来源:origin: org.apache.carbondata/carbondata-hadoop
projectColumns = new String[]{};
QueryModel queryModel = new QueryModelBuilder(carbonTable)
.projectColumns(projectColumns)
.filterExpression(getFilterPredicates(configuration))
.dataConverter(getDataTypeConverter(configuration))
.build();
代码示例来源:origin: org.apache.carbondata/carbondata-processing
new ArrayList<>(CarbonCommonConstants.DEFAULT_COLLECTION_SIZE);
List<TableBlockInfo> list = null;
QueryModelBuilder builder = new QueryModelBuilder(carbonTable)
.projectAllColumns()
.dataConverter(dataTypeConverter)
.enableForcedDetailRawQuery();
if (enablePageLevelReaderForCompaction()) {
builder.enableReadPageByPage();
queryModel = builder.build();
内容来源于网络,如有侵权,请联系作者删除!