public class MemorySinkTap
extends cascading.tap.hadoop.Lfs
| Constructor and Description |
|---|
MemorySinkTap(java.util.List<cascading.tuple.Tuple> tuples) |
MemorySinkTap(java.util.List<cascading.tuple.Tuple> tuples,
cascading.tuple.Fields fields) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
commitResource(org.apache.hadoop.mapred.JobConf conf) |
static java.lang.String |
getTempDir() |
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, verifyNoDuplicatescreateResource, 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, toStringpublic MemorySinkTap(java.util.List<cascading.tuple.Tuple> tuples,
cascading.tuple.Fields fields)
public MemorySinkTap(java.util.List<cascading.tuple.Tuple> tuples)
public static java.lang.String getTempDir()
public boolean commitResource(org.apache.hadoop.mapred.JobConf conf)
throws java.io.IOException
commitResource in class cascading.tap.Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector>java.io.IOException