- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for BytesProcessed (0.08 sec)
-
internal/s3select/message.go
// <BytesProcessed>1024</BytesProcessed> // <BytesReturned>1024</BytesReturned> // // </Progress> func newProgressMessage(bytesScanned, bytesProcessed, bytesReturned int64) []byte { payload := []byte(`<?xml version="1.0" encoding="UTF-8"?><Progress><BytesScanned>` + strconv.FormatInt(bytesScanned, 10) + `</BytesScanned><BytesProcessed>` + strconv.FormatInt(bytesProcessed, 10) + `</BytesProcessed><BytesReturned>` +
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 15.2K bytes - Viewed (0) -
docs/select/README.md
elif 'Stats' in event: statsDetails = event['Stats']['Details'] print("Stats details bytesScanned: ") print(statsDetails['BytesScanned']) print("Stats details bytesProcessed: ") print(statsDetails['BytesProcessed']) ``` ## 4. Run the Program Upload a sample dataset to MinIO using the following commands. ```sh
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 6.5K bytes - Viewed (0) -
internal/s3select/progress.go
defer pr.closedMu.Unlock() if pr.closed { return nil } pr.closed = true if pr.closer != nil { pr.closer.Close() } return pr.rc.Close() } func (pr *progressReader) Stats() (bytesScanned, bytesProcessed int64) { if pr == nil { return 0, 0 } return pr.scannedReader.BytesRead(), pr.processedReader.BytesRead() } func newProgressReader(rc io.ReadCloser, compType CompressionType) (*progressReader, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 4.3K bytes - Viewed (0) -
internal/s3select/select.go
case jsonFormat: return json.NewRecord(sql.SelectFmtJSON) } panic(fmt.Errorf("unknown output format '%v'", s3Select.Output.format)) } func (s3Select *S3Select) getProgress() (bytesScanned, bytesProcessed int64) { if s3Select.progressReader != nil { return s3Select.progressReader.Stats() } return -1, -1 } // Open - opens S3 object by using callback for SQL selection query.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 21.2K bytes - Viewed (0)