- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for SendRecord (0.28 sec)
-
internal/s3select/select.go
return false } } if err = writer.SendRecord(buf); err != nil { // FIXME: log this error. 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 }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
internal/s3select/message.go
for len(writer.payloadCh) > 0 { payload := <-writer.payloadCh bufPool.Put(payload) } } // Sends a single whole record. func (writer *messageWriter) SendRecord(payload *bytes.Buffer) error { select { case writer.payloadCh <- payload: return nil case <-writer.doneCh: return fmt.Errorf("messageWriter is done") } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0)