| /dports/devel/hadoop/hadoop-1.2.1/src/contrib/capacity-scheduler/src/test/org/apache/hadoop/mapred/ |
| H A D | TestCapacitySchedulerWithJobTracker.java | 62 rjob = runJob(job, false); in testFailingJobInitalization()
109 jobs[0] = runJob(sleepJobConf, true); in testJobTrackerIntegration()
119 jobs[1] = runJob(sleep2, false); in testJobTrackerIntegration()
126 private RunningJob runJob(JobConf conf, boolean inBackGround) in runJob() method in TestCapacitySchedulerWithJobTracker
129 RunningJob rjob = JobClient.runJob(conf); in runJob()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/ |
| H A D | TestJobClient.java | 44 private String runJob() throws Exception { in runJob() method in TestJobClient
71 return JobClient.runJob(conf).getID().toString(); in runJob()
86 String jobId = runJob(); in testGetCounter()
97 String jobId = runJob(); in testJobList()
123 String jobId = runJob(); in testChangingJobPriority()
|
| H A D | TestJobStatusPersistency.java | 42 private JobID runJob() throws Exception { in runJob() method in TestJobStatusPersistency
70 return JobClient.runJob(conf).getID(); in runJob()
75 JobID jobId = runJob(); in testNonPersistency()
91 JobID jobId = runJob(); in testPersistency()
132 JobID jobId = runJob(); in testLocalPersistency()
|
| H A D | TestReduceFetch.java | 80 public static Counters runJob(JobConf conf) throws Exception { in runJob() method in TestReduceFetch
92 job = JobClient.runJob(conf); in runJob()
112 Counters c = runJob(job); in testReduceFromDisk()
133 Counters c = runJob(job); in testReduceFromPartialMem()
147 Counters c = runJob(job); in testReduceFromMem()
|
| H A D | TestJobExecutionAsDifferentUser.java | 52 job = UtilsForTests.runJob(getClusterConf(), inDir, outDir, 0, 0); in testJobExecution()
58 job = UtilsForTests.runJob(getClusterConf(), inDir, outDir, 1, 0); in testJobExecution()
64 job = UtilsForTests.runJob(getClusterConf(), inDir, outDir, 1, 1); in testJobExecution()
|
| H A D | TestMapRed.java | 342 JobClient.runJob(conf); in testPartitioner()
352 JobClient.runJob(conf); in testPartitioner()
400 JobClient.runJob(conf); in testNullKeys()
446 RunningJob rj = JobClient.runJob(conf); in checkCompression()
565 JobClient.runJob(genJob); in launch()
611 JobClient.runJob(checkJob); in launch()
635 JobClient.runJob(mergeJob); in launch()
758 runJob(100); in testSmallInput()
763 runJob(1000); in testBiggerInput()
766 public void runJob(int items) { in runJob() method in TestMapRed
[all …]
|
| H A D | TestJobHistoryServer.java | 64 RunningJob job = runJob(conf); in testHistoryServerEmbedded()
106 RunningJob job = runJob(conf); in testHistoryServerStandalone()
137 private synchronized RunningJob runJob(JobConf conf) throws IOException { in runJob() method in TestJobHistoryServer
154 return JobClient.runJob(conf); in runJob()
|
| H A D | TestMiniMRTaskTempDir.java | 124 JobClient.runJob(conf); in launchTest()
129 JobClient.runJob(conf); in launchTest()
134 JobClient.runJob(conf); in launchTest()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/system/java/org/apache/hadoop/mapred/ |
| H A D | TestJobSummary.java | 96 RunningJob runJob = jobClient.submitJob(jobConf); in testJobSummaryInfoOfKilledJob() local
97 JobID jobId = runJob.getID(); in testJobSummaryInfoOfKilledJob()
128 RunningJob runJob = jobClient.submitJob(jobConf); in testJobSummaryInfoOfFailedJob() local
129 JobID jobId = runJob.getID(); in testJobSummaryInfoOfFailedJob()
164 RunningJob runJob = jobClient.submitJob(jobConf); in testJobQueueInfoInJobSummary() local
165 JobID jobId = runJob.getID(); in testJobQueueInfoInJobSummary()
212 RunningJob runJob = proxyUGI.doAs( in testJobSummaryInfoForDifferentUser() local
218 JobID jobId = runJob.getID(); in testJobSummaryInfoForDifferentUser()
|
| H A D | TestTaskChildsKilling.java | 118 RunningJob runJob = client.submitJob(jobConf); in testProcessTreeCleanupOfKilledTask1() local
119 JobID id = runJob.getID(); in testProcessTreeCleanupOfKilledTask1()
181 runJob.killJob(); in testProcessTreeCleanupOfKilledTask1()
229 RunningJob runJob = client.submitJob(jobConf); in testProcessTreeCleanupOfKilledTask2() local
230 JobID id = runJob.getID(); in testProcessTreeCleanupOfKilledTask2()
273 runJob.killTask(taskAttID, false); in testProcessTreeCleanupOfKilledTask2()
287 runJob.killJob(); in testProcessTreeCleanupOfKilledTask2()
333 RunningJob runJob = client.submitJob(jobConf); in testProcessTreeCleanupOfFailedTask1() local
334 JobID id = runJob.getID(); in testProcessTreeCleanupOfFailedTask1()
436 RunningJob runJob = client.submitJob(jobConf); in testProcessTreeCleanupOfFailedTask2() local
[all …]
|
| H A D | TestChildsKillingOfMemoryExceedsTask.java | 132 RunningJob runJob = client.submitJob(jobConf); in testProcessTreeCleanupAfterJobKilled() local
133 JobID id = runJob.getID(); in testProcessTreeCleanupAfterJobKilled()
180 String[] taskDiagnostics = runJob.getTaskDiagnostics(tAttID); in testProcessTreeCleanupAfterJobKilled()
189 runJob.killJob(); in testProcessTreeCleanupAfterJobKilled()
250 RunningJob runJob = client.submitJob(jobConf); in testProcessTreeCleanupOfFailedTask() local
251 JobID id = runJob.getID(); in testProcessTreeCleanupOfFailedTask()
297 String[] taskDiagnostics = runJob.getTaskDiagnostics(tAttID); in testProcessTreeCleanupOfFailedTask()
|
| H A D | TestLinuxTaskControllerOtherUser.java | 91 RunningJob runJob = null; in testSubmitJobDifferentUserJobClient() local
102 runJob = proxyUGI.doAs( in testSubmitJobDifferentUserJobClient()
115 Assert.assertNull("Job is still running", runJob); in testSubmitJobDifferentUserJobClient()
|
| /dports/polish/kadu/kadu-4.3/kadu-core/avatars/ |
| H A D | avatar-job-manager.cpp | 59 QTimer::singleShot(0, this, SLOT(runJob())); in scheduleJob()
62 void AvatarJobManager::runJob() in runJob() function in AvatarJobManager
80 runner->runJob(); in runJob()
|
| /dports/net/kio-gdrive/kio-gdrive-21.12.3/src/ |
| H A D | kio_gdrive.cpp | 156 if (runJob(aboutFetch, url, accountId)) { in fileSystemFreeSpace()
389 return runJob(createJob, url, accountId); in createSharedDrive()
562 if (!runJob(fetchJob, url, accountId)) { in resolveFileIdFromPath()
739 if (!runJob(fileFetchJob, url, accountId)) { in listDir()
811 if (runJob(createJob, url, accountId)) { in mkdir()
881 if (!runJob(fileFetchJob, url, accountId)) { in stat()
955 if (!runJob(contentJob, url, accountId)) { in get()
1049 if (!runJob(fetchJob, url, accountId)) { in putUpdate()
1069 if (!runJob(modifyJob, url, accountId)) { in putUpdate()
1116 if (!runJob(createJob, url, accountId)) { in putCreate()
[all …]
|
| /dports/games/xonotic/Xonotic/misc/tools/NexuizDemoRecorder/main/src/main/java/com/nexuiz/demorecorder/application/ |
| H A D | DemoRecorderApplication.java | 164 this.poolExecutor.runJob(currentJob); in startRecording()
169 this.poolExecutor.runJob(new RecordsDoneJob(this)); in startRecording()
178 this.poolExecutor.runJob(currentJob); in recordSelectedJobs()
183 this.poolExecutor.runJob(new RecordsDoneJob(this)); in recordSelectedJobs()
192 this.poolExecutor.runJob(new EncoderJob(currentJob, plugin)); in executePluginForSelectedJobs()
197 this.poolExecutor.runJob(new RecordsDoneJob(this)); in executePluginForSelectedJobs()
214 this.poolExecutor.runJob(new RecordsDoneJob(this)); in stopRecording()
|
| /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 | TestMiniMRProxyUser.java | 123 RunningJob runJob = jobClient.submitJob(jobConf); in mrRun() local
124 runJob.waitForCompletion(); in mrRun()
125 assertTrue(runJob.isComplete()); in mrRun()
126 assertTrue(runJob.isSuccessful()); in mrRun()
|
| /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 | TestMRCJCJobClient.java | 36 private String runJob() throws Exception { in runJob() method in TestMRCJCJobClient
64 return JobClient.runJob(conf).getID().toString(); in runJob()
80 String jobId = runJob(); in testJobClient()
|
| H A D | TestReduceFetch.java | 43 Counters c = runJob(job); in testReduceFromDisk()
63 Counters c = runJob(job); in testReduceFromMem()
|
| H A D | TestMapRed.java | 368 JobClient.runJob(conf); in testNullKeys()
417 RunningJob rj = JobClient.runJob(conf); in checkCompression()
537 JobClient.runJob(genJob); in launch()
583 JobClient.runJob(checkJob); in launch()
607 JobClient.runJob(mergeJob); in launch()
730 runJob(100); in testSmallInput()
735 runJob(1000); in testBiggerInput()
738 public void runJob(int items) { in runJob() method in TestMapRed
779 JobClient.runJob(conf); in runJob()
|
| H A D | UtilsForTests.java | 562 static RunningJob runJob(JobConf conf, Path inDir, Path outDir) in runJob() method in UtilsForTests
564 return runJob(conf, inDir, outDir, conf.getNumMapTasks(), conf.getNumReduceTasks()); in runJob()
568 static RunningJob runJob(JobConf conf, Path inDir, Path outDir, int numMaps, in runJob() method in UtilsForTests
575 return runJob(conf, inDir, outDir, numMaps, numReds, input); in runJob()
579 static RunningJob runJob(JobConf conf, Path inDir, Path outDir, int numMaps, in runJob() method in UtilsForTests
617 RunningJob job = UtilsForTests.runJob(conf, inDir, outDir); in runJobSucceed()
642 RunningJob job = UtilsForTests.runJob(conf, inDir, outDir); in runJobFail()
667 RunningJob job = UtilsForTests.runJob(conf, inDir, outDir); in runJobKill()
|
| /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/security/ssl/ |
| H A D | TestEncryptedShuffle.java | 156 RunningJob runJob = jobClient.submitJob(jobConf); in encryptedShuffleWithCerts() local
157 runJob.waitForCompletion(); in encryptedShuffleWithCerts()
158 Assert.assertTrue(runJob.isComplete()); in encryptedShuffleWithCerts()
159 Assert.assertTrue(runJob.isSuccessful()); in encryptedShuffleWithCerts()
|
| /dports/x11/kf5-krunner/krunner-5.89.0/src/ |
| H A D | runnerjobs.cpp | 175 auto runJob = job.dynamicCast<FindMatchesJob>(); in jobDone() local
177 if (!runJob) { in jobDone()
181 m_jobs.remove(runJob); in jobDone()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/examples/org/apache/hadoop/examples/ |
| H A D | Grep.java | 69 JobClient.runJob(grepJob); in run()
84 JobClient.runJob(sortJob); in run()
|
| /dports/net-mgmt/nagios-check_bacula9/bacula-9.6.7/src/qt-console/jobs/ |
| H A D | jobs.cpp | 49 this, SLOT(runJob())); in Jobs()
193 connect(actionRunJob, SIGNAL(triggered()), this, SLOT(runJob())); in createContextMenu()
261 void Jobs::runJob() in runJob() function in Jobs
|
| /dports/net-mgmt/nagios-check_bacula11/bacula-11.0.5/src/qt-console/jobs/ |
| H A D | jobs.cpp | 49 this, SLOT(runJob())); in Jobs()
193 connect(actionRunJob, SIGNAL(triggered()), this, SLOT(runJob())); in createContextMenu()
261 void Jobs::runJob() in runJob() function in Jobs
|