public abstract class BaseDistCacheTap extends DecoratorTap<java.lang.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,
java.net.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, 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<java.lang.Void,Configuration,RecordReader,OutputCollector>
public TupleEntryIterator openForRead(FlowProcess<? extends Configuration> flowProcess, RecordReader input) throws java.io.IOException
openForRead
in class DecoratorTap<java.lang.Void,Configuration,RecordReader,OutputCollector>
java.io.IOException
protected abstract Path[] getLocalCacheFiles(FlowProcess<? extends Configuration> flowProcess) throws java.io.IOException
java.io.IOException
protected abstract void addLocalCacheFiles(Configuration conf, java.net.URI uri)
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.