- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 1,013 for stored (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/bigdata/README.md
mapreduce.task.sort.spill.percent=0.9 # Minimum % before spilling to disk ```
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 14.7K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
if (url != null) { return url; } return id; } } /** * Statistics data object that stores timestamped events and maintains reference counting. * Extends LinkedHashMap to store event names mapped to their timestamps. * Includes reference counting for multi-threaded access tracking. */
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Aug 07 03:06:29 GMT 2025 - 17.4K bytes - Click Count (0) -
src/test/java/jcifs/smb/SmbFileIntegrationTest.java
.withCopyFileToContainer(MountableFile.forHostPath(tempDir.resolve("shared")), "/share/shared") .withCommand("-u", USERNAME + ";" + PASSWORD, "-s", "public;/share/public;yes;no;yes;all;;all;all", "-s", "shared;/share/shared;no;no;no;all;" + USERNAME + ";all;all", "-g", "log level = 1", "-g",
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 56K bytes - Click Count (0) -
internal/event/target/elasticsearch.go
func (target *ElasticsearchTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set. func (target *ElasticsearchTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *ElasticsearchTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15K bytes - Click Count (0) -
internal/store/queuestore_test.go
func TestQueueStorePut(t *testing.T) { defer func() { if err := tearDownQueueStore(); err != nil { t.Fatal("Failed to tear down store ", err) } }() store, err := setUpQueueStore(queueDir, 100) if err != nil { t.Fatal("Failed to create a queue store ", err) } // Put 100 items. for range 100 { if _, err := store.Put(testItem); err != nil { t.Fatal("Failed to put to queue store ", err) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 10.2K bytes - Click Count (0) -
cmd/storage-datatypes.go
// TransitionTier is the storage class label assigned to remote tier. TransitionTier string `msg:"tt"` // TransitionVersionID stores a version ID of the object associate // with the remote tier. TransitionVersionID string `msg:"tv"` // ExpireRestored indicates that the restored object is to be expired. ExpireRestored bool `msg:"exp"` // DataDir of the file DataDir string `msg:"dd"`
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.4K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/ds/DataStoreTest.java
params.put("key1", "value1"); params.put("key2", "value2"); IndexUpdateCallback callback = new TestIndexUpdateCallback(); // Execute store method dataStore.store(config, callback, params); // Verify store was called assertTrue(storeCalled.get()); assertNotNull(capturedConfig.get()); assertEquals("test-config", capturedConfig.get().getName());
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 13.2K bytes - Click Count (0) -
internal/store/batch_test.go
if err := tearDownQueueStore(); err != nil { t.Fatalf("Failed to tear down store; %v", err) } }() store, err := setUpQueueStore(queueDir, 100) if err != nil { t.Fatalf("Failed to create a queue store; %v", err) } var limit uint32 = 100 batch := NewBatch[TestItem](BatchConfig[TestItem]{ Limit: limit, Store: store, CommitTimeout: 5 * time.Minute,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.6K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
queueStore := store.NewQueueStore[any](queueDir, uint64(h.kconfig.QueueSize), kafkaLoggerExtension) if err = queueStore.Open(); err != nil { return fmt.Errorf("unable to initialize the queue store of %s webhook: %w", h.Name(), err) } ctx, cancel := context.WithCancel(ctx) h.store = queueStore h.storeCtxCancel = cancel store.StreamItems(h.store, h, ctx.Done(), h.kconfig.LogOnce) return err }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
internal/event/target/kafka.go
if target.store != nil { if args.BatchSize > 1 { target.batch = store.NewBatch[event.Event](store.BatchConfig[event.Event]{ Limit: args.BatchSize, Log: loggerOnce, Store: queueStore, CommitTimeout: args.BatchCommitTimeout, }) } store.StreamItems(target.store, target, target.quitCh, target.loggerOnce) } return target, nil }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 13.6K bytes - Click Count (0)