/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/ |
H A D | TestEventFetcher.java | 51 TaskUmbilicalProtocol umbilical = mock(TaskUmbilicalProtocol.class); in testConsecutiveFetch() local 107 TaskUmbilicalProtocol umbilical, ShuffleScheduler<K,V> scheduler, in EventFetcherForTest()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/ |
H A D | EventFetcher.java | 36 private final TaskUmbilicalProtocol umbilical; field in EventFetcher 45 TaskUmbilicalProtocol umbilical, in EventFetcher()
|
H A D | Shuffle.java | 52 private TaskUmbilicalProtocol umbilical; field in Shuffle
|
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
H A D | Task.java | 165 protected TaskUmbilicalProtocol umbilical; field in Task 474 public abstract void run(JobConf job, TaskUmbilicalProtocol umbilical) in run() 544 private TaskUmbilicalProtocol umbilical; field in Task.TaskReporter 855 public void done(TaskUmbilicalProtocol umbilical, in done() 907 protected void statusUpdate(TaskUmbilicalProtocol umbilical) in statusUpdate() 933 private void sendLastUpdate(TaskUmbilicalProtocol umbilical) in sendLastUpdate() 982 private void commit(TaskUmbilicalProtocol umbilical, in commit() 1033 protected void runTaskCleanupTask(TaskUmbilicalProtocol umbilical, in runTaskCleanupTask() 1040 void taskCleanup(TaskUmbilicalProtocol umbilical) in taskCleanup() 1051 protected void runJobCleanupTask(TaskUmbilicalProtocol umbilical, in runJobCleanupTask() [all …]
|
H A D | MapTask.java | 273 private TaskUmbilicalProtocol umbilical; field in MapTask.SkippingRecordReader 277 SkippingRecordReader(InputSplit split, TaskUmbilicalProtocol umbilical, in SkippingRecordReader() 338 public void run(final JobConf job, final TaskUmbilicalProtocol umbilical) in run() 402 final TaskUmbilicalProtocol umbilical, in runOldMapper() 612 JobConf job, TaskUmbilicalProtocol umbilical, TaskReporter reporter) in NewDirectOutputCollector() 670 TaskUmbilicalProtocol umbilical, in NewOutputCollector() 710 final TaskUmbilicalProtocol umbilical, in runNewMapper() 806 public DirectMapOutputCollector(TaskUmbilicalProtocol umbilical, in DirectMapOutputCollector() 922 public MapOutputBuffer(TaskUmbilicalProtocol umbilical, JobConf job, in MapOutputBuffer()
|
H A D | Child.java | 109 final TaskUmbilicalProtocol umbilical = in main() local
|
H A D | ReduceTask.java | 262 private TaskUmbilicalProtocol umbilical; field in ReduceTask.SkippingReduceValuesIterator 276 TaskUmbilicalProtocol umbilical) throws IOException { in SkippingReduceValuesIterator() 349 public void run(JobConf job, final TaskUmbilicalProtocol umbilical) in run() 480 TaskUmbilicalProtocol umbilical, in runOldReducer() 600 final TaskUmbilicalProtocol umbilical, in runNewReducer() 664 private TaskUmbilicalProtocol umbilical; field in ReduceTask.ReduceCopier 1929 public ReduceCopier(TaskUmbilicalProtocol umbilical, JobConf conf, in ReduceCopier()
|
/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 D | Task.java | 189 protected TaskUmbilicalProtocol umbilical; field in Task 638 private TaskUmbilicalProtocol umbilical; field in Task.TaskReporter 653 TaskUmbilicalProtocol umbilical) { in TaskReporter() 1035 public void done(TaskUmbilicalProtocol umbilical, in done() 1095 public void statusUpdate(TaskUmbilicalProtocol umbilical) in statusUpdate() 1121 private void sendLastUpdate(TaskUmbilicalProtocol umbilical) in sendLastUpdate() 1170 private void commit(TaskUmbilicalProtocol umbilical, in commit() 1221 protected void runTaskCleanupTask(TaskUmbilicalProtocol umbilical, in runTaskCleanupTask() 1228 void taskCleanup(TaskUmbilicalProtocol umbilical) in taskCleanup() 1239 protected void runJobCleanupTask(TaskUmbilicalProtocol umbilical, in runJobCleanupTask() [all …]
|
H A D | ShuffleConsumerPlugin.java | 53 private final TaskUmbilicalProtocol umbilical; field in ShuffleConsumerPlugin.Context 74 TaskUmbilicalProtocol umbilical, in Context() 91 this. umbilical = umbilical; in Context() local
|
H A D | ReduceTask.java | 232 private TaskUmbilicalProtocol umbilical; field in ReduceTask.SkippingReduceValuesIterator 246 TaskUmbilicalProtocol umbilical) throws IOException { in SkippingReduceValuesIterator() 319 public void run(JobConf job, final TaskUmbilicalProtocol umbilical) in run() 403 TaskUmbilicalProtocol umbilical, in runOldReducer() 577 final TaskUmbilicalProtocol umbilical, in runNewReducer()
|
H A D | MapTask.java | 240 private TaskUmbilicalProtocol umbilical; field in MapTask.SkippingRecordReader 244 SkippingRecordReader(TaskUmbilicalProtocol umbilical, in SkippingRecordReader() 305 public void run(final JobConf job, final TaskUmbilicalProtocol umbilical) in run() 422 final TaskUmbilicalProtocol umbilical, in runOldMapper() 631 JobConf job, TaskUmbilicalProtocol umbilical, TaskReporter reporter) in NewDirectOutputCollector() 695 TaskUmbilicalProtocol umbilical, in NewOutputCollector() 735 final TaskUmbilicalProtocol umbilical, in runNewMapper()
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/ |
H A D | TestReduceTaskFetchFail.java | 42 public TestReduceCopier(TaskUmbilicalProtocol umbilical, JobConf conf, in TestReduceCopier()
|
H A D | TestTaskCommit.java | 236 MyUmbilical umbilical = new MyUmbilical(); in testTaskCleanupDoesNotCommit() local
|
/dports/net-p2p/bitcoin-utils/bitcoin-22.0/src/ |
H A D | bitcoind.cpp | 50 std::optional<TokenPipe> umbilical = TokenPipe::Make(); in fork_daemon() local
|
/dports/net-p2p/bitcoin/bitcoin-22.0/src/ |
H A D | bitcoind.cpp | 50 std::optional<TokenPipe> umbilical = TokenPipe::Make(); in fork_daemon() local
|
/dports/net-p2p/bitcoin-daemon/bitcoin-22.0/src/ |
H A D | bitcoind.cpp | 50 std::optional<TokenPipe> umbilical = TokenPipe::Make(); in fork_daemon() local
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapred/ |
H A D | LocalContainerLauncher.java | 82 private final TaskUmbilicalProtocol umbilical; field in LocalContainerLauncher 90 TaskUmbilicalProtocol umbilical) { in LocalContainerLauncher()
|
H A D | YarnChild.java | 107 final TaskUmbilicalProtocol umbilical = in main() local
|
/dports/security/tinc-devel/tinc-1.1pre18/src/ |
H A D | logger.c | 41 int umbilical = 0; variable
|
/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 | TestMapProgress.java | 200 TaskReporter startReporter(final TaskUmbilicalProtocol umbilical) { in startReporter()
|
H A D | TestTaskCommit.java | 226 MyUmbilical umbilical = new MyUmbilical(); in testTaskCleanupDoesNotCommit() local
|
/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/job/impl/ |
H A D | TestTaskImpl.java | 199 public void run(JobConf job, TaskUmbilicalProtocol umbilical) in run()
|
/dports/www/orangehrm/orangehrm-4.9/symfony/lib/vendor/bjeavons/zxcvbn-php/src/Matchers/ |
H A D | ranked_frequency_lists.json | 1 …n":8,"margaret":9,"dorothy":10,"lisa":11,"nancy":12,"karen":13,"betty":14,"helen":15,"sandra":16,"…
|