com.datasalt.pangool.tuplemr.mapred.lib.output
Class ProxyOutputFormat.ProxyOutputCommitter

java.lang.Object
  extended by org.apache.hadoop.mapreduce.OutputCommitter
      extended by org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
          extended by com.datasalt.pangool.tuplemr.mapred.lib.output.ProxyOutputFormat.ProxyOutputCommitter
Enclosing class:
ProxyOutputFormat

public class ProxyOutputFormat.ProxyOutputCommitter
extends org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter


Field Summary
 
Fields inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
TEMP_DIR_NAME
 
Constructor Summary
ProxyOutputFormat.ProxyOutputCommitter(org.apache.hadoop.fs.Path outputPath, org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
ProxyOutputFormat.ProxyOutputCommitter(org.apache.hadoop.fs.Path outputPath, org.apache.hadoop.mapreduce.TaskAttemptContext context, org.apache.hadoop.mapreduce.OutputCommitter committer)
           
 
Method Summary
 void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
           
 void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
           
 String getBaseDir()
           
 boolean needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
           
 void setupJob(org.apache.hadoop.mapreduce.JobContext jobContext)
           
 void setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
           
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
cleanupJob, getWorkPath
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ProxyOutputFormat.ProxyOutputCommitter

public ProxyOutputFormat.ProxyOutputCommitter(org.apache.hadoop.fs.Path outputPath,
                                              org.apache.hadoop.mapreduce.TaskAttemptContext context,
                                              org.apache.hadoop.mapreduce.OutputCommitter committer)
                                       throws IOException
Throws:
IOException

ProxyOutputFormat.ProxyOutputCommitter

public ProxyOutputFormat.ProxyOutputCommitter(org.apache.hadoop.fs.Path outputPath,
                                              org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                       throws IOException
Throws:
IOException
Method Detail

getBaseDir

public String getBaseDir()

setupJob

public void setupJob(org.apache.hadoop.mapreduce.JobContext jobContext)
              throws IOException
Overrides:
setupJob in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Throws:
IOException

setupTask

public void setupTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
               throws IOException
Overrides:
setupTask in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Throws:
IOException

needsTaskCommit

public boolean needsTaskCommit(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
                        throws IOException
Overrides:
needsTaskCommit in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Throws:
IOException

commitTask

public void commitTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
                throws IOException
Overrides:
commitTask in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter
Throws:
IOException

abortTask

public void abortTask(org.apache.hadoop.mapreduce.TaskAttemptContext taskContext)
Overrides:
abortTask in class org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter


Copyright © –2014 Datasalt Systems S.L.. All rights reserved.