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

change code style (#4776)

Browse Source
This commit is contained in:
Zhengguo Yang
2020-10-24 17:36:06 +08:00
committed by GitHub
parent 0213e93ea1
commit 2fa3ffda7b
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
fe/fe-core/src/main/java/org/apache/doris/planner/OlapScanNode.java
View File

@ -280,15 +280,8 @@ public class OlapScanNode extends ScanNode {
@Override
public void init(Analyzer analyzer) throws UserException {
super.init(analyzer);
if (!Util.showHiddenColumns() && olapTable.hasDeleteSign()) {
SlotRef deleteSignSlot = new SlotRef(desc.getAliasAsName(), Column.DELETE_SIGN);
deleteSignSlot.analyze(analyzer);
deleteSignSlot.getDesc().setIsMaterialized(true);
Expr conjunct = new BinaryPredicate(BinaryPredicate.Operator.EQ, deleteSignSlot, new IntLiteral(0));
conjunct.analyze(analyzer);
conjuncts.add(conjunct);
}
filterDeletedRows(analyzer);
computePartitionInfo();
}
@ -764,4 +757,15 @@ public class OlapScanNode extends ScanNode {
}
return expr instanceof SlotRef;
}
private void filterDeletedRows(Analyzer analyzer) throws AnalysisException{
if (!Util.showHiddenColumns() && olapTable.hasDeleteSign()) {
SlotRef deleteSignSlot = new SlotRef(desc.getAliasAsName(), Column.DELETE_SIGN);
deleteSignSlot.analyze(analyzer);
deleteSignSlot.getDesc().setIsMaterialized(true);
Expr conjunct = new BinaryPredicate(BinaryPredicate.Operator.EQ, deleteSignSlot, new IntLiteral(0));
conjunct.analyze(analyzer);
conjuncts.add(conjunct);
}
}
}