Home
last modified time | relevance | path

Searched defs:numMaps (Results 1 – 25 of 127) sorted by relevance

123456

/dports/devel/folly/folly-2021.12.27.00/folly/
H A DAtomicHashMap-inl.h305 const unsigned int numMaps = in findInternal() local
387 int const numMaps = numMapsAllocated_.load(std::memory_order_acquire); in erase() local
416 int const numMaps = numMapsAllocated_.load(std::memory_order_acquire); in capacity() local
442 int const numMaps = numMapsAllocated_.load(std::memory_order_acquire); in spaceRemaining() local
470 int const numMaps = numMapsAllocated_.load(std::memory_order_relaxed); in clear() local
498 int const numMaps = numMapsAllocated_.load(std::memory_order_acquire); in size() local
H A DAtomicHashMap.h210 const unsigned int numMaps = in ~AtomicHashMap() local
358 const int numMaps = numMapsAllocated_.load(std::memory_order_acquire); in setEntryCountThreadCacheSize() local
/dports/security/keybase/client-v5.7.1/shared/ios/Pods/Folly/folly/
H A DAtomicHashMap-inl.h303 const unsigned int numMaps = in findInternal() local
385 int const numMaps = numMapsAllocated_.load(std::memory_order_acquire); in erase() local
414 int const numMaps = numMapsAllocated_.load(std::memory_order_acquire); in capacity() local
440 int const numMaps = numMapsAllocated_.load(std::memory_order_acquire); in spaceRemaining() local
468 int const numMaps = numMapsAllocated_.load(std::memory_order_relaxed); in clear() local
496 int const numMaps = numMapsAllocated_.load(std::memory_order_acquire); in size() local
H A DAtomicHashMap.h210 const unsigned int numMaps = in ~AtomicHashMap() local
366 const int numMaps = numMapsAllocated_.load(std::memory_order_acquire); in setEntryCountThreadCacheSize() local
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-common/src/main/java/org/apache/hadoop/mapreduce/v2/jobhistory/
H A DJobIndexInfo.java35 private int numMaps; field in JobIndexInfo
44 String jobName, JobId jobId, int numMaps, int numReduces, String jobStatus) { in JobIndexInfo()
50 String jobName, JobId jobId, int numMaps, int numReduces, in JobIndexInfo()
103 public void setNumMaps(int numMaps) { in setNumMaps()
/dports/devel/hadoop/hadoop-1.2.1/src/tools/org/apache/hadoop/tools/distcp2/mapred/lib/
H A DDynamicInputFormat.java82 int numMaps = getNumMapTasks(jobContext.getConfiguration()); in createSplits() local
109 int numMaps = getNumMapTasks(configuration); in splitCopyListingIntoChunksWithShuffle() local
170 private static void validateNumChunksUsing(int splitRatio, int numMaps) in validateNumChunksUsing()
236 int numMaps, int numPaths) { in getListingSplitRatio()
/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 DTestMiniMRClasspath.java48 int numMaps, int numReduces, Path inDir, Path outDir) throws IOException { in configureWordCount()
78 int numMaps, int numReduces) in launchWordCount()
106 int numMaps, int numReduces) in launchExternal()
H A DTestMultipleLevelCaching.java150 int numMaps, int otherLocalMaps, in launchJobAndTestCounters()
172 int numMaps, String jobName) throws IOException { in launchJob()
H A DMRBench.java143 private JobConf setupJob(int numMaps, int numReduces, String jarFile) { in setupJob()
235 int numMaps = 2; in run() local
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-distcp/src/main/java/org/apache/hadoop/tools/mapred/lib/
H A DDynamicInputFormat.java84 int numMaps = getNumMapTasks(jobContext.getConfiguration()); in createSplits() local
118 int numMaps = getNumMapTasks(configuration); in splitCopyListingIntoChunksWithShuffle() local
182 private static void validateNumChunksUsing(int splitRatio, int numMaps, in validateNumChunksUsing()
248 int numMaps, int numPaths) { in getListingSplitRatio()
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/
H A DTestMiniMRClasspath.java44 int numMaps, in configureWordCount()
78 String input, int numMaps, int numReduces) in launchWordCount()
107 String input, int numMaps, int numReduces) in launchExternal()
H A DTestRackAwareTaskPlacement.java69 int numMaps, int otherLocalMaps, in launchJobAndTestCounters()
165 int numMaps, String jobName) throws IOException { in launchJob()
H A DTestNodeGroupAwareTaskPlacement.java91 int numMaps, int otherLocalMaps, in launchJobAndTestCounters()
237 int numMaps, String jobName) throws IOException { in launchJob()
H A DMRBench.java143 private JobConf setupJob(int numMaps, int numReduces, String jarFile) { in setupJob()
235 int numMaps = 2; in run() local
H A DTestKillCompletedJob.java44 int numMaps, in launchWordCount()
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/shuffle/
H A DBaseShuffleHandle.scala27 val numMaps: Int, constant
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/v2/
H A DTestMRAppWithCombiner.java101 int numMaps = 5; in testCombinerShouldUpdateTheReporter() local
127 static void createInputOutPutFolder(Path inDir, Path outDir, int numMaps) in createInputOutPutFolder()
/dports/devel/hadoop/hadoop-1.2.1/src/test/system/java/org/apache/hadoop/mapred/
H A DJobInfoImpl.java50 private int numMaps; field in JobInfoImpl
69 List<String> blackListedTracker, boolean isComplete, int numMaps, in JobInfoImpl()
155 public int numMaps() { in numMaps() method in JobInfoImpl
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/
H A DTestTaskContext.java90 int numMaps = 1; in testContextStatus() local
191 int numMaps = 1; in testMapContextProgress() local
H A DTestNoJobSetupCleanup.java45 private Job submitAndValidateJob(Configuration conf, int numMaps, int numReds) in submitAndValidateJob()
/dports/devel/hadoop/hadoop-1.2.1/src/contrib/gridmix/src/test/org/apache/hadoop/mapred/gridmix/
H A DTestGridmixSummary.java301 private static void testExecutionSummarizer(int numMaps, int numReds, in testExecutionSummarizer()
320 private static JobStats generateFakeJobStats(final int numMaps, in generateFakeJobStats()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-gridmix/src/test/java/org/apache/hadoop/mapred/gridmix/
H A DTestGridmixSummary.java317 private static void testExecutionSummarizer(int numMaps, int numReds, in testExecutionSummarizer()
338 private static JobStats generateFakeJobStats(final int numMaps, in generateFakeJobStats()
/dports/devel/hadoop/hadoop-1.2.1/src/test/system/java/org/apache/hadoop/mapreduce/test/system/
H A DJobInfo.java90 int numMaps(); in numMaps() method
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/
H A DResourceEstimator.java118 void setThreshhold(int numMaps) { in setThreshhold()
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/shuffle/
H A DBlockStoreShuffleReaderSuite.scala69 val numMaps = 6 constant

123456