public abstract class BaseDistCacheTap extends DecoratorTap<Void,Configuration,RecordReader,OutputCollector>
metaInfo, original
Constructor and Description |
---|
BaseDistCacheTap(Tap<Configuration,RecordReader,OutputCollector> original) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
addLocalCacheFiles(Configuration conf,
URI uri) |
protected abstract Path[] |
getLocalCacheFiles(FlowProcess<? extends Configuration> flowProcess) |
TupleEntryIterator |
openForRead(FlowProcess<? extends Configuration> flowProcess,
RecordReader input) |
void |
sourceConfInit(FlowProcess<? extends Configuration> process,
Configuration conf) |
commitResource, createResource, createResource, deleteResource, deleteResource, flowConfInit, getConfigDef, getFullIdentifier, getFullIdentifier, getIdentifier, getMetaInfo, getModifiedTime, getModifiedTime, getNodeConfigDef, getOriginal, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hasNodeConfigDef, hasStepConfigDef, isEquivalentTo, 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 BaseDistCacheTap(Tap<Configuration,RecordReader,OutputCollector> original)
public void sourceConfInit(FlowProcess<? extends Configuration> process, Configuration conf)
sourceConfInit
in class DecoratorTap<Void,Configuration,RecordReader,OutputCollector>
public TupleEntryIterator openForRead(FlowProcess<? extends Configuration> flowProcess, RecordReader input) throws IOException
openForRead
in class DecoratorTap<Void,Configuration,RecordReader,OutputCollector>
IOException
protected abstract Path[] getLocalCacheFiles(FlowProcess<? extends Configuration> flowProcess) throws IOException
IOException
protected abstract void addLocalCacheFiles(Configuration conf, URI uri)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.