- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for AggregateRow (0.13 sec)
-
internal/s3select/sql/aggregation.go
} func (e *AliasedExpression) aggregateRow(r Record, tableAlias string) error { return e.Expression.aggregateRow(r, tableAlias) } func (e *Expression) aggregateRow(r Record, tableAlias string) error { for _, ex := range e.And { err := ex.aggregateRow(r, tableAlias) if err != nil { return err } } return nil } func (e *ListExpr) aggregateRow(r Record, tableAlias string) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat Dec 23 07:19:11 UTC 2023 - 7.9K bytes - Viewed (0) -
internal/s3select/sql/statement.go
} return b, nil } // AggregateRow - aggregates the input record. Applies only to // aggregation queries. func (e *SelectStatement) AggregateRow(input Record) error { ok, err := e.isPassingWhereClause(input) if err != nil { return err } if !ok { return nil } for _, expr := range e.selectAST.Expression.Expressions { err := expr.aggregateRow(input, e.tableAlias) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 8.9K bytes - Viewed (0) -
internal/s3select/select.go
break } for _, inputRecord := range inputRecords { if s3Select.statement.IsAggregated() { if err = s3Select.statement.AggregateRow(*inputRecord); err != nil { break OuterLoop } } else { var outputRecord sql.Record // We will attempt to reuse the records in the table. // The type of these should not change.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 21.2K bytes - Viewed (0)