cascading.tap.hadoop.util

Class TempHfs

java.lang.Object

cascading.tap.Tap<Configuration,RecordReader,OutputCollector>

cascading.tap.hadoop.Hfs

cascading.tap.hadoop.util.TempHfs

All Implemented Interfaces:

FlowElement, ScopedElement, FileType<Configuration>, Traceable, java.io.Serializable

public class TempHfs
extends Hfs

Class TempHfs creates a temporary Tap instance for use internally.

See Also:

Serialized Form

Field Summary

Fields inherited from class cascading.tap.hadoop.Hfs

stringPath

Constructor Summary

Constructors

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 Scheme> schemeClass) Constructor TempDfs creates a new TempDfs instance.
TempHfs(Configuration conf, java.lang.String name, java.lang.Class<? extends Scheme> schemeClass, boolean unique)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.Class<? extends Scheme>	getSchemeClass()
boolean	isTemporary()
Scope	outgoingScopeFor(java.util.Set<Scope> incomingScopes)
java.lang.String	toString()

Methods inherited from class cascading.tap.hadoop.Hfs

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

Methods inherited from class cascading.tap.Tap

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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TempHfs

public TempHfs(Configuration conf,
       java.lang.String name,
       boolean isNull)

Constructor TempHfs creates a new TempHfs instance.

Parameters:

name - of type String

isNull - of type boolean

TempHfs

public TempHfs(Configuration conf,
       java.lang.String name,
       java.lang.Class<? extends Scheme> schemeClass)

Constructor TempDfs creates a new TempDfs instance.

Parameters:

name - of type String

TempHfs

public TempHfs(Configuration conf,
       java.lang.String name,
       java.lang.Class<? extends Scheme> schemeClass,
       boolean unique)

Method Detail

getSchemeClass

public java.lang.Class<? extends Scheme> getSchemeClass()

outgoingScopeFor

public Scope outgoingScopeFor(java.util.Set<Scope> incomingScopes)

Specified by:

outgoingScopeFor in interface ScopedElement

Overrides:

outgoingScopeFor in class Tap<Configuration,RecordReader,OutputCollector>

isTemporary

public boolean isTemporary()

Overrides:

isTemporary in class Tap<Configuration,RecordReader,OutputCollector>

toString

public java.lang.String toString()

Overrides:

toString in class Tap<Configuration,RecordReader,OutputCollector>