Home
last modified time | relevance | path

Searched refs:JobImpl (Results 1 – 16 of 16) sorted by relevance

/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 DJobImpl.java1817 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 DTestJobImpl.java538 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 Ddevice_management_service.cc331 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 Ddevice_management_service.h341 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 DTestJobEndNotifier.java50 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 DTestMRAppComponentDependencies.java34 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl;
46 JobImpl job = (JobImpl) app.submit(new Configuration()); in testComponentStopOrder()
H A DTestMRApp.java51 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 DTestStagingCleanup.java46 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 DMRApp.java72 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 DTestKill.java46 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 DMockJobs.java60 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 DRMCommunicator.java41 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 DTestEvents.java37 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 DMRAppMaster.java98 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 DTestJobHistoryParsing.java75 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 DTestRMContainerAllocator.java75 import org.apache.hadoop.mapreduce.v2.app.job.impl.JobImpl;
733 mrApp.waitForInternalState((JobImpl) job, JobStateInternal.RUNNING);
885 mrApp.waitForInternalState((JobImpl)job, JobStateInternal.RUNNING);