public class TempHfs extends Hfs
Tap
instance for use internally.stringPath
Constructor and Description |
---|
TempHfs(Configuration conf,
java.lang.String name,
boolean isNull)
Constructor TempHfs creates a new TempHfs instance.
|
TempHfs(Configuration conf,
java.lang.String name,
java.lang.Class<? extends cascading.scheme.Scheme> schemeClass)
Constructor TempDfs creates a new TempDfs instance.
|
TempHfs(Configuration conf,
java.lang.String name,
java.lang.Class<? extends cascading.scheme.Scheme> schemeClass,
boolean unique) |
Modifier and Type | Method and Description |
---|---|
java.lang.Class<? extends cascading.scheme.Scheme> |
getSchemeClass() |
boolean |
isTemporary() |
cascading.flow.planner.Scope |
outgoingScopeFor(java.util.Set<cascading.flow.planner.Scope> incomingScopes) |
java.lang.String |
toString() |
applySourceConfInitIdentifiers, createResource, deleteChildResource, deleteChildResource, deleteResource, getBlockSize, getBlockSize, getChildIdentifiers, getChildIdentifiers, getChildIdentifiers, getChildIdentifiers, getCombinedInputSafeMode, getDefaultFileSystem, getDefaultFileSystemURIScheme, getFileStatus, 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, sourceConfInitAddInputPaths, sourceConfInitComplete, verifyNoDuplicates
commitResource, createResource, deleteResource, equals, flowConfInit, getConfigDef, getFullIdentifier, getModifiedTime, getNodeConfigDef, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasNodeConfigDef, hasStepConfigDef, id, isKeep, isReplace, isSink, isSource, isUpdate, openForRead, openForWrite, prepareResourceForRead, prepareResourceForWrite, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, retrieveSinkFields, retrieveSourceFields, rollbackResource, setScheme, taps
public TempHfs(Configuration conf, java.lang.String name, boolean isNull)
name
- of type StringisNull
- of type booleanpublic TempHfs(Configuration conf, java.lang.String name, java.lang.Class<? extends cascading.scheme.Scheme> schemeClass)
name
- of type Stringpublic TempHfs(Configuration conf, java.lang.String name, java.lang.Class<? extends cascading.scheme.Scheme> schemeClass, boolean unique)
public java.lang.Class<? extends cascading.scheme.Scheme> getSchemeClass()
public cascading.flow.planner.Scope outgoingScopeFor(java.util.Set<cascading.flow.planner.Scope> incomingScopes)
outgoingScopeFor
in interface cascading.flow.planner.ScopedElement
outgoingScopeFor
in class cascading.tap.Tap<Configuration,RecordReader,OutputCollector>
public boolean isTemporary()
isTemporary
in class cascading.tap.Tap<Configuration,RecordReader,OutputCollector>
public java.lang.String toString()
toString
in class cascading.tap.Tap<Configuration,RecordReader,OutputCollector>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.