- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 208 for Select (0.2 sec)
-
docs/select/select.py
aws_access_key_id='minio', aws_secret_access_key='minio123', region_name='us-east-1') r = s3.select_object_content( Bucket='mycsvbucket', Key='sampledata/TotalPopulation.csv.gz', ExpressionType='SQL', Expression="select * from s3object s where s.Location like '%United States%'", InputSerialization={ 'CSV': { "FileHeaderInfo": "USE", },
Python - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Aug 18 00:11:39 GMT 2018 - 1K bytes - Viewed (0) -
internal/s3select/select.go
s2Type CompressionType = "S2" snappyType CompressionType = "SNAPPY" ) const ( maxRecordSize = 1 << 20 // 1 MiB ) var parquetSupport bool func init() { parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn } var bufPool = sync.Pool{ New: func() interface{} { // make a buffer with a reasonable capacity. return bytes.NewBuffer(make([]byte, 0, maxRecordSize)) }, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
internal/s3select/select_test.go
mango`, }, { name: "Select column simplest", query: `select qty from S3Object`, wantResult: `1 3`, }, { name: "Select column with table name prefix", query: `select S3Object.qty from S3Object`, wantResult: `1 3`, }, { name: "Select column without table alias", query: `select qty from S3Object s`, wantResult: `1 3`, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 76.2K bytes - Viewed (0) -
internal/s3select/select_benchmark_test.go
func BenchmarkSelectAll_10M(b *testing.B) { benchmarkSelectAll(b, 10*humanize.MiByte) } func benchmarkSingleCol(b *testing.B, count int) { benchmarkSelect(b, count, "select id from S3Object") } // BenchmarkSingleRow_100K - benchmark SELECT column function with 100k records. func BenchmarkSingleCol_100K(b *testing.B) { benchmarkSingleCol(b, 1e5) } // BenchmarkSelectAll_1M - benchmark * function with 1m records.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 14 13:54:47 GMT 2022 - 5K bytes - Viewed (0) -
internal/s3select/sql/parser_test.go
p := participle.MustBuild( &Select{}, participle.Lexer(sqlLexer), participle.CaseInsensitive("Keyword"), ) s := Select{} cases := []string{ "select * from s3object", "select a, b from s3object s", "select a, b from s3object as s", "select a, b from s3object as s where a = 1", "select a, b from s3object s where a = 1", "select a, b from s3object where a = 1", }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/mrf.go
if m == nil { return } select { case m.opCh <- op: default: } } var healSleeper = newDynamicSleeper(5, time.Second, false) // healRoutine listens to new disks reconnection events and // issues healing requests for queued objects belonging to the // corresponding erasure set func (m *mrfState) healRoutine(z *erasureServerPools) { for { select { case <-GlobalContext.Done(): return
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/iam.go
return nil, errServerNotInitialized } select { case <-sys.configLoaded: return sys.store.GetBucketUsers(bucket) case <-ctx.Done(): return nil, ctx.Err() } } // ListUsers - list all users. func (sys *IAMSys) ListUsers(ctx context.Context) (map[string]madmin.UserInfo, error) { if !sys.Initialized() { return nil, errServerNotInitialized } select { case <-sys.configLoaded:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
internal/s3select/message.go
progressTickerC = progressTicker.C } recordStagingTicker := time.NewTicker(500 * time.Millisecond) // Exit conditions: // // 1. If a writer.write() returns false, select loop below exits and // closes `doneCh` to indicate to caller to also exit. // // 2. If caller (Evaluate()) has an error, it sends an error // message and waits for this go-routine to quit in // FinishWithError()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
buildscripts/minio-iam-ldap-upgrade-import-test.sh
groups=$(echo "$output" | jq -r '.result.policyMappings[] | select(.policy == "readwrite") | .groups[]') if [ "$groups" != "cn=project.c,ou=groups,ou=swengg,dc=min,dc=io" ]; then echo "Failed to verify groups: $groups" exit 1 fi users=$(echo "$output" | jq -r '.result.policyMappings[] | select(.policy == "readwrite") | .users[]')
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:49:53 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
go func() { buf := bytes.NewBuffer(grid.GetByteBuffer()[:0]) enc := json.NewEncoder(buf) tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}} for { select { case ev := <-localCh: buf.Reset() tmpEvt.Records[0] = ev if err := enc.Encode(tmpEvt); err != nil { bugLogIf(ctx, err, "event: Encode failed") continue }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0)