com.twitter.maple.tap

Class StdoutTap

java.lang.Object

cascading.tap.Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector>

cascading.tap.hadoop.Hfs

cascading.tap.hadoop.Lfs

com.twitter.maple.tap.StdoutTap

All Implemented Interfaces:

cascading.flow.FlowElement, cascading.tap.type.FileType<org.apache.hadoop.mapred.JobConf>, cascading.util.Traceable, java.io.Serializable

public class StdoutTap
extends cascading.tap.hadoop.Lfs

See Also:

Serialized Form

Field Summary

Fields inherited from class cascading.tap.hadoop.Hfs

stringPath, TEMPORARY_DIRECTORY

Constructor Summary

Constructors

Constructor and Description
StdoutTap()

Method Summary

Modifier and Type	Method and Description
boolean	commitResource(org.apache.hadoop.mapred.JobConf conf)
static java.lang.String	getTempDir()

Methods inherited from class cascading.tap.hadoop.Lfs

getFileSystem, setStringPath

Methods inherited from class cascading.tap.hadoop.Hfs

applySourceConfInitIdentifiers, createResource, deleteChildResource, deleteResource, getBlockSize, getChildIdentifiers, getChildIdentifiers, getCombinedInputSafeMode, getDefaultFileSystem, getDefaultFileSystemURIScheme, getFullIdentifier, getIdentifier, getLocalModeScheme, getModifiedTime, getPath, getReplication, getSize, getTemporaryDirectory, getTempPath, getURIScheme, getUseCombinedInput, isDirectory, makeTemporaryPathDirString, makeURIScheme, openForRead, openForWrite, resourceExists, setTemporaryDirectory, setUriScheme, sinkConfInit, sourceConfInit, sourceConfInitAddInputPath, sourceConfInitComplete, verifyNoDuplicates

Methods inherited from class cascading.tap.Tap

createResource, deleteResource, equals, flowConfInit, getConfigDef, getFullIdentifier, getModifiedTime, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasStepConfigDef, id, isEquivalentTo, isKeep, isReplace, isSink, isSource, isTemporary, isUpdate, openForRead, openForWrite, outgoingScopeFor, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, retrieveSinkFields, retrieveSourceFields, rollbackResource, setScheme, taps, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StdoutTap

public StdoutTap()

Method Detail

getTempDir

public static java.lang.String getTempDir()

commitResource

public boolean commitResource(org.apache.hadoop.mapred.JobConf conf)
                       throws java.io.IOException

Overrides:

commitResource in class cascading.tap.Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector>

Throws:

java.io.IOException