oracle.spatial.hadoop.vector.mapreduce.output

Class WrapperOutputCommitter

java.lang.Object

FileOutputCommitter

oracle.spatial.hadoop.vector.mapreduce.output.WrapperOutputCommitter

Direct Known Subclasses:

JoinOutputCommitter, MergeFileOutputCommiter, MergeJsonFileOutputCommiter, MultipleJsonOutputMergeOutputCommitter, MultipleOutputMergeOutputCommitter, SpatialIndexOutputCommitter

public class WrapperOutputCommitter
extends FileOutputCommitter

Redirects all the method calls to a wrapped OutputCommitter.

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
WrapperOutputCommitter(OutputCommitter outCom, JobContext context) Creates a new instance

Method Summary

Modifier and Type	Method and Description
void	abortJob(JobContext context, State state)
void	abortTask(TaskAttemptContext context)
void	abortTask(TaskAttemptContext context, Path path)
void	cleanupJob(JobContext context)
void	commitJob(JobContext context)
void	commitTask(TaskAttemptContext context)
void	commitTask(TaskAttemptContext context, Path path)
Path	getCommittedTaskPath(TaskAttemptContext context)
Path	getJobAttemptPath(JobContext context)
Path	getTaskAttemptPath(TaskAttemptContext context)
Path	getWorkPath()
boolean	isRecoverySupported()
boolean	isRecoverySupported(JobContext context)
boolean	needsTaskCommit(TaskAttemptContext context)
boolean	needsTaskCommit(TaskAttemptContext context, Path path)
void	recoverTask(TaskAttemptContext context)
void	setupJob(JobContext context)
void	setupTask(TaskAttemptContext context)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WrapperOutputCommitter

public WrapperOutputCommitter(OutputCommitter outCom,
                              JobContext context)
                       throws java.io.IOException

Creates a new instance

Parameters:

outCom - the wrapped output committer

context - a job context

Throws:

java.io.IOException

Method Detail

abortJob

public void abortJob(JobContext context,
                     State state)
              throws java.io.IOException

Throws:

java.io.IOException

abortTask

public void abortTask(TaskAttemptContext context)
               throws java.io.IOException

Throws:

java.io.IOException

abortTask

public void abortTask(TaskAttemptContext context,
                      Path path)
               throws java.io.IOException

Throws:

java.io.IOException

cleanupJob

public void cleanupJob(JobContext context)
                throws java.io.IOException

Throws:

java.io.IOException

commitJob

public void commitJob(JobContext context)
               throws java.io.IOException

Throws:

java.io.IOException

commitTask

public void commitTask(TaskAttemptContext context)
                throws java.io.IOException

Throws:

java.io.IOException

commitTask

public void commitTask(TaskAttemptContext context,
                       Path path)
                throws java.io.IOException

Throws:

java.io.IOException

getCommittedTaskPath

public Path getCommittedTaskPath(TaskAttemptContext context)

getJobAttemptPath

public Path getJobAttemptPath(JobContext context)

getTaskAttemptPath

public Path getTaskAttemptPath(TaskAttemptContext context)

getWorkPath

public Path getWorkPath()
                 throws java.io.IOException

Throws:

java.io.IOException

isRecoverySupported

public boolean isRecoverySupported()

isRecoverySupported

public boolean isRecoverySupported(JobContext context)
                            throws java.io.IOException

Throws:

java.io.IOException

needsTaskCommit

public boolean needsTaskCommit(TaskAttemptContext context)
                        throws java.io.IOException

Throws:

java.io.IOException

needsTaskCommit

public boolean needsTaskCommit(TaskAttemptContext context,
                               Path path)
                        throws java.io.IOException

Throws:

java.io.IOException

recoverTask

public void recoverTask(TaskAttemptContext context)
                 throws java.io.IOException

Throws:

java.io.IOException

setupJob

public void setupJob(JobContext context)
              throws java.io.IOException

Throws:

java.io.IOException

setupTask

public void setupTask(TaskAttemptContext context)
               throws java.io.IOException

Throws:

java.io.IOException