Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getProgressFunc (0.25 sec)

  1. internal/s3select/message.go

    }
    
    // newMessageWriter creates a message writer that writes to the HTTP
    // response writer
    func newMessageWriter(w http.ResponseWriter, getProgressFunc func() (bytesScanned, bytesProcessed int64)) *messageWriter {
    	writer := &messageWriter{
    		writer:          w,
    		getProgressFunc: getProgressFunc,
    
    		payloadBuffer: make([]byte, bufLength),
    		payloadCh:     make(chan *bytes.Buffer, 1),
    
    		errCh:  make(chan []byte),
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  2. internal/s3select/select.go

    func (s3Select *S3Select) Evaluate(w http.ResponseWriter) {
    	getProgressFunc := s3Select.getProgress
    	if !s3Select.Progress.Enabled {
    		getProgressFunc = nil
    	}
    	writer := newMessageWriter(w, getProgressFunc)
    
    	var outputQueue []sql.Record
    
    	// Create queue based on the type.
    	if s3Select.statement.IsAggregated() {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
Back to top