Searched refs:assignedMaps (Results 1 – 11 of 11) sorted by relevance
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/appmaster/ |
H A D | MRAMSimulator.java | 80 private Map<ContainerId, ContainerSimulator> assignedMaps = field in MRAMSimulator 219 if (assignedMaps.containsKey(containerId)) { in processResponseQueue() 222 assignedMaps.remove(containerId); in processResponseQueue() 239 if (assignedMaps.containsKey(containerId)) { in processResponseQueue() 242 pendingFailedMaps.add(assignedMaps.remove(containerId)); in processResponseQueue() 276 assignedMaps.put(container.getId(), cs); in processResponseQueue() 401 assignedMaps.clear(); in lastStep()
|
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
H A D | JobQueueTaskScheduler.java | 212 int assignedMaps = assignedTasks.size(); in assignTasks() local 258 assignedMaps + " (" + numLocalMaps + ", " + numNonLocalMaps + in assignTasks() 262 ", " + (assignedTasks.size()-assignedMaps) + "]"); in assignTasks()
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/opencontainers/runc/vendor/github.com/cilium/ebpf/ |
H A D | collection.go | 375 assignedMaps := make(map[string]struct{}) 391 assignedMaps[name] = struct{}{} 406 for name := range assignedMaps {
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/vendor/github.com/cilium/ebpf/ |
H A D | collection.go | 375 assignedMaps := make(map[string]struct{}) 391 assignedMaps[name] = struct{}{} 406 for name := range assignedMaps {
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/cilium/ebpf/ |
H A D | collection.go | 375 assignedMaps := make(map[string]struct{}) 391 assignedMaps[name] = struct{}{} 406 for name := range assignedMaps {
|
/dports/sysutils/nomad/nomad-1.1.0/vendor/github.com/cilium/ebpf/ |
H A D | collection.go | 375 assignedMaps := make(map[string]struct{}) 391 assignedMaps[name] = struct{}{} 406 for name := range assignedMaps {
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/vendor/github.com/cilium/ebpf/ |
H A D | collection.go | 474 assignedMaps := make(map[string]struct{}) 490 assignedMaps[name] = struct{}{} 505 for name := range assignedMaps {
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/vendor/github.com/cilium/ebpf/ |
H A D | collection.go | 447 assignedMaps := make(map[string]struct{}) 463 assignedMaps[name] = struct{}{} 478 for name := range assignedMaps {
|
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/github.com/cilium/ebpf/ |
H A D | collection.go | 474 assignedMaps := make(map[string]struct{}) 490 assignedMaps[name] = struct{}{} 505 for name := range assignedMaps {
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
H A D | TestRMContainerAllocator.java | 1803 int assignedMaps = 2; 1822 assignedMaps, assignedReduces, 1845 assignedMaps, assignedReduces, 1857 assignedMaps, assignedReduces, 1871 assignedMaps, assignedReduces, 1887 assignedMaps, assignedReduces, 1903 scheduledReduces, assignedMaps, assignedReduces, mapResourceReqt, 1912 scheduledReduces, assignedMaps, assignedReduces, mapResourceReqt, 1928 int scheduledMaps, int scheduledReduces, int assignedMaps,
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
H A D | RMContainerAllocator.java | 526 int assignedMaps, int assignedReduces, in scheduleReduces() argument 575 Resources.multiply(mapResourceReqt, (scheduledMaps + assignedMaps)); in scheduleReduces() 598 mapResourceReqt, getSchedulerResourceTypes()) >= (scheduledMaps + assignedMaps)) { in scheduleReduces()
|