- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 34 for Partition (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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 nonpositiveCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Nov 17 22:50:48 GMT 2025 - 43.6K bytes - Click Count (0) -
cmd/xl-storage-format-utils.go
fivs, err := getAllFileInfoVersions(xlMetaBuf, volume, path, true) if err != nil { return fivs, err } // If inclFreeVersions is false, partition the versions in fivs.Versions // such that finally fivs.Versions has // all the non-free versions and fivs.FreeVersions has all the free // versions. n := 0 for _, fi := range fivs.Versions {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 08 15:29:58 GMT 2024 - 5.5K bytes - Click Count (0) -
docs/smb3-features/06-witness-protocol-design.md
// Implementation would store registration details for recovery } } ``` ### 8.2 Network Partition Handling ```java public class WitnessNetworkPartitionHandler { public void handleNetworkPartition() { log.warn("Network partition detected - witness notifications may be delayed"); // Switch to more aggressive connection retryCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 16 02:53:50 GMT 2025 - 42K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/math/StatsTesting.java
checkArgument(partitionSize > 0); PairedStatsAccumulator accumulator = new PairedStatsAccumulator(); List<List<Double>> xPartitions = Lists.partition(xValues, partitionSize); List<List<Double>> yPartitions = Lists.partition(yValues, partitionSize); for (int index = 0; index < xPartitions.size(); index++) { accumulator.addAll(createPairedStatsOf(xPartitions.get(index), yPartitions.get(index)));
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 23.8K bytes - Click Count (0) -
android/guava/src/com/google/common/math/Quantiles.java
swap(array, min, from); } return; } // Let's play quickselect! We'll repeatedly partition the range [from, to] containing the // required element, as long as it has more than one element. while (to > from) { int partitionPoint = partition(array, from, to); if (partitionPoint >= required) { to = partitionPoint - 1; }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 30.1K bytes - Click Count (0) -
fastapi/security/http.py
data = b64decode(param).decode("ascii") except (ValueError, UnicodeDecodeError, binascii.Error) as e: raise self.make_not_authenticated_error() from e username, separator, password = data.partition(":") if not separator: raise self.make_not_authenticated_error() return HTTPBasicCredentials(username=username, password=password) class HTTPBearer(HTTPBase): """
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 13.2K bytes - Click Count (0) -
docs/bigdata/README.md
``` cat ${HADOOP_CONF_DIR}/core-site.xml | kv-pairify | grep "mapred" mapred.maxthreads.generate.mapoutput=2 # Num threads to write map outputs mapred.maxthreads.partition.closer=0 # Asynchronous map flushers mapreduce.fileoutputcommitter.algorithm.version=2 # Use the latest committer version mapreduce.job.reduce.slowstart.completedmaps=0.99 # 99% map, then reduceCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 14.7K bytes - Click Count (0) -
generics.go
} rnnColumn := clause.Column{Name: "gorm_preload_rnn"} sql := "ROW_NUMBER() OVER (PARTITION BY ? ?)" vars := []interface{}{partitionBy} if orderBy, ok := q.db.Statement.Clauses["ORDER BY"]; ok { vars = append(vars, orderBy) } else {Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Nov 02 14:09:18 GMT 2025 - 25.9K bytes - Click Count (0) -
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) -
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)