public class DistCacheTap extends cascading.tap.hadoop.BaseDistCacheTap
Modifier and Type | Field and Description |
---|---|
static String |
CASCADING_LOCAL_RESOURCES |
static 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,
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
public static final String CASCADING_LOCAL_RESOURCES
public static final String CASCADING_REMOTE_RESOURCES
public DistCacheTap(Tap<Configuration,RecordReader,OutputCollector> original)
protected Path[] getLocalCacheFiles(FlowProcess<? extends Configuration> flowProcess) throws IOException
getLocalCacheFiles
in class cascading.tap.hadoop.BaseDistCacheTap
IOException
protected void addLocalCacheFiles(Configuration conf, URI uri)
addLocalCacheFiles
in class cascading.tap.hadoop.BaseDistCacheTap
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.