Home
last modified time | relevance | path

Searched defs:umbilical (Results 1 – 23 of 23) sorted by relevance

/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 DTestEventFetcher.java51 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 DEventFetcher.java36 private final TaskUmbilicalProtocol umbilical; field in EventFetcher
45 TaskUmbilicalProtocol umbilical, in EventFetcher()
H A DShuffle.java52 private TaskUmbilicalProtocol umbilical; field in Shuffle
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/
H A DTask.java165 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 DMapTask.java273 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 DChild.java109 final TaskUmbilicalProtocol umbilical = in main() local
H A DReduceTask.java262 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 DTask.java189 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 DShuffleConsumerPlugin.java53 private final TaskUmbilicalProtocol umbilical; field in ShuffleConsumerPlugin.Context
74 TaskUmbilicalProtocol umbilical, in Context()
91 this. umbilical = umbilical; in Context() local
H A DReduceTask.java232 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 DMapTask.java240 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 DTestReduceTaskFetchFail.java42 public TestReduceCopier(TaskUmbilicalProtocol umbilical, JobConf conf, in TestReduceCopier()
H A DTestTaskCommit.java236 MyUmbilical umbilical = new MyUmbilical(); in testTaskCleanupDoesNotCommit() local
/dports/net-p2p/bitcoin-utils/bitcoin-22.0/src/
H A Dbitcoind.cpp50 std::optional<TokenPipe> umbilical = TokenPipe::Make(); in fork_daemon() local
/dports/net-p2p/bitcoin/bitcoin-22.0/src/
H A Dbitcoind.cpp50 std::optional<TokenPipe> umbilical = TokenPipe::Make(); in fork_daemon() local
/dports/net-p2p/bitcoin-daemon/bitcoin-22.0/src/
H A Dbitcoind.cpp50 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 DLocalContainerLauncher.java82 private final TaskUmbilicalProtocol umbilical; field in LocalContainerLauncher
90 TaskUmbilicalProtocol umbilical) { in LocalContainerLauncher()
H A DYarnChild.java107 final TaskUmbilicalProtocol umbilical = in main() local
/dports/security/tinc-devel/tinc-1.1pre18/src/
H A Dlogger.c41 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 DTestMapProgress.java200 TaskReporter startReporter(final TaskUmbilicalProtocol umbilical) { in startReporter()
H A DTestTaskCommit.java226 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 DTestTaskImpl.java199 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 Dranked_frequency_lists.json1 …n":8,"margaret":9,"dorothy":10,"lisa":11,"nancy":12,"karen":13,"betty":14,"helen":15,"sandra":16,"…