1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.hadoop.hbase.mapreduce;
20
21 import java.io.IOException;
22
23 import org.apache.hadoop.hbase.classification.InterfaceAudience;
24 import org.apache.hadoop.hbase.classification.InterfaceStability;
25 import org.apache.hadoop.mapreduce.JobContext;
26 import org.apache.hadoop.mapreduce.OutputCommitter;
27 import org.apache.hadoop.mapreduce.TaskAttemptContext;
28
29
30
31
32 @InterfaceAudience.Public
33 @InterfaceStability.Stable
34 public class TableOutputCommitter extends OutputCommitter {
35
36 @Override
37 public void abortTask(TaskAttemptContext arg0) throws IOException {
38 }
39
40 @Override
41 public void cleanupJob(JobContext arg0) throws IOException {
42 }
43
44 @Override
45 public void commitTask(TaskAttemptContext arg0) throws IOException {
46 }
47
48 @Override
49 public boolean needsTaskCommit(TaskAttemptContext arg0) throws IOException {
50 return false;
51 }
52
53 @Override
54 public void setupJob(JobContext arg0) throws IOException {
55 }
56
57 @Override
58 public void setupTask(TaskAttemptContext arg0) throws IOException {
59 }
60
61 public boolean isRecoverySupported() {
62 return true;
63 }
64
65 public void recoverTask(TaskAttemptContext taskContext)
66 throws IOException
67 {
68 }
69 }