Skip to content

Commit 2964879

Browse files
committed
parse nested columns
1 parent 377e479 commit 2964879

File tree

5 files changed

+200
-100
lines changed

5 files changed

+200
-100
lines changed

engine/engine.go

+2
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,8 @@ func (p *ParquetEngine) executeSelect(stmt *parser.Select) (*RecordSet, error) {
9595
break
9696
case *parser.ColExpr:
9797
cols = append(cols, field.(*parser.ColExpr).Name)
98+
case *parser.NestColExpr:
99+
fmt.Println(field.(*parser.NestColExpr).Subs)
98100
}
99101
}
100102
filterCols := make([]string, 0)

parser/ast.go

+3
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,9 @@ type (
3434
}
3535
StarExpr struct {
3636
}
37+
NestColExpr struct {
38+
Subs []string
39+
}
3740
FuncExpr struct {
3841
Name string
3942
Fields SelectFieldList

0 commit comments

Comments
 (0)