This project has retired. For details please refer to its Attic page.
ImmutableOutputCommitter xref
View Javadoc

1   /*
2    * Licensed to the Apache Software Foundation (ASF) under one
3    * or more contributor license agreements.  See the NOTICE file
4    * distributed with this work for additional information
5    * regarding copyright ownership.  The ASF licenses this file
6    * to you under the Apache License, Version 2.0 (the
7    * "License"); you may not use this file except in compliance
8    * with the License.  You may obtain a copy of the License at
9    *
10   *     http://www.apache.org/licenses/LICENSE-2.0
11   *
12   * Unless required by applicable law or agreed to in writing, software
13   * distributed under the License is distributed on an "AS IS" BASIS,
14   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15   * See the License for the specific language governing permissions and
16   * limitations under the License.
17   */
18  
19  package org.apache.giraph.bsp;
20  
21  import java.io.IOException;
22  
23  import org.apache.hadoop.mapreduce.JobContext;
24  import org.apache.hadoop.mapreduce.OutputCommitter;
25  import org.apache.hadoop.mapreduce.TaskAttemptContext;
26  
27  /**
28   * This output committer doesn't do anything, meant for the case
29   * where output isn't desired, or as a base for not using
30   * FileOutputCommitter.
31   */
32  public class ImmutableOutputCommitter extends OutputCommitter {
33    @Override
34    public void abortTask(TaskAttemptContext context) throws IOException {
35    }
36  
37    @Override
38    public void commitTask(TaskAttemptContext context) throws IOException {
39    }
40  
41    @Override
42    public boolean needsTaskCommit(TaskAttemptContext context)
43      throws IOException {
44      return false;
45    }
46  
47    @Override
48    public void setupJob(JobContext context) throws IOException {
49    }
50  
51    @Override
52    public void setupTask(TaskAttemptContext context) throws IOException {
53    }
54  
55  /*if[HADOOP_NON_SECURE]
56    @Override
57    public void cleanupJob(JobContext jobContext) throws IOException {
58    }
59  
60  else[HADOOP_NON_SECURE]*/
61  /*end[HADOOP_NON_SECURE]*/
62    @Override
63    public void commitJob(JobContext jobContext) throws IOException {
64    }
65  }