oracle.spatial.hadoop.vector.mapreduce.output

Class WrapperOutputFormat<V,K>

java.lang.Object

<any>

oracle.spatial.hadoop.vector.mapreduce.output.WrapperOutputFormat<V,K>

Type Parameters:

V - The type of the input keys

K - The type of the input values

public class WrapperOutputFormat<V,K>
extends <any>

A wrapper for a FileOutputFormat. An OutputCommitter can be assigned by wrapping it using a WrapperOutputCommitter.

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
WrapperOutputFormat()

Method Summary

Modifier and Type	Method and Description
void	checkOutputSpecs(JobContext context)
Path	getDefaultWorkFile(TaskAttemptContext context, java.lang.String extension)
OutputCommitter	getOutputCommitter(TaskAttemptContext context)
<any>	getOutputFormat(Configuration conf) Gets an instance of the wrapped output format
static <K,V> java.lang.Class<? extends <any>>	getOutputFormatClass(Configuration conf) Gets the wrapped OutputFormat class
<any>	getRecordWriter(TaskAttemptContext context)
WrapperOutputCommitter	getWrapperOutputCommitter(OutputCommitter intOutCom, JobContext context) Gets an instance of the WrapperOutputCommitter
static java.lang.Class<? extends WrapperOutputCommitter>	getWrapperOutputCommitterClass(Configuration conf) Gets the WrapperOutputCommitter that contains the final output committer
static <K,V> void	setOutputFormatClass(Configuration conf, java.lang.Class<? extends <any>> outputFormatClass) Sets the OutputFormat class to be wrapped
static void	setWrapperOutputCommitterClass(Configuration conf, java.lang.Class<? extends WrapperOutputCommitter> outComClass) Sets the WrapperOutputCommitter that contains the final output committer

Methods inherited from class java.lang.Object

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

Constructor Detail

WrapperOutputFormat

public WrapperOutputFormat()

Method Detail

checkOutputSpecs

public void checkOutputSpecs(JobContext context)
                      throws FileAlreadyExistsException,
                             java.io.IOException

Throws:

FileAlreadyExistsException

java.io.IOException

getDefaultWorkFile

public Path getDefaultWorkFile(TaskAttemptContext context,
                               java.lang.String extension)
                        throws java.io.IOException

Throws:

java.io.IOException

getOutputCommitter

public OutputCommitter getOutputCommitter(TaskAttemptContext context)
                                   throws java.io.IOException

Throws:

java.io.IOException

getOutputFormat

public <any> getOutputFormat(Configuration conf)

Gets an instance of the wrapped output format

Parameters:

conf -

Returns:

getOutputFormatClass

public static <K,V> java.lang.Class<? extends <any>> getOutputFormatClass(Configuration conf)

Gets the wrapped OutputFormat class

Parameters:

conf -

Returns:

getRecordWriter

public <any> getRecordWriter(TaskAttemptContext context)
                      throws java.io.IOException,
                             java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getWrapperOutputCommitter

public WrapperOutputCommitter getWrapperOutputCommitter(OutputCommitter intOutCom,
                                                        JobContext context)
                                                 throws java.lang.Exception

Gets an instance of the WrapperOutputCommitter

Parameters:

intOutCom -

context -

Returns:

Throws:

java.lang.Exception

getWrapperOutputCommitterClass

public static java.lang.Class<? extends WrapperOutputCommitter> getWrapperOutputCommitterClass(Configuration conf)

Gets the WrapperOutputCommitter that contains the final output committer

Parameters:

conf -

Returns:

setOutputFormatClass

public static <K,V> void setOutputFormatClass(Configuration conf,
                                              java.lang.Class<? extends <any>> outputFormatClass)

Sets the OutputFormat class to be wrapped

Parameters:

conf -

outputFormatClass -

setWrapperOutputCommitterClass

public static void setWrapperOutputCommitterClass(Configuration conf,
                                                  java.lang.Class<? extends WrapperOutputCommitter> outComClass)

Sets the WrapperOutputCommitter that contains the final output committer

Parameters:

conf -

outComClass -