org.kepler.hadoop.io.output

Class TokenOutputFormat

java.lang.Object

org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

org.kepler.hadoop.io.output.TokenOutputFormat

public class TokenOutputFormat
extends org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Hadoop OutputFormat for Ptolemy tokens.

Author:

Daniel Crawl

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TokenOutputFormat.TokenOutputCommitter

Constructor Summary

Constructors

Constructor and Description
TokenOutputFormat()

Method Summary

Modifier and Type	Method and Description
void	checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
org.apache.hadoop.mapreduce.OutputCommitter	getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Get the output commiter.
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>	getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) Get the record writer.

Methods inherited from class java.lang.Object

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

Constructor Detail

TokenOutputFormat

public TokenOutputFormat()

Method Detail

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                                      throws java.io.IOException,
                                                                                                                             java.lang.InterruptedException

Get the record writer.

Specified by:

getRecordWriter in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Throws:

java.io.IOException

java.lang.InterruptedException

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
                      throws java.io.IOException,
                             java.lang.InterruptedException

Specified by:

checkOutputSpecs in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Throws:

java.io.IOException

java.lang.InterruptedException

getOutputCommitter

public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                               throws java.io.IOException,
                                                                      java.lang.InterruptedException

Get the output commiter.

Specified by:

getOutputCommitter in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable>

Throws:

java.io.IOException

java.lang.InterruptedException