本文整理了Java中org.apache.carbondata.core.scan.model.QueryModelBuilder.build
方法的一些代码示例,展示了QueryModelBuilder.build
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryModelBuilder.build
方法的具体详情如下:
包路径:org.apache.carbondata.core.scan.model.QueryModelBuilder
类名称:QueryModelBuilder
方法名: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-processing
builder.enableReadPageByPage();
queryModel = builder.build();
代码示例来源: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-hadoop
.filterExpression(getFilterPredicates(configuration))
.dataConverter(getDataTypeConverter(configuration))
.build();
内容来源于网络,如有侵权,请联系作者删除!