public class DistCacheTap extends cascading.tap.hadoop.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
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 cascading.tap.hadoop.BaseDistCacheTap
java.io.IOException
protected void addLocalCacheFiles(Configuration conf, java.net.URI uri)
addLocalCacheFiles
in class cascading.tap.hadoop.BaseDistCacheTap
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.