/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/ |
H A D | OutputCommitter.java | 115 public abstract boolean needsTaskCommit(TaskAttemptContext taskContext) in needsTaskCommit() method in OutputCommitter 207 needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext in needsTaskCommit() method in OutputCommitter 209 return needsTaskCommit((TaskAttemptContext) taskContext); in needsTaskCommit()
|
H A D | FileOutputCommitter.java | 206 public boolean needsTaskCommit(TaskAttemptContext context) in needsTaskCommit() method in FileOutputCommitter
|
H A D | Task.java | 902 commitRequired = committer.needsTaskCommit(taskContext); in isCommitRequired()
|
/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 | 145 public abstract boolean needsTaskCommit(TaskAttemptContext taskContext) in needsTaskCommit() method in OutputCommitter 297 needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext in needsTaskCommit() method in OutputCommitter 299 return needsTaskCommit((TaskAttemptContext) taskContext); in needsTaskCommit()
|
H A D | FileOutputCommitter.java | 181 public boolean needsTaskCommit(TaskAttemptContext context) in needsTaskCommit() method in FileOutputCommitter 183 return getWrapped(context).needsTaskCommit(context, getTaskAttemptPath(context)); in needsTaskCommit()
|
H A D | Task.java | 1085 commitRequired = committer.needsTaskCommit(taskContext); in isCommitRequired()
|
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/ |
H A D | OutputCommitter.java | 118 public abstract boolean needsTaskCommit(TaskAttemptContext taskContext) in needsTaskCommit() method in OutputCommitter
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapred/ |
H A D | TestFileOutputCommitter.java | 110 if(committer.needsTaskCommit(tContext)) { in testRecoveryInternal() 226 if(committer.needsTaskCommit(tContext)) { in testCommitterInternal() 266 if(committer.needsTaskCommit(tContext)) { in testMapFileOutputCommitterInternal() 306 if(committer.needsTaskCommit(tContext)) { in testMapOnlyNoOutputInternal()
|
/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 | 144 public abstract boolean needsTaskCommit(TaskAttemptContext taskContext) in needsTaskCommit() method in OutputCommitter
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/ |
H A D | TableOutputCommitter.java | 49 public boolean needsTaskCommit(TaskAttemptContext arg0) throws IOException { in needsTaskCommit() method in TableOutputCommitter
|
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/lib/output/ |
H A D | NullOutputFormat.java | 51 public boolean needsTaskCommit(TaskAttemptContext taskContext) { in getOutputCommitter()
|
H A D | FileOutputCommitter.java | 264 public boolean needsTaskCommit(TaskAttemptContext context in needsTaskCommit() method in FileOutputCommitter
|
/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/lib/output/ |
H A D | FileOutputCommitter.java | 528 public boolean needsTaskCommit(TaskAttemptContext context in needsTaskCommit() method in FileOutputCommitter 530 return needsTaskCommit(context, null); in needsTaskCommit() 534 public boolean needsTaskCommit(TaskAttemptContext context, Path taskAttemptPath in needsTaskCommit() method in FileOutputCommitter
|
H A D | NullOutputFormat.java | 56 public boolean needsTaskCommit(TaskAttemptContext taskContext) { in getOutputCommitter()
|
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/mapred/ |
H A D | SparkHadoopMapRedUtil.scala | 61 if (committer.needsTaskCommit(mrTaskContext)) {
|
/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 | 64 public boolean needsTaskCommit(TaskAttemptContext taskContext) in needsTaskCommit() method in CustomOutputCommitter
|
/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/ |
H A D | TestMROutputFormat.java | 164 public boolean needsTaskCommit(TaskAttemptContext taskContext)
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapreduce/ |
H A D | TestMROutputFormat.java | 161 public boolean needsTaskCommit(TaskAttemptContext taskContext)
|
/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 | TestTaskCommit.java | 69 public boolean needsTaskCommit(TaskAttemptContext context) in needsTaskCommit() method in TestTaskCommit.CommitterThatAlwaysRequiresCommit
|
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapred/ |
H A D | TestTaskCommit.java | 69 public boolean needsTaskCommit(TaskAttemptContext context) in needsTaskCommit() method in TestTaskCommit.CommitterThatAlwaysRequiresCommit
|
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/rdd/ |
H A D | PairRDDFunctionsSuite.scala | 748 override def needsTaskCommit(taskContext: TaskAttemptContext): Boolean = true 792 def needsTaskCommit(p1: NewTaskAttempContext): Boolean = false method
|
/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 | MRApp.java | 649 public boolean needsTaskCommit(TaskAttemptContext taskContext)
|
/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 | 983 public boolean needsTaskCommit(TaskAttemptContext taskContext) in needsTaskCommit() method in TestJobImpl.StubbedOutputCommitter
|