public class TempHfs extends Hfs
Tap
instance for use internally.stringPath
Constructor and Description |
---|
TempHfs(Configuration conf,
String name,
boolean isNull)
Constructor TempHfs creates a new TempHfs instance.
|
TempHfs(Configuration conf,
String name,
Class<? extends Scheme> schemeClass)
Constructor TempDfs creates a new TempDfs instance.
|
TempHfs(Configuration conf,
String name,
Class<? extends Scheme> schemeClass,
boolean unique) |
Modifier and Type | Method and Description |
---|---|
Class<? extends Scheme> |
getSchemeClass() |
boolean |
isTemporary() |
Scope |
outgoingScopeFor(Set<Scope> incomingScopes) |
String |
toString() |
applySourceConfInitIdentifiers, createResource, deleteChildResource, deleteChildResource, deleteResource, getBlockSize, getBlockSize, getChildIdentifiers, getChildIdentifiers, getChildIdentifiers, getChildIdentifiers, getCombinedInputSafeMode, getDefaultFileSystem, getDefaultFileSystemURIScheme, getFileSystem, getFullIdentifier, getIdentifier, getLocalModeScheme, getModifiedTime, getPath, getReplication, getReplication, getSize, getSize, getTempPath, getURIScheme, getUseCombinedInput, isDirectory, isDirectory, makeTemporaryPathDirString, makeURIScheme, openForRead, openForWrite, resetFileStatuses, resourceExists, setStringPath, setUriScheme, sinkConfInit, sourceConfInit, sourceConfInitAddInputPath, sourceConfInitComplete, verifyNoDuplicates
commitResource, createResource, deleteResource, equals, flowConfInit, getConfigDef, getFullIdentifier, getModifiedTime, getNodeConfigDef, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasNodeConfigDef, hasStepConfigDef, id, isEquivalentTo, isKeep, isReplace, isSink, isSource, isUpdate, openForRead, openForWrite, prepareResourceForRead, prepareResourceForWrite, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, retrieveSinkFields, retrieveSourceFields, rollbackResource, setScheme, taps
public TempHfs(Configuration conf, String name, boolean isNull)
name
- of type StringisNull
- of type booleanpublic TempHfs(Configuration conf, String name, Class<? extends Scheme> schemeClass)
name
- of type Stringpublic TempHfs(Configuration conf, String name, Class<? extends Scheme> schemeClass, boolean unique)
public Class<? extends Scheme> getSchemeClass()
public Scope outgoingScopeFor(Set<Scope> incomingScopes)
outgoingScopeFor
in interface FlowElement
outgoingScopeFor
in class Tap<Configuration,RecordReader,OutputCollector>
public boolean isTemporary()
isTemporary
in class Tap<Configuration,RecordReader,OutputCollector>
public String toString()
toString
in class Tap<Configuration,RecordReader,OutputCollector>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.