Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1351 - 1360 of 2,109 for collect (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. src/main/java/org/codelibs/fess/opensearch/config/exentity/DataConfig.java

                final Map<String, String> parameterMap = paramMap.entrySet()
                        .stream()
                        .filter(e -> e.getKey().startsWith(prefix))
                        .collect(Collectors.toMap(e -> e.getKey().substring(prefix.length()), Entry::getValue));
                authScheme = new FormScheme(parameterMap);
            }
            return authScheme;
        }
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 18.6K bytes
    - Viewed (0)
  10. 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)
Back to top