Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -201,6 +201,7 @@ public String debugString() {

@Override
protected void toThrift(TExprNode msg) {
throw new RuntimeException("AnalyticExpr should be rewritten");
}

public static boolean isAnalyticFn(Function fn) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ protected String toSqlImpl() {

@Override
protected void toThrift(TExprNode msg) {

throw new RuntimeException("DefaultValueExpr should be rewritten");
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ protected String toSqlImpl() {

@Override
protected void toThrift(TExprNode msg) {
// no operation
throw new RuntimeException("EncryptKeyRef should be rewritten");
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ public Expr negate() {
@Override
protected void toThrift(TExprNode msg) {
// Cannot serialize a nested predicate
Preconditions.checkState(false);
throw new RuntimeException("ExistsPredicate should be rewritten");
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,6 +50,7 @@ public int compareLiteral(LiteralExpr expr) {

@Override
protected void toThrift(TExprNode msg) {
throw new RuntimeException("MaxLiteral should be rewritten");
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -220,5 +220,7 @@ public Expr reset() {
}

@Override
protected void toThrift(TExprNode msg) {}
protected void toThrift(TExprNode msg) {
throw new RuntimeException("Subquery should be rewritten");
}
}