Home
last modified time | relevance | path

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 DMRAMSimulator.java80 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 DJobQueueTaskScheduler.java212 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 Dcollection.go375 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 Dcollection.go375 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 Dcollection.go375 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 Dcollection.go375 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 Dcollection.go474 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 Dcollection.go447 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 Dcollection.go474 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 DTestRMContainerAllocator.java1803 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 DRMContainerAllocator.java526 int assignedMaps, int assignedReduces, in scheduleReduces() argument
575 Resources.multiply(mapResourceReqt, (scheduledMaps + assignedMaps)); in scheduleReduces()
598 mapResourceReqt, getSchedulerResourceTypes()) >= (scheduledMaps + assignedMaps)) { in scheduleReduces()