Home
last modified time | relevance | path

Searched refs:needsTaskCommit (Results 1 – 23 of 23) sorted by relevance

/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/
H A DOutputCommitter.java115 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 DFileOutputCommitter.java206 public boolean needsTaskCommit(TaskAttemptContext context) in needsTaskCommit() method in FileOutputCommitter
H A DTask.java902 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 DOutputCommitter.java145 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 DFileOutputCommitter.java181 public boolean needsTaskCommit(TaskAttemptContext context) in needsTaskCommit() method in FileOutputCommitter
183 return getWrapped(context).needsTaskCommit(context, getTaskAttemptPath(context)); in needsTaskCommit()
H A DTask.java1085 commitRequired = committer.needsTaskCommit(taskContext); in isCommitRequired()
/dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapreduce/
H A DOutputCommitter.java118 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 DTestFileOutputCommitter.java110 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 DOutputCommitter.java144 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 DTableOutputCommitter.java49 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 DNullOutputFormat.java51 public boolean needsTaskCommit(TaskAttemptContext taskContext) { in getOutputCommitter()
H A DFileOutputCommitter.java264 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 DFileOutputCommitter.java528 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 DNullOutputFormat.java56 public boolean needsTaskCommit(TaskAttemptContext taskContext) { in getOutputCommitter()
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/mapred/
H A DSparkHadoopMapRedUtil.scala61 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 DCustomOutputCommitter.java64 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 DTestMROutputFormat.java164 public boolean needsTaskCommit(TaskAttemptContext taskContext)
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/mapreduce/
H A DTestMROutputFormat.java161 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 DTestTaskCommit.java69 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 DTestTaskCommit.java69 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 DPairRDDFunctionsSuite.scala748 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 DMRApp.java649 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 DTestJobImpl.java983 public boolean needsTaskCommit(TaskAttemptContext taskContext) in needsTaskCommit() method in TestJobImpl.StubbedOutputCommitter