Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 107 for Collector (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/metrics-v3.go

    		}
    	}
    
    	// Prepare to register the collectors. Other than `MetricGroup` collectors,
    	// we also have standard collectors like `GoCollector`.
    
    	// Create all Non-`MetricGroup` collectors here.
    	collectors := map[collectorPath]prometheus.Collector{
    		debugGoCollectorPath: collectors.NewGoCollector(),
    	}
    
    	// Add all `MetricGroup` collectors to the map.
    	for _, mg := range allMetricGroups {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 02 00:55:27 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  2. compat/maven-model-builder/src/test/java/org/apache/maven/model/interpolation/AbstractModelInterpolatorTest.java

            context.put("project.baseUri", "myBaseUri");
        }
    
        protected void assertProblemFree(SimpleProblemCollector collector) {
            assertEquals(0, collector.getErrors().size(), "Expected no errors");
            assertEquals(0, collector.getWarnings().size(), "Expected no warnings");
            assertEquals(0, collector.getFatals().size(), "Expected no fatals");
        }
    
        @SuppressWarnings("SameParameterValue")
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Sun Mar 30 23:08:36 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  3. guava/src/com/google/common/collect/CollectCollectors.java

      static <E> Collector<E, ?, ImmutableSet<E>> toImmutableSet() {
        return (Collector) TO_IMMUTABLE_SET;
      }
    
      static <E> Collector<E, ?, ImmutableSortedSet<E>> toImmutableSortedSet(
          Comparator<? super E> comparator) {
        checkNotNull(comparator);
        return Collector.of(
            () -> new ImmutableSortedSet.Builder<E>(comparator),
            ImmutableSortedSet.Builder::add,
            ImmutableSortedSet.Builder::combine,
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  4. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

         */
        @Nonnull
        Stream<P> problems(BuilderProblem.Severity severity);
    
        /**
         * Creates an "empty" problem collector that doesn't store any problems.
         *
         * @param <P> the type of problem
         * @return an empty problem collector
         */
        @Nonnull
        static <P extends BuilderProblem> ProblemCollector<P> empty() {
            return new ProblemCollector<>() {
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jul 18 17:30:19 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  5. impl/maven-core/src/test/java/org/apache/maven/graph/DefaultGraphBuilderTest.java

    import org.apache.maven.project.ProjectBuildingResult;
    import org.apache.maven.project.collector.DefaultProjectsSelector;
    import org.apache.maven.project.collector.MultiModuleCollectionStrategy;
    import org.apache.maven.project.collector.PomlessCollectionStrategy;
    import org.apache.maven.project.collector.ProjectsSelector;
    import org.apache.maven.project.collector.RequestPomCollectionStrategy;
    import org.junit.jupiter.api.BeforeEach;
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Dec 09 20:39:03 GMT 2025
    - 28K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/Comparators.java

        checkNonnegative(k, "k");
        checkNotNull(comparator);
        return Collector.of(
            () -> TopKSelector.<T>least(k, comparator),
            TopKSelector::offer,
            TopKSelector::combine,
            TopKSelector::topK,
            Collector.Characteristics.UNORDERED);
      }
    
      /**
       * Returns a {@code Collector} that returns the {@code k} greatest (relative to the specified
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 10.9K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb1/http/NtlmHttpURLConnection.java

            private final OutputStream collector;
    
            public CacheStream(final OutputStream stream, final OutputStream collector) {
                this.stream = stream;
                this.collector = collector;
            }
    
            @Override
            public void close() throws IOException {
                stream.close();
                collector.close();
            }
    
            @Override
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  8. cmd/metrics-v3-types.go

    // to collect the metrics.
    //
    // It implements the prometheus.Collector interface for metric groups without a
    // bucket dimension. For metric groups with a bucket dimension, use the
    // `GetBucketCollector` method to get a `BucketCollector` that implements the
    // prometheus.Collector interface.
    type MetricsGroup struct {
    	// Path (relative to the Metrics v3 base endpoint) at which this group of
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Feb 28 19:33:08 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  9. guava/src/com/google/common/collect/ImmutableTable.java

        implements Serializable {
    
      /**
       * Returns a {@code Collector} that accumulates elements into an {@code ImmutableTable}. Each
       * input element is mapped to one cell in the returned table, with the rows, columns, and values
       * generated by applying the specified functions.
       *
       * <p>The returned {@code Collector} will throw a {@code NullPointerException} at collection time
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 17.3K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

        return max(10L, Runtime.getRuntime().totalMemory() / (32L * 1024L * 1024L));
      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/260137033
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Mar 17 20:26:29 GMT 2025
    - 11.5K bytes
    - Click Count (0)
Back to Top