public class DistCacheTap extends BaseDistCacheTap
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CASCADING_LOCAL_RESOURCES |
static java.lang.String |
CASCADING_REMOTE_RESOURCES |
metaInfo, original
Constructor and Description |
---|
DistCacheTap(Tap<Configuration,RecordReader,OutputCollector> original) |
Modifier and Type | Method and Description |
---|---|
protected void |
addLocalCacheFiles(Configuration conf,
java.net.URI uri) |
protected Path[] |
getLocalCacheFiles(FlowProcess<? extends Configuration> flowProcess) |
openForRead, sourceConfInit
commitResource, createResource, createResource, deleteResource, deleteResource, flowConfInit, getConfigDef, getFullIdentifier, getFullIdentifier, getIdentifier, getMetaInfo, getModifiedTime, getModifiedTime, getNodeConfigDef, getOriginal, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hasNodeConfigDef, hasStepConfigDef, isKeep, isReplace, isSink, isSource, isTemporary, isUpdate, openForRead, openForWrite, openForWrite, outgoingScopeFor, prepareResourceForRead, prepareResourceForWrite, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, resourceExists, retrieveSinkFields, retrieveSourceFields, rollbackResource, setMetaInfo, setOriginal, sinkConfInit, toString
entryStream, entryStream, entryStreamCopy, entryStreamCopy, equals, hashCode, id, openForReadUnchecked, setScheme, spliterator, splititerator, taps, tupleStream, tupleStream, tupleStreamCopy, tupleStreamCopy
public static final java.lang.String CASCADING_LOCAL_RESOURCES
public static final java.lang.String CASCADING_REMOTE_RESOURCES
public DistCacheTap(Tap<Configuration,RecordReader,OutputCollector> original)
protected Path[] getLocalCacheFiles(FlowProcess<? extends Configuration> flowProcess) throws java.io.IOException
getLocalCacheFiles
in class BaseDistCacheTap
java.io.IOException
protected void addLocalCacheFiles(Configuration conf, java.net.URI uri)
addLocalCacheFiles
in class BaseDistCacheTap
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.