- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 548 for selects (0.19 sec)
-
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.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5K bytes - Viewed (0) -
internal/s3select/sql/parser.go
// Translate doubled quotes *qi = QuotedIdentifier(strings.ReplaceAll(r, `""`, `"`)) return nil } // Types representing AST of SQL statement. Only SELECT is supported. // Select is the top level AST node type type Select struct { Expression *SelectExpression `parser:"\"SELECT\" @@"` From *TableExpression `parser:"\"FROM\" @@"` Where *Expression `parser:"( \"WHERE\" @@ )?"`
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 12.9K bytes - Viewed (0) -
cmd/erasure.go
updateTime := 30*time.Second + time.Duration(float64(10*time.Second)*rand.Float64()) t := time.NewTicker(updateTime) defer t.Stop() defer saverWg.Done() var lastSave time.Time for { select { case <-t.C: if cache.Info.LastUpdate.Equal(lastSave) { continue } scannerLogOnceIf(ctx, cache.save(ctx, er, dataUsageCacheName), "nsscanner-cache-update") updates <- cache.clone()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 16.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/WebPlatformToAsciiTest.kt
/** Runs the web platform ToAscii tests. */ class WebPlatformToAsciiTest { @Suppress("ktlint:standard:max-line-length") val knownFailures = setOf( // OkHttp rejects empty labels. "x..xn--zca", "x..ß", // OkHttp rejects labels longer than 63 code points, the web platform tests don't. "x01234567890123456789012345678901234567890123456789012345678901x.xn--zca",Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
logger/slog_test.go
handler := slog.NewTextHandler(buf, &slog.HandlerOptions{AddSource: true}) logger := NewSlogLogger(slog.New(handler), Config{LogLevel: Info}) logger.Trace(context.Background(), time.Now(), func() (string, int64) { return "select count(*) from users", 0 }, nil) if strings.Contains(buf.String(), "gorm/logger/slog.go") { t.Error("Found internal slog.go reference in caller frame. Expected only test file references.") }
Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Thu Oct 30 10:56:26 UTC 2025 - 782 bytes - Viewed (0) -
internal/grid/stream.go
muxID uint64 ctx context.Context } // Send a payload to the remote server. func (s *Stream) Send(b []byte) error { if s.Requests == nil { return errors.New("stream does not accept requests") } select { case s.Requests <- b: return nil case <-s.ctx.Done(): return context.Cause(s.ctx) } } // Results returns the results from the remote server one by one.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
internal/bpool/bpool.go
bp.Put(buf[:bp.w]) } } // Get gets a []byte from the BytePool, or creates a new one if none are // available in the pool. func (bp *BytePoolCap) Get() (b []byte) { if bp == nil { return nil } select { case b = <-bp.c: // reuse existing buffer default: // create new aligned buffer b = reedsolomon.AllocAligned(1, bp.wcap)[0][:bp.w] } return b } // Put returns the given Buffer to the BytePool.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/rdma/RdmaProviderFactory.java
import jcifs.Configuration; import jcifs.internal.smb2.rdma.disni.DisniRdmaProvider; import jcifs.internal.smb2.rdma.tcp.TcpRdmaProvider; /** * Factory for creating RDMA provider instances. * * This factory attempts to select the best available RDMA provider * based on system capabilities and configuration preferences. */ public class RdmaProviderFactory { /** * Private constructor to prevent instantiation */Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sun Aug 24 00:12:28 UTC 2025 - 4.2K bytes - Viewed (0) -
cmd/peer-rest-client.go
} st.Results(func(b *grid.Bytes) error { select { case listenCh <- *b: default: // Do not block on slow receivers. b.Recycle() } return nil }) } // Listen - listen on peers. func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) { go func() { for { client.doListen(ctx, listenCh, v) select { case <-ctx.Done(): return
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 26.1K bytes - Viewed (0) -
misc/ios/clangwrap.sh
#!/bin/sh # This script configures clang to target the iOS simulator. If you'd like to # build for real iOS devices, change SDK to "iphoneos" and PLATFORM to "ios". # This uses the latest available iOS SDK, which is recommended. To select a # specific SDK, run 'xcodebuild -showsdks' to see the available SDKs and replace # iphonesimulator with one of them. SDK=iphonesimulator PLATFORM=ios-simulator if [ "$GOARCH" == "arm64" ]; then CLANGARCH="arm64"
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Jun 18 16:32:49 UTC 2024 - 724 bytes - Viewed (0)