- Sort Score
- Result 10 results
- Languages All
Results 1351 - 1360 of 2,109 for collect (0.15 sec)
-
cmd/metacache-set.go
return true } if o.Lifecycle != nil || o.Replication.Config != nil { return triggerExpiryAndRepl(ctx, *o, entry) } return false } // gatherResults will collect all results on the input channel and filter results according // to the options or to the current bucket ILM expiry rules. // Caller should close the channel when done.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.7K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Iterators.java
* limitations under the License. */ package com.google.common.collect; import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.base.Preconditions.checkState; import static com.google.common.base.Predicates.instanceOf; import static com.google.common.collect.CollectPreconditions.checkRemove;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 50.5K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Table.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.collect; import com.google.common.annotations.GwtCompatible; import com.google.errorprone.annotations.CanIgnoreReturnValue; import com.google.errorprone.annotations.CompatibleWith; import com.google.errorprone.annotations.DoNotMock;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 10.5K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java
insertAll(targetList.stream() .filter(urlQueue -> StringUtil.isNotBlank(urlQueue.getSessionId()) && StringUtil.isNotBlank(urlQueue.getUrl())) .collect(Collectors.toList()), OpType.CREATE, true); if (logger.isDebugEnabled()) { logger.debug("Offered URL: Session ID: {}, UrlQueue: {}", sessionId, targetList); } } }
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Aug 07 02:55:08 UTC 2025 - 17K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Sets.java
* See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.collect; import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Preconditions.checkNotNull; import static com.google.common.collect.CollectPreconditions.checkNonnegative; import static com.google.common.math.IntMath.saturatedAdd; import static java.lang.Math.max;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 81.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheExpirationTest.java
import com.google.common.cache.TestingRemovalListeners.CountingRemovalListener; import com.google.common.cache.TestingRemovalListeners.QueuingRemovalListener; import com.google.common.collect.Iterators; import com.google.common.testing.FakeTicker; import com.google.common.util.concurrent.Callables; import java.util.List; import java.util.Set; import java.util.concurrent.ExecutionException;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 18.7K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
} return result; } // After the collection we will have the artifact object in the result but they will not be resolved yet. result = artifactCollector.collect( artifacts, rootArtifact, managedVersions, collectionRequest, source, collectionFilter, listeners, null); // We have metadata retrieval problems, or there are cycles that have been detected
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 25K bytes - Viewed (0) -
cmd/data-usage-cache.go
// Appears to be printed with _MINIO_SERVER_DEBUG=off // console.Debugf(" %d children found, compacting %v\n", total, path) leaves := make([]struct { objects uint64 path dataUsageHash }, total) // Collect current leaves that have children. leaves = leaves[:0] remove := total - limit var add func(path dataUsageHash) add = func(path dataUsageHash) { e, ok := d.Cache[path.Key()] if !ok { return }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/exentity/DataConfig.java
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 18.6K bytes - Viewed (0) -
api/maven-api-model/src/main/mdo/maven.mdo
* @see java.lang.Object#toString() */ public String toString() { return "PatternSet [" + "includes: {" + getIncludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}, " + "excludes: {" + getExcludes().stream().collect(java.util.stream.Collectors.joining(", ")) + "}]"; } ]]> </code> </codeSegment> </codeSegments> </class>
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Thu Aug 07 14:32:16 UTC 2025 - 132.7K bytes - Viewed (0)