Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for BytesProcessed (0.07 sec)

  1. docs/select/select.py

        elif 'Stats' in event:
            statsDetails = event['Stats']['Details']
            print("Stats details bytesScanned: ")
            print(statsDetails['BytesScanned'])
            print("Stats details bytesProcessed: ")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 18 00:11:39 UTC 2018
    - 1K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top