Home
last modified time | relevance | path

Searched refs:clusterMap (Results 1 – 25 of 414) sorted by relevance

12345678910>>...17

/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/server/namenode/
H A DBlockPlacementPolicyDefault.java51 protected NetworkTopology clusterMap; field in BlockPlacementPolicyDefault
56 NetworkTopology clusterMap) { in BlockPlacementPolicyDefault() argument
57 initialize(conf, stats, clusterMap); in BlockPlacementPolicyDefault()
65 NetworkTopology clusterMap) { in initialize() argument
69 this.clusterMap = clusterMap; in initialize()
121 int clusterSize = clusterMap.getNumOfLeaves(); in chooseTarget()
129 (totalNumOfReplicas-1)/clusterMap.getNumOfRacks()+2; in chooseTarget()
139 if (!clusterMap.contains(writer)) { in chooseTarget()
497 int size = clusterMap.getNumOfLeaves(); in isGoodTarget()
536 synchronized(clusterMap) { in getPipeline()
[all …]
H A DBlockPlacementPolicyWithNodeGroup.java48 NetworkTopology clusterMap) { in BlockPlacementPolicyWithNodeGroup() argument
49 initialize(conf, stats, clusterMap); in BlockPlacementPolicyWithNodeGroup()
57 NetworkTopology clusterMap) { in initialize() argument
58 super.initialize(conf, stats, clusterMap); in initialize()
91 (NetworkTopologyWithNodeGroup)clusterMap, localMachine, excludedNodes, in chooseLocalNode()
112 List<Node> leafNodes = clusterMap.getLeaves(nodeGroup); in addNodeGroupToExcludedNodes()
151 clusterMap.getRack(newLocal.getNetworkLocation()), excludedNodes, in chooseLocalRack()
193 NetworkTopologyWithNodeGroup clusterMap, DatanodeDescriptor localMachine, in chooseLocalNodeGroup() argument
206 clusterMap.getNodeGroup(localMachine.getNetworkLocation()), in chooseLocalNodeGroup()
222 clusterMap.getNodeGroup(newLocal.getNetworkLocation()), in chooseLocalNodeGroup()
[all …]
H A DBlockPlacementPolicy.java151 NetworkTopology clusterMap); in initialize() argument
164 NetworkTopology clusterMap) { in getInstance() argument
171 replicator.initialize(conf, stats, clusterMap); in getInstance()
/dports/misc/elki/elki-release0.7.1-1166-gfb1fffdf3/elki-clustering/src/main/java/de/lmu/ifi/dbs/elki/algorithm/clustering/correlation/
H A DERiC.java145 for(int corrDim = 0; corrDim < clusterMap.size(); corrDim++) { in run()
161 for(List<Cluster<CorrelationModel>> correlationClusters : clusterMap) { in run()
170 buildHierarchy(clustering, clusterMap, npred); in run()
173 for(int corrDim = 0; corrDim < clusterMap.size(); corrDim++) { in run()
191 for(Cluster<CorrelationModel> rc : clusterMap.get(clusterMap.size() - 1)) { in run()
211 List<List<Cluster<CorrelationModel>>> clusterMap = new ArrayList<>(); in extractCorrelationClusters() local
213 clusterMap.add(new ArrayList<Cluster<CorrelationModel>>()); in extractCorrelationClusters()
264 if(!clusterMap.get(i).isEmpty()) { in extractCorrelationClusters()
267 clusterMap.remove(i); in extractCorrelationClusters()
269 return clusterMap; in extractCorrelationClusters()
[all …]
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/balancer/
H A DSimpleLoadBalancer.java184 Map<ServerName, List<HRegionInfo>> clusterMap) { in balanceCluster() argument
185 List<RegionPlan> regionsToReturn = balanceMasterRegions(clusterMap); in balanceCluster()
186 if (regionsToReturn != null || clusterMap == null || clusterMap.size() <= 1) { in balanceCluster()
189 if (masterServerName != null && clusterMap.containsKey(masterServerName)) { in balanceCluster()
190 if (clusterMap.size() <= 2) { in balanceCluster()
193 clusterMap = new HashMap<ServerName, List<HRegionInfo>>(clusterMap); in balanceCluster()
194 clusterMap.remove(masterServerName); in balanceCluster()
201 Cluster c = new Cluster(clusterMap, null, this.regionFinder, this.rackManager); in balanceCluster()
204 ClusterLoadState cs = new ClusterLoadState(clusterMap); in balanceCluster()
407 for (Map.Entry<ServerName, List<HRegionInfo>> e: clusterMap.entrySet()) { in balanceCluster()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/server/blockmanagement/
H A DBlockPlacementPolicyWithNodeGroup.java45 NetworkTopology clusterMap, DatanodeManager datanodeManager) { in BlockPlacementPolicyWithNodeGroup() argument
46 initialize(conf, stats, clusterMap, host2datanodeMap); in BlockPlacementPolicyWithNodeGroup()
53 NetworkTopology clusterMap, in initialize() argument
55 super.initialize(conf, stats, clusterMap, host2datanodeMap); in initialize()
101 (NetworkTopologyWithNodeGroup)clusterMap, localMachine, excludedNodes, in chooseLocalStorage()
151 clusterMap.getRack(newLocal.getNetworkLocation()), excludedNodes, in chooseLocalRack()
199 NetworkTopologyWithNodeGroup clusterMap, Node localMachine, in chooseLocalNodeGroup() argument
213 clusterMap.getNodeGroup(localMachine.getNetworkLocation()), in chooseLocalNodeGroup()
221 clusterMap.getNodeGroup(newLocal.getNetworkLocation()), in chooseLocalNodeGroup()
254 List<Node> leafNodes = clusterMap.getLeaves(nodeGroupScope); in addToExcludedNodes()
H A DBlockPlacementPolicyDefault.java67 protected NetworkTopology clusterMap; field in BlockPlacementPolicyDefault
83 NetworkTopology clusterMap, in initialize() argument
88 this.clusterMap = clusterMap; in initialize()
193 if (numOfReplicas == 0 || clusterMap.getNumOfLeaves()==0) { in chooseTarget()
241 int clusterSize = clusterMap.getNumOfLeaves(); in getMaxNodesPerRack()
248 int numOfRacks = clusterMap.getNumOfRacks(); in getMaxNodesPerRack()
355 if (clusterMap.isOnSameRack(dn0, dn1)) { in chooseTarget()
635 (DatanodeDescriptor)clusterMap.chooseRandom(scope); in chooseRandom()
832 synchronized(clusterMap) { in getPipeline()
834 if (writer == null || !clusterMap.contains(writer)) { in getPipeline()
[all …]
H A DBlockPlacementPolicy.java146 NetworkTopology clusterMap, in initialize() argument
161 NetworkTopology clusterMap, in getInstance() argument
169 replicator.initialize(conf, stats, clusterMap, host2datanodeMap); in getInstance()
/dports/biology/mothur/mothur-1.46.1/source/communitytype/
H A Dcommunitytype.cpp568 map<int, int> clusterMap; //map sample to partition in calcCHIndex() local
574 clusterMap[j] = i; in calcCHIndex()
598 vector<vector<double> > centers = calcCenters(dists, clusterMap, relativeAbundance); in calcCHIndex()
610 …i][j] = ((relativeAbundance[i][j] - centers[clusterMap[i]][j])*(relativeAbundance[i][j] - centers[… in calcCHIndex()
646 int partitionI = clusterMap[i]; in calcCenters()
657 int partitionJ = clusterMap[j]; in calcCenters()
720 map<int, int> clusterMap; //map sample to partition in calcSilhouettes() local
726 clusterMap[j] = i; in calcSilhouettes()
738 int partitionI = clusterMap[i]; in calcSilhouettes()
743 int partitionJ = clusterMap[j]; in calcSilhouettes()
[all …]
/dports/misc/elki/elki-release0.7.1-1166-gfb1fffdf3/elki-clustering/src/main/java/de/lmu/ifi/dbs/elki/algorithm/clustering/subspace/
H A DSUBCLU.java143 …TreeMap<Subspace, List<Cluster<Model>>> clusterMap = new TreeMap<>(new Subspace.DimensionComparato… in run() local
160 clusterMap.put(currentSubspace, clusters); in run()
184 Subspace bestSubspace = bestSubspace(subspaces, candidate, clusterMap); in run()
189 List<Cluster<Model>> bestSubspaceClusters = clusterMap.get(bestSubspace); in run()
209 clusterMap.put(candidate, clusters); in run()
221 for(Subspace subspace : clusterMap.descendingKeySet()) { in run()
222 List<Cluster<Model>> clusters = clusterMap.get(subspace); in run()
379 …List<Subspace> subspaces, Subspace candidate, TreeMap<Subspace, List<Cluster<Model>>> clusterMap) { in bestSubspace() argument
386 List<Cluster<Model>> clusters = clusterMap.get(subspace); in bestSubspace()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/
H A DTestGetSplitHosts.java33 NetworkTopology clusterMap = new NetworkTopology(); in testGetSplitHosts() local
78 String [] hosts = sif.getSplitHosts(bs, 0, fileSize, clusterMap); in testGetSplitHosts()
99 hosts = sif.getSplitHosts(bs, 0, fileSize, clusterMap); in testGetSplitHosts()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestGetSplitHosts.java33 NetworkTopology clusterMap = new NetworkTopology(); in testGetSplitHosts() local
78 String [] hosts = sif.getSplitHosts(bs, 0, fileSize, clusterMap); in testGetSplitHosts()
99 hosts = sif.getSplitHosts(bs, 0, fileSize, clusterMap); in testGetSplitHosts()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/net/
H A DNetworkTopology.java377 InnerNode clusterMap; field in NetworkTopology
386 clusterMap = new InnerNode(InnerNode.ROOT); in NetworkTopology()
418 if (clusterMap.add(node)) { in add()
468 InnerNode rack = (InnerNode) clusterMap.getLoc(loc); in getDatanodesInRack()
491 if (clusterMap.remove(node)) { in remove()
517 if (parent == clusterMap) { in contains()
539 return clusterMap.getLoc(loc); in getNode()
573 return clusterMap.getNumOfLeaves(); in getNumOfLeaves()
795 return clusterMap.getNumOfLeaves() - scopeNodeCount in countNumOfAvailableNodes()
820 tree.append(NodeBase.getPath(clusterMap.getLeaf(i, null))); in toString()
/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/net/
H A DNetworkTopology.java337 InnerNode clusterMap; field in NetworkTopology
344 clusterMap = new InnerNode(InnerNode.ROOT); in NetworkTopology()
382 if (clusterMap.add(node)) { in add()
440 if (clusterMap.remove(node)) { in remove()
465 if (parent == clusterMap) in contains()
486 return clusterMap.getLoc(loc); in getNode()
520 return clusterMap.getNumOfLeaves(); in getNumOfLeaves()
721 return clusterMap.getNumOfLeaves()- in countNumOfAvailableNodes()
745 tree.append(NodeBase.getPath(clusterMap.getLeaf(i, null))); in toString()
/dports/www/firefox-esr/firefox-91.8.0/gfx/harfbuzz/src/
H A Dhb-directwrite.cc669 uint16_t* clusterMap; in _hb_directwrite_shape_full() local
670 clusterMap = new uint16_t[textLength]; in _hb_directwrite_shape_full()
681 maxGlyphCount, clusterMap, textProperties, in _hb_directwrite_shape_full()
718 hr = analyzer->GetGlyphPlacements (textString, clusterMap, textProperties, in _hb_directwrite_shape_full()
737 clusterMap, glyphProperties, in _hb_directwrite_shape_full()
767 clusterMap, glyphIndices, glyphAdvances, in _hb_directwrite_shape_full()
787 delete [] clusterMap; in _hb_directwrite_shape_full()
793 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
866 delete [] clusterMap; in _hb_directwrite_shape_full()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/harfbuzz-ng/src/src/
H A Dhb-directwrite.cc660 uint16_t* clusterMap; in _hb_directwrite_shape_full() local
661 clusterMap = new uint16_t[textLength]; in _hb_directwrite_shape_full()
672 maxGlyphCount, clusterMap, textProperties, in _hb_directwrite_shape_full()
709 hr = analyzer->GetGlyphPlacements (textString, clusterMap, textProperties, in _hb_directwrite_shape_full()
728 clusterMap, glyphProperties, in _hb_directwrite_shape_full()
758 clusterMap, glyphIndices, glyphAdvances, in _hb_directwrite_shape_full()
778 delete [] clusterMap; in _hb_directwrite_shape_full()
784 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
857 delete [] clusterMap; in _hb_directwrite_shape_full()
/dports/mail/thunderbird/thunderbird-91.8.0/gfx/harfbuzz/src/
H A Dhb-directwrite.cc669 uint16_t* clusterMap; in _hb_directwrite_shape_full() local
670 clusterMap = new uint16_t[textLength]; in _hb_directwrite_shape_full()
681 maxGlyphCount, clusterMap, textProperties, in _hb_directwrite_shape_full()
718 hr = analyzer->GetGlyphPlacements (textString, clusterMap, textProperties, in _hb_directwrite_shape_full()
737 clusterMap, glyphProperties, in _hb_directwrite_shape_full()
767 clusterMap, glyphIndices, glyphAdvances, in _hb_directwrite_shape_full()
787 delete [] clusterMap; in _hb_directwrite_shape_full()
793 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
866 delete [] clusterMap; in _hb_directwrite_shape_full()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/
H A DFileInputFormat.java333 NetworkTopology clusterMap = new NetworkTopology(); in getSplits() local
352 length-bytesRemaining, splitSize, clusterMap); in getSplits()
360 - bytesRemaining, bytesRemaining, clusterMap); in getSplits()
365 String[][] splitHosts = getSplitHostsAndCachedHosts(blkLocations,0,length,clusterMap); in getSplits()
556 long offset, long splitSize, NetworkTopology clusterMap) throws IOException { in getSplitHosts() argument
558 clusterMap)[0]; in getSplitHosts()
576 long offset, long splitSize, NetworkTopology clusterMap) in getSplitHostsAndCachedHosts() argument
641 node = clusterMap.getNode(topo); in getSplitHostsAndCachedHosts()
645 clusterMap.add(node); in getSplitHostsAndCachedHosts()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/harfbuzz-ng/src/src/
H A Dhb-directwrite.cc660 uint16_t* clusterMap; in _hb_directwrite_shape_full() local
661 clusterMap = new uint16_t[textLength]; in _hb_directwrite_shape_full()
672 maxGlyphCount, clusterMap, textProperties, in _hb_directwrite_shape_full()
709 hr = analyzer->GetGlyphPlacements (textString, clusterMap, textProperties, in _hb_directwrite_shape_full()
728 clusterMap, glyphProperties, in _hb_directwrite_shape_full()
758 clusterMap, glyphIndices, glyphAdvances, in _hb_directwrite_shape_full()
778 delete [] clusterMap; in _hb_directwrite_shape_full()
784 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
857 delete [] clusterMap; in _hb_directwrite_shape_full()
/dports/graphics/mupdf/mupdf-1.18.0-source/thirdparty/harfbuzz/src/
H A Dhb-directwrite.cc660 uint16_t* clusterMap; in _hb_directwrite_shape_full() local
661 clusterMap = new uint16_t[textLength]; in _hb_directwrite_shape_full()
672 maxGlyphCount, clusterMap, textProperties, in _hb_directwrite_shape_full()
709 hr = analyzer->GetGlyphPlacements (textString, clusterMap, textProperties, in _hb_directwrite_shape_full()
728 clusterMap, glyphProperties, in _hb_directwrite_shape_full()
758 clusterMap, glyphIndices, glyphAdvances, in _hb_directwrite_shape_full()
778 delete [] clusterMap; in _hb_directwrite_shape_full()
784 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
857 delete [] clusterMap; in _hb_directwrite_shape_full()
/dports/textproc/cast2gif/cast2gif-0.1.0/cargo-crates/harfbuzz-sys-0.3.4/harfbuzz/src/
H A Dhb-directwrite.cc660 uint16_t* clusterMap; in _hb_directwrite_shape_full() local
661 clusterMap = new uint16_t[textLength]; in _hb_directwrite_shape_full()
672 maxGlyphCount, clusterMap, textProperties, in _hb_directwrite_shape_full()
709 hr = analyzer->GetGlyphPlacements (textString, clusterMap, textProperties, in _hb_directwrite_shape_full()
728 clusterMap, glyphProperties, in _hb_directwrite_shape_full()
758 clusterMap, glyphIndices, glyphAdvances, in _hb_directwrite_shape_full()
778 delete [] clusterMap; in _hb_directwrite_shape_full()
784 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
857 delete [] clusterMap; in _hb_directwrite_shape_full()
/dports/lang/spidermonkey78/firefox-78.9.0/gfx/harfbuzz/src/
H A Dhb-directwrite.cc660 uint16_t* clusterMap; in _hb_directwrite_shape_full() local
661 clusterMap = new uint16_t[textLength]; in _hb_directwrite_shape_full()
672 maxGlyphCount, clusterMap, textProperties, in _hb_directwrite_shape_full()
709 hr = analyzer->GetGlyphPlacements (textString, clusterMap, textProperties, in _hb_directwrite_shape_full()
728 clusterMap, glyphProperties, in _hb_directwrite_shape_full()
758 clusterMap, glyphIndices, glyphAdvances, in _hb_directwrite_shape_full()
778 delete [] clusterMap; in _hb_directwrite_shape_full()
784 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
857 delete [] clusterMap; in _hb_directwrite_shape_full()
/dports/www/firefox-legacy/firefox-52.8.0esr/gfx/harfbuzz/src/
H A Dhb-directwrite.cc666 uint16_t* clusterMap = (uint16_t*) malloc (textLength * sizeof (uint16_t)); in _hb_directwrite_shape_full() local
676 featureRangeLengths, 1, maxGlyphCount, clusterMap, textProperties, glyphIndices, in _hb_directwrite_shape_full()
720 clusterMap, textProperties, textLength, glyphIndices, in _hb_directwrite_shape_full()
742 runHead->mScript, textLength, glyphCount, textString, clusterMap, in _hb_directwrite_shape_full()
784 textLength, glyphCount, maxGlyphCount, clusterMap, glyphIndices, in _hb_directwrite_shape_full()
806 free (clusterMap); in _hb_directwrite_shape_full()
812 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
888 free (clusterMap); in _hb_directwrite_shape_full()
/dports/lang/spidermonkey60/firefox-60.9.0/gfx/harfbuzz/src/
H A Dhb-directwrite.cc664 uint16_t* clusterMap = (uint16_t*) malloc (textLength * sizeof (uint16_t)); in _hb_directwrite_shape_full() local
674 featureRangeLengths, 1, maxGlyphCount, clusterMap, textProperties, glyphIndices, in _hb_directwrite_shape_full()
718 clusterMap, textProperties, textLength, glyphIndices, in _hb_directwrite_shape_full()
740 runHead->mScript, textLength, glyphCount, textString, clusterMap, in _hb_directwrite_shape_full()
782 textLength, glyphCount, maxGlyphCount, clusterMap, glyphIndices, in _hb_directwrite_shape_full()
804 free (clusterMap); in _hb_directwrite_shape_full()
810 clusterMap = modifiedClusterMap; in _hb_directwrite_shape_full()
886 free (clusterMap); in _hb_directwrite_shape_full()
/dports/math/R/R-4.1.2/src/library/parallel/tests/
H A Dsnow1.RR13 ## Use clusterMap like an mapply example
14 clusterMap(cl, function(x,y) seq_len(x) + y,

12345678910>>...17