com.twitter.maple.tap

Class MemorySinkTap

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.MemorySinkTap

All Implemented Interfaces:

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

public class MemorySinkTap
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
MemorySinkTap(java.util.List<cascading.tuple.Tuple> tuples)
MemorySinkTap(java.util.List<cascading.tuple.Tuple> tuples, cascading.tuple.Fields fields)

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

MemorySinkTap

public MemorySinkTap(java.util.List<cascading.tuple.Tuple> tuples,
                     cascading.tuple.Fields fields)

MemorySinkTap

public MemorySinkTap(java.util.List<cascading.tuple.Tuple> tuples)

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