| /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/ |
| H A D | OutputCommitter.java | 78 public abstract void setupJob(JobContext jobContext) throws IOException; in setupJob()
91 public void cleanupJob(JobContext jobContext) throws IOException { } in cleanupJob()
103 public void commitJob(JobContext jobContext) throws IOException { in commitJob()
118 public void abortJob(JobContext jobContext, JobStatus.State state) in abortJob()
205 public boolean isRecoverySupported(JobContext jobContext) throws IOException { in isRecoverySupported()
|
| /dports/multimedia/photofilmstrip/photofilmstrip-3.7.0/photofilmstrip/cli/ |
| H A D | Main.py | 42 def OnHandleJobBegin(self, jobContext): argument
45 def OnHandleJobDone(self, jobContext): argument
49 def OnHandleJobUpdate(self, jobContext, fields=None): argument
82 def OnHandleJobBegin(self, jobContext): argument
85 def OnHandleJobDone(self, jobContext): argument
88 def OnHandleJobUpdate(self, jobContext, fields=None): argument
|
| /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 | OutputCommitter.java | 80 public abstract void setupJob(JobContext jobContext) throws IOException; in setupJob()
93 public void cleanupJob(JobContext jobContext) throws IOException { } in cleanupJob()
105 public void commitJob(JobContext jobContext) throws IOException { in commitJob()
119 public void abortJob(JobContext jobContext, int status) in abortJob()
203 public boolean isRecoverySupported(JobContext jobContext) throws IOException { in isRecoverySupported()
231 public final void setupJob(org.apache.hadoop.mapreduce.JobContext jobContext in setupJob()
|
| /dports/multimedia/photofilmstrip/photofilmstrip-3.7.0/photofilmstrip/lib/jobimpl/ |
| H A D | IVisualJobHandler.py | 9 def OnHandleJobBegin(self, jobContext): argument
12 def OnHandleJobDone(self, jobContext): argument
15 def OnHandleJobUpdate(self, jobContext, fields=None): argument
|
| H A D | LogVisualJobHandler.py | 12 def OnHandleJobBegin(self, jobContext): argument
15 def OnHandleJobDone(self, jobContext): argument
18 def OnHandleJobUpdate(self, jobContext, fields=None): argument
|
| H A D | IWorkLoad.py | 9 def _Execute(self, jobContext): argument
15 def Run(self, jobContext): argument
|
| H A D | WxVisualJobHandler.py | 37 def OnHandleJobBegin(self, jobContext): argument
41 def OnHandleJobDone(self, jobContext): argument
48 def OnHandleJobUpdate(self, jobContext, fields=None): argument
52 def OnHandleJobInteraction(self, jobContext, evt): argument
|
| H A D | JobManager.py | 43 def Put(self, jobContext): argument
69 def SetActive(self, jobContext): argument
171 def EnqueueContext(self, jobContext): argument
|
| H A D | WorkLoad.py | 14 def _Execute(self, jobContext): argument
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
| H A D | OutputCommitter.java | 65 public abstract void setupJob(JobContext jobContext) throws IOException; in setupJob()
73 public void cleanupJob(JobContext jobContext) throws IOException { } in cleanupJob()
82 public void commitJob(JobContext jobContext) throws IOException { in commitJob()
94 public void abortJob(JobContext jobContext, int status) in abortJob()
144 public final void setupJob(org.apache.hadoop.mapreduce.JobContext jobContext in setupJob()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/ |
| H A D | OutputCommitter.java | 65 public abstract void setupJob(JobContext jobContext) throws IOException; in setupJob()
75 public void commitJob(JobContext jobContext) throws IOException { in commitJob()
97 public void abortJob(JobContext jobContext, JobStatus.State state) in abortJob()
|
| /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/commit/ |
| H A D | CommitterJobCommitEvent.java | 27 private JobContext jobContext; field in CommitterJobCommitEvent
29 public CommitterJobCommitEvent(JobId jobID, JobContext jobContext) { in CommitterJobCommitEvent()
|
| H A D | CommitterJobSetupEvent.java | 27 private JobContext jobContext; field in CommitterJobSetupEvent
29 public CommitterJobSetupEvent(JobId jobID, JobContext jobContext) { in CommitterJobSetupEvent()
|
| H A D | CommitterJobAbortEvent.java | 28 private JobContext jobContext; field in CommitterJobAbortEvent
31 public CommitterJobAbortEvent(JobId jobID, JobContext jobContext, in CommitterJobAbortEvent()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-distcp/src/test/java/org/apache/hadoop/tools/mapred/ |
| H A D | TestCopyCommitter.java | 110 JobContext jobContext = new JobContextImpl(taskAttemptContext.getConfiguration(), in testNoCommitAction() local
129 JobContext jobContext = new JobContextImpl(taskAttemptContext.getConfiguration(), in testPreserveStatus() local
181 JobContext jobContext = new JobContextImpl(taskAttemptContext.getConfiguration(), in testDeleteMissing() local
237 JobContext jobContext = new JobContextImpl(taskAttemptContext.getConfiguration(), in testDeleteMissingFlatInterleavedFiles() local
303 JobContext jobContext = new JobContextImpl(taskAttemptContext.getConfiguration(), in testAtomicCommitMissingFinal() local
343 JobContext jobContext = new JobContextImpl(taskAttemptContext.getConfiguration(), in testAtomicCommitExistingFinal() local
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/tools/distcp2/mapred/ |
| H A D | TestCopyCommitter.java | 124 JobContext jobContext = new JobContext(taskAttemptContext.getConfiguration(), in testNoCommitAction() local
143 JobContext jobContext = new JobContext(taskAttemptContext.getConfiguration(), in testPreserveStatus() local
193 JobContext jobContext = new JobContext(taskAttemptContext.getConfiguration(), in testDeleteMissing() local
249 JobContext jobContext = new JobContext(taskAttemptContext.getConfiguration(), in testDeleteMissingFlatInterleavedFiles() local
315 JobContext jobContext = new JobContext(taskAttemptContext.getConfiguration(), in testAtomicCommitMissingFinal() local
354 JobContext jobContext = new JobContext(taskAttemptContext.getConfiguration(), in testAtomicCommitExistingFinal() local
|
| /dports/multimedia/photofilmstrip/photofilmstrip-3.7.0/photofilmstrip/core/ |
| H A D | tasks.py | 38 def Run(self, jobContext): argument
59 def Run(self, jobContext): argument
78 def Run(self, jobContext): argument
106 def Run(self, jobContext): argument
137 def Run(self, jobContext): argument
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/ |
| H A D | CustomOutputCommitter.java | 41 public void setupJob(JobContext jobContext) throws IOException { in setupJob()
46 public void commitJob(JobContext jobContext) throws IOException { in commitJob()
52 public void abortJob(JobContext jobContext, int status) in abortJob()
|
| /dports/devel/qtcreator/qt-creator-opensource-src-5.0.3/tests/unit/unittest/ |
| H A D | clangasyncjob-base.h | 62 ClangBackEnd::JobContext jobContext; variable
|
| /dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/rdd/ |
| H A D | BinaryFileRDD.scala | 45 val jobContext = new JobContextImpl(conf, jobId) constant
|
| H A D | WholeTextFileRDD.scala | 48 val jobContext = new JobContextImpl(conf, jobId) constant
|
| /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/lib/input/ |
| H A D | TestMRCJCFileInputFormat.java | 98 JobContext jobContext = mock(JobContext.class); in testLastInputSplitAtSplitBoundary() local
114 JobContext jobContext = mock(JobContext.class); in testLastInputSplitExceedingSplitBoundary() local
130 JobContext jobContext = mock(JobContext.class); in testLastInputSplitSingleSplit() local
|
| /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/ |
| H A D | TestContextFactory.java | 32 JobContext jobContext; field in TestContextFactory
|
| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/lib/output/ |
| H A D | NullOutputFormat.java | 54 public void setupJob(JobContext jobContext) { } in getOutputCommitter()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapreduce/lib/input/ |
| H A D | TestKeyValueTextInputFormat.java | 90 JobContext jobContext = new JobContext(job.getConfiguration(), new JobID()); in testFormat() local
225 JobContext jobContext = new JobContext(job.getConfiguration(), new JobID()); in testGzip() local
|