database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Feature](partitions) Support auto-partition (#24153)

Browse Source 
Co-authored-by: zhangstar333 <2561612514@qq.com>
This commit is contained in:
zclllyybb
2023-09-12 15:23:15 +08:00
committed by GitHub
parent 4bb9a12038
commit d3f1388717
29 changed files with 1631 additions and 566 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/planner/OlapTableSink.java
View File

@ -346,10 +346,11 @@ public class OlapTableSink extends DataSink {
}
ArrayList<Expr> exprs = partitionInfo.getPartitionExprs();
if (exprs != null && analyzer != null) {
Analyzer funcAnalyzer = new Analyzer(analyzer.getEnv(), analyzer.getContext());
tupleDescriptor.setTable(table);
analyzer.registerTupleDescriptor(tupleDescriptor);
funcAnalyzer.registerTupleDescriptor(tupleDescriptor);
for (Expr e : exprs) {
e.analyze(analyzer);
e.analyze(funcAnalyzer);
}
partitionParam.setPartitionFunctionExprs(Expr.treesToThrift(exprs));
}