Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 291 for Record (0.3 sec)

  1. internal/s3select/json/record.go

    }
    
    // Reset the record.
    func (r *Record) Reset() {
    	if len(r.KVS) > 0 {
    		r.KVS = r.KVS[:0]
    	}
    }
    
    // Clone the record and if possible use the destination provided.
    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    		other = &Record{}
    	}
    	if len(other.KVS) > 0 {
    		other.KVS = other.KVS[:0]
    	}
    	other.KVS = append(other.KVS, r.KVS...)
    	return other
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 25 20:31:19 GMT 2022
    - 5.2K bytes
    - Viewed (0)
  2. internal/s3select/csv/record.go

    		r.csvRecord = r.csvRecord[:0]
    	}
    	for k := range r.nameIndexMap {
    		delete(r.nameIndexMap, k)
    	}
    }
    
    // Clone the record.
    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    		other = &Record{}
    	}
    	if len(other.columnNames) > 0 {
    		other.columnNames = other.columnNames[:0]
    	}
    	if len(other.csvRecord) > 0 {
    		other.csvRecord = other.csvRecord[:0]
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Sep 13 00:00:59 GMT 2022
    - 4.1K bytes
    - Viewed (0)
  3. internal/s3select/sql/record.go

    	QuoteEscape    rune
    	AlwaysQuote    bool
    }
    
    // Record - is a type containing columns and their values.
    type Record interface {
    	Get(name string) (*Value, error)
    
    	// Set a value.
    	// Can return a different record type.
    	Set(name string, value *Value) (Record, error)
    	WriteCSV(writer io.Writer, opts WriteCSVOpts) error
    	WriteJSON(writer io.Writer) error
    
    	// Clone the record and if possible use the destination provided.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 3.4K bytes
    - Viewed (0)
  4. internal/s3select/simdj/record.go

    }
    
    // Reset the record.
    func (r *Record) Reset() {
    	r.object = simdjson.Object{}
    }
    
    // Clone the record and if possible use the destination provided.
    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    		other = &Record{}
    	}
    	other.object = r.object
    	return other
    }
    
    // CloneTo clones the record to a json Record.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 5.4K bytes
    - Viewed (0)
  5. internal/s3select/json/preader_test.go

    		t.Run(file.Name(), func(t *testing.T) {
    			f, err := os.Open(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				t.Fatal(err)
    			}
    			r := NewPReader(f, &ReaderArgs{})
    			var record sql.Record
    			for {
    				record, err = r.Read(record)
    				if err != nil {
    					break
    				}
    			}
    			r.Close()
    			if err != io.EOF {
    				t.Fatalf("Reading failed with %s, %s", err, file.Name())
    			}
    		})
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 2.5K bytes
    - Viewed (0)
  6. docs/sts/ldap.md

    If the DNS SRV record is at an entirely different place, say `_ldapsrv._tcpish.myldapserver.com`, then set `srv_record_name` to the special value `on` and set `server_addr=_ldapsrv._tcpish.myldapserver.com`.
    
    When using this feature, do not specify a port in the `server_addr` as the port is picked up automatically from the SRV record.
    
    With the default (empty) value for `srv_record_name`, MinIO **will not** perform any SRV record request.
    
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.4K bytes
    - Viewed (1)
  7. internal/s3select/sql/evaluate.go

    // processed, and the `getAggregate` function is called.
    
    func (e *AliasedExpression) evalNode(r Record, tableAlias string) (*Value, error) {
    	return e.Expression.evalNode(r, tableAlias)
    }
    
    func (e *Expression) evalNode(r Record, tableAlias string) (*Value, error) {
    	if len(e.And) == 1 {
    		// In this case, result is not required to be boolean
    		// type.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Dec 23 07:19:11 GMT 2023
    - 12K bytes
    - Viewed (0)
  8. internal/s3select/simdj/reader.go

    	exitReader chan struct{}
    	readerWg   sync.WaitGroup
    }
    
    // Read - reads single record.
    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.decoded
    	if !ok {
    		if r.err != nil && *r.err != nil {
    			return nil, errJSONParsingError(*r.err)
    		}
    		return nil, io.EOF
    	}
    	dstRec, ok := dst.(*Record)
    	if !ok {
    		dstRec = &Record{}
    	}
    	dstRec.object = v
    	return dstRec, nil
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue May 30 17:02:22 GMT 2023
    - 4.9K bytes
    - Viewed (0)
  9. internal/config/dns/etcd_dns.go

    		records, err := c.list(key+etcdPathSeparator, true)
    		if err != nil {
    			return srvRecords, err
    		}
    		for _, record := range records {
    			if record.Key == "" {
    				continue
    			}
    			srvRecords[record.Key] = append(srvRecords[record.Key], record)
    		}
    	}
    	return srvRecords, nil
    }
    
    // Get - Retrieves DNS records for a bucket.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 8.3K bytes
    - Viewed (0)
  10. internal/s3select/sql/funceval.go

    	case e.DateDiff != nil:
    		return sqlFnDateDiff
    	default:
    		return ""
    	}
    }
    
    // evalSQLFnNode assumes that the FuncExpr is not an aggregation
    // function.
    func (e *FuncExpr) evalSQLFnNode(r Record, tableAlias string) (res *Value, err error) {
    	// Handle functions that have phrase arguments
    	switch e.getFunctionName() {
    	case sqlFnCast:
    		expr := e.Cast.Expr
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 13.2K bytes
    - Viewed (0)
Back to top