public abstract class BaseDistCacheTap extends cascading.tap.DecoratorTap<java.lang.Void,Configuration,RecordReader,OutputCollector>
Constructor and Description |
---|
BaseDistCacheTap(cascading.tap.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(cascading.flow.FlowProcess<? extends Configuration> flowProcess) |
cascading.tuple.TupleEntryIterator |
openForRead(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
RecordReader input) |
void |
sourceConfInit(cascading.flow.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(cascading.tap.Tap<Configuration,RecordReader,OutputCollector> original)
public void sourceConfInit(cascading.flow.FlowProcess<? extends Configuration> process, Configuration conf)
sourceConfInit
in class cascading.tap.DecoratorTap<java.lang.Void,Configuration,RecordReader,OutputCollector>
public cascading.tuple.TupleEntryIterator openForRead(cascading.flow.FlowProcess<? extends Configuration> flowProcess, RecordReader input) throws java.io.IOException
openForRead
in class cascading.tap.DecoratorTap<java.lang.Void,Configuration,RecordReader,OutputCollector>
java.io.IOException
protected abstract Path[] getLocalCacheFiles(cascading.flow.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.