/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/job/impl/ |
H A D | JobImpl.java | 1817 SingleArcTransition<JobImpl, JobEvent> { 1884 SingleArcTransition<JobImpl, JobEvent> { 1950 JobImpl job; 2046 SingleArcTransition<JobImpl, JobEvent> { 2055 SingleArcTransition<JobImpl, JobEvent> { 2067 SingleArcTransition<JobImpl, JobEvent> { 2078 SingleArcTransition<JobImpl, JobEvent> { 2086 SingleArcTransition<JobImpl, JobEvent> { 2116 SingleArcTransition<JobImpl, JobEvent> { 2125 SingleArcTransition<JobImpl, JobEvent> { [all …]
|
/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 | TestJobImpl.java | 538 JobImpl job1 = new JobImpl(jobId, null, conf1, null, null, null, null, null, in testCheckAccess() 549 JobImpl job2 = new JobImpl(jobId, null, conf2, null, null, null, null, null, in testCheckAccess() 560 JobImpl job3 = new JobImpl(jobId, null, conf3, null, null, null, null, null, in testCheckAccess() 571 JobImpl job4 = new JobImpl(jobId, null, conf4, null, null, null, null, null, in testCheckAccess() 582 JobImpl job5 = new JobImpl(jobId, null, conf5, null, null, null, null, null, in testCheckAccess() 598 JobImpl job = new JobImpl(jobId, Records in testReportDiagnostics() 609 job = new JobImpl(jobId, Records in testReportDiagnostics() 675 JobImpl job = in testUberDecision() 748 JobImpl job = in testMetaInfoSizeOverMax() 827 private static void completeJobTasks(JobImpl job) { in completeJobTasks() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/policy/core/common/cloud/ |
H A D | device_management_service.cc | 331 class DeviceManagementService::JobImpl : public Job, public JobControl { class in policy::DeviceManagementService 333 JobImpl(DeviceManagementService* service, in JobImpl() function in policy::DeviceManagementService::JobImpl 336 ~JobImpl() override { service_->RemoveJob(this); } in ~JobImpl() 370 DISALLOW_COPY_AND_ASSIGN(JobImpl); 374 DeviceManagementService::JobImpl::CreateFetcher() { in CreateFetcher() 384 DeviceManagementService::JobImpl::OnURLLoadComplete( in OnURLLoadComplete() 433 DeviceManagementService::JobImpl::ShouldRetry(const std::string& mime_type, in ShouldRetry() 467 int DeviceManagementService::JobImpl::GetRetryDelay(RetryMethod method) { in GetRetryDelay() 487 std::unique_ptr<JobImpl> job = in CreateJob() 488 std::make_unique<JobImpl>(this, std::move(config)); in CreateJob()
|
H A D | device_management_service.h | 341 class JobImpl; variable
|
/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/ |
H A D | TestJobEndNotifier.java | 50 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 210 JobImpl job = (JobImpl)app.submit(conf); in testNotificationOnLastRetryNormalShutdown() 233 JobImpl job = (JobImpl)app.submit(conf); in testAbsentNotificationOnNotLastRetryUnregistrationFailure() 266 JobImpl job = (JobImpl)app.submit(conf); in testNotificationOnLastRetryUnregistrationFailure()
|
H A D | TestMRAppComponentDependencies.java | 34 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 46 JobImpl job = (JobImpl) app.submit(new Configuration()); in testComponentStopOrder()
|
H A D | TestMRApp.java | 51 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 386 JobImpl job = (JobImpl) app.submit(new Configuration()); in testJobSuccess() 435 app.waitForInternalState((JobImpl) job, JobStateInternal.REBOOT); in testJobRebootOnLastRetryOnUnregistrationFailure() 442 private JobImpl spiedJob; 452 spiedJob = spy((JobImpl) super.createJob(conf, forcedState, diagnostic)); in createJob() 462 JobImpl job = (JobImpl)app.submit(new Configuration()); in testCountersOnJobFinish()
|
H A D | TestStagingCleanup.java | 46 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 291 JobImpl jobImpl = mock(JobImpl.class); in createJob() 469 JobImpl job = (JobImpl)app.submit(new Configuration());
|
H A D | MRApp.java | 72 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 312 public void waitForInternalState(JobImpl job, in waitForInternalState() 697 class TestJob extends JobImpl { 701 StateMachineFactory<JobImpl, JobStateInternal, JobEventType, JobEvent> localFactory 737 static class TestInitTransition extends JobImpl.InitTransition { 745 protected void setup(JobImpl job) throws IOException { 751 protected TaskSplitMetaInfo[] createSplits(JobImpl job, JobId jobId) {
|
H A D | TestKill.java | 46 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 214 app.waitForInternalState((JobImpl)job, JobStateInternal.KILLED); in testKillTaskWait() 295 app.waitForInternalState((JobImpl)job, JobStateInternal.KILLED); in testKillTaskWaitKillJobAfterTA_DONE()
|
H A D | MockJobs.java | 60 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 442 return JobImpl.incrTaskCounters(counters, completedTasks);
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
H A D | RMCommunicator.java | 41 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 202 JobImpl jobImpl = (JobImpl)job; in doUnregistration()
|
/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/jobhistory/ |
H A D | TestEvents.java | 37 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 343 datum.setDiagnostics(JobImpl.JOB_KILLED_DIAG); in getJobKilledEvent()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/ |
H A D | MRAppMaster.java | 98 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 552 if (((JobImpl)job).getInternalState() != JobStateInternal.REBOOT) { 632 new JobImpl(jobId, appAttemptID, conf, dispatcher.getEventHandler(), 1085 initFailed = (((JobImpl)job).getInternalState() != JobStateInternal.INITED);
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/test/java/org/apache/hadoop/mapreduce/v2/hs/ |
H A D | TestJobHistoryParsing.java | 75 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 577 historyError.contains(JobImpl.JOB_KILLED_DIAG)); in testDiagnosticsForKilledJob()
|
/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/rm/ |
H A D | TestRMContainerAllocator.java | 75 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl; 733 mrApp.waitForInternalState((JobImpl) job, JobStateInternal.RUNNING); 885 mrApp.waitForInternalState((JobImpl)job, JobStateInternal.RUNNING);
|