- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for LimitReached (0.21 sec)
-
internal/s3select/sql/statement.go
return nil, err } } // Update count of records output. e.outputCount++ return output, nil } // LimitReached - returns true if the number of records output has // reached the value of the `LIMIT` clause. func (e *SelectStatement) LimitReached() bool { if e.limitValue == -1 { return false } return e.outputCount >= e.limitValue
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 09 17:19:11 UTC 2024 - 8.9K bytes - Viewed (0) -
internal/s3select/select.go
err = nil bufPool.Put(buf) return false } outputQueue = outputQueue[:0] return true } var rec sql.Record OuterLoop: for { if s3Select.statement.LimitReached() { if !sendRecord() { break } if err = writer.Finish(s3Select.getProgress()); err != nil { // FIXME: log this error. err = nil } break }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 21K bytes - Viewed (0)