/dports/devel/folly/folly-2021.12.27.00/folly/ |
H A D | AtomicHashMap-inl.h | 305 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 D | AtomicHashMap.h | 210 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 D | AtomicHashMap-inl.h | 303 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 D | AtomicHashMap.h | 210 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 D | JobIndexInfo.java | 35 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 D | DynamicInputFormat.java | 82 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 D | TestMiniMRClasspath.java | 48 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 D | TestMultipleLevelCaching.java | 150 int numMaps, int otherLocalMaps, in launchJobAndTestCounters() 172 int numMaps, String jobName) throws IOException { in launchJob()
|
H A D | MRBench.java | 143 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 D | DynamicInputFormat.java | 84 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 D | TestMiniMRClasspath.java | 44 int numMaps, in configureWordCount() 78 String input, int numMaps, int numReduces) in launchWordCount() 107 String input, int numMaps, int numReduces) in launchExternal()
|
H A D | TestRackAwareTaskPlacement.java | 69 int numMaps, int otherLocalMaps, in launchJobAndTestCounters() 165 int numMaps, String jobName) throws IOException { in launchJob()
|
H A D | TestNodeGroupAwareTaskPlacement.java | 91 int numMaps, int otherLocalMaps, in launchJobAndTestCounters() 237 int numMaps, String jobName) throws IOException { in launchJob()
|
H A D | MRBench.java | 143 private JobConf setupJob(int numMaps, int numReduces, String jarFile) { in setupJob() 235 int numMaps = 2; in run() local
|
H A D | TestKillCompletedJob.java | 44 int numMaps, in launchWordCount()
|
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/shuffle/ |
H A D | BaseShuffleHandle.scala | 27 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 D | TestMRAppWithCombiner.java | 101 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 D | JobInfoImpl.java | 50 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 D | TestTaskContext.java | 90 int numMaps = 1; in testContextStatus() local 191 int numMaps = 1; in testMapContextProgress() local
|
H A D | TestNoJobSetupCleanup.java | 45 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 D | TestGridmixSummary.java | 301 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 D | TestGridmixSummary.java | 317 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 D | JobInfo.java | 90 int numMaps(); in numMaps() method
|
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
H A D | ResourceEstimator.java | 118 void setThreshhold(int numMaps) { in setThreshhold()
|
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/shuffle/ |
H A D | BlockStoreShuffleReaderSuite.scala | 69 val numMaps = 6 constant
|