Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 27 for partitions (0.06 seconds)

  1. guava-tests/test/com/google/common/collect/IteratorsTest.java

        Iterator<List<Integer>> partitions = Iterators.partition(source, 1);
        assertTrue(partitions.hasNext());
        assertTrue(partitions.hasNext());
        assertEquals(ImmutableList.of(1), partitions.next());
        assertFalse(partitions.hasNext());
      }
    
      public void testPartition_singleton2() {
        Iterator<Integer> source = singletonIterator(1);
        Iterator<List<Integer>> partitions = Iterators.partition(source, 2);
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:44:53 GMT 2025
    - 56.7K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/collect/IterablesTest.java

        assertEquals(1, Iterables.size(partitions));
        assertEquals(singletonList(1), partitions.iterator().next());
      }
    
      public void testPartition_view() {
        List<Integer> list = asList(1, 2);
        Iterable<List<Integer>> partitions = Iterables.partition(list, 2);
    
        // Changes before the partition is retrieved are reflected
        list.set(0, 3);
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Oct 28 18:44:53 GMT 2025
    - 45.6K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/collect/Iterables.java

       * <p><b>Note:</b> if {@code iterable} is a {@link List}, use {@link Lists#partition(List, int)}
       * instead.
       *
       * @param iterable the iterable to return a partitioned view of
       * @param size the desired size of each partition (the last may be smaller)
       * @return an iterable of unmodifiable lists containing the elements of {@code iterable} divided
       *     into partitions
       * @throws IllegalArgumentException if {@code size} is nonpositive
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 16 18:35:28 GMT 2025
    - 43.8K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/TopKSelector.java

          }
        }
      }
    
      /**
       * Partitions the contents of buffer in the range [left, right] around the pivot element
       * previously stored in buffer[pivotValue]. Returns the new index of the pivot element,
       * pivotNewIndex, so that everything in [left, pivotNewIndex] is ≤ pivotValue and everything in
       * (pivotNewIndex, right] is greater than pivotValue.
       */
      private int partition(int left, int right, int pivotIndex) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Aug 31 13:15:26 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  5. cmd/admin-handlers.go

    			anonymizeAddr(&localPartitions)
    			healthInfo.Sys.Partitions = append(healthInfo.Sys.Partitions, localPartitions)
    
    			peerPartitions := globalNotificationSys.GetPartitions(healthCtx)
    			for _, p := range peerPartitions {
    				anonymizeAddr(&p)
    				healthInfo.Sys.Partitions = append(healthInfo.Sys.Partitions, p)
    			}
    			partialWrite(healthInfo)
    		}
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  6. cmd/peer-rest-server.go

    	info := madmin.GetNetInfo(globalLocalNodeName, globalInternodeInterface)
    	return madminNetInfo.NewJSONWith(&info), nil
    }
    
    // GetPartitionsHandler - returns disk partition information.
    func (s *peerRESTServer) GetPartitionsHandler(_ *grid.MSS) (*grid.JSON[madmin.Partitions], *grid.RemoteErr) {
    	info := madmin.GetPartitions(context.Background(), globalLocalNodeName)
    	return madminPartitions.NewJSONWith(&info), nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  7. guava/src/com/google/common/collect/Iterables.java

       * <p><b>Note:</b> if {@code iterable} is a {@link List}, use {@link Lists#partition(List, int)}
       * instead.
       *
       * @param iterable the iterable to return a partitioned view of
       * @param size the desired size of each partition (the last may be smaller)
       * @return an iterable of unmodifiable lists containing the elements of {@code iterable} divided
       *     into partitions
       * @throws IllegalArgumentException if {@code size} is nonpositive
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 43.6K bytes
    - Click Count (0)
  8. guava/src/com/google/common/collect/Iterators.java

       * OutOfMemoryError}.
       *
       * @param iterator the iterator to return a partitioned view of
       * @param size the desired size of each partition (the last may be smaller)
       * @return an iterator of immutable lists containing the elements of {@code iterator} divided into
       *     partitions
       * @throws IllegalArgumentException if {@code size} is nonpositive
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 16 12:42:11 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  9. cmd/notification.go

    		if err != nil {
    			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
    		}
    	}
    	return reply
    }
    
    // GetPartitions - Disk partition information
    func (sys *NotificationSys) GetPartitions(ctx context.Context) []madmin.Partitions {
    	reply := make([]madmin.Partitions, len(sys.peerClients))
    
    	g := errgroup.WithNErrs(len(sys.peerClients))
    	for index, client := range sys.peerClients {
    		if client == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  10. cmd/peer-rest-client.go

    	resp, err := getNetInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    // GetPartitions - fetch disk partition information for a remote node.
    func (client *peerRESTClient) GetPartitions(ctx context.Context) (info madmin.Partitions, err error) {
    	resp, err := getPartitionsRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
Back to Top