cascading.tap.hadoop.util
Class TempHfs

java.lang.Object
  extended by cascading.tap.Tap<JobConf,RecordReader,OutputCollector>
      extended by cascading.tap.hadoop.Hfs
          extended by cascading.tap.hadoop.util.TempHfs
All Implemented Interfaces:
cascading.flow.FlowElement, cascading.tap.type.FileType<JobConf>, 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, TEMPORARY_DIRECTORY
 
Constructor Summary
TempHfs(JobConf conf, String name, boolean isNull)
          Constructor TempHfs creates a new TempHfs instance.
TempHfs(JobConf conf, String name, Class<? extends cascading.scheme.Scheme> schemeClass)
          Constructor TempDfs creates a new TempDfs instance.
TempHfs(JobConf conf, String name, Class<? extends cascading.scheme.Scheme> schemeClass, boolean unique)
           
 
Method Summary
 boolean equals(Object object)
           
 Class<? extends cascading.scheme.Scheme> getSchemeClass()
           
 int hashCode()
           
 boolean isTemporary()
           
 cascading.flow.planner.Scope outgoingScopeFor(Set<cascading.flow.planner.Scope> incomingScopes)
           
 String toString()
           
 
Methods inherited from class cascading.tap.hadoop.Hfs
applySourceConfInitIdentifiers, createResource, deleteChildResource, deleteResource, getBlockSize, getChildIdentifiers, getChildIdentifiers, getCombinedInputSafeMode, getDefaultFileSystem, getDefaultFileSystemURIScheme, getFileSystem, getFullIdentifier, getIdentifier, getLocalModeScheme, getModifiedTime, getPath, getReplication, getSize, getTemporaryDirectory, getTempPath, getURIScheme, getUseCombinedInput, isDirectory, makeTemporaryPathDirString, makeURIScheme, openForRead, openForWrite, resourceExists, setStringPath, setTemporaryDirectory, setUriScheme, sinkConfInit, sourceConfInit, sourceConfInitAddInputPath, sourceConfInitComplete, verifyNoDuplicates
 
Methods inherited from class cascading.tap.Tap
commitResource, createResource, deleteResource, flowConfInit, getConfigDef, getFullIdentifier, getModifiedTime, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hasStepConfigDef, id, isEquivalentTo, isKeep, isReplace, isSink, isSource, isUpdate, openForRead, openForWrite, 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(JobConf conf,
               String name,
               boolean isNull)
Constructor TempHfs creates a new TempHfs instance.

Parameters:
name - of type String
isNull - of type boolean

TempHfs

public TempHfs(JobConf conf,
               String name,
               Class<? extends cascading.scheme.Scheme> schemeClass)
Constructor TempDfs creates a new TempDfs instance.

Parameters:
name - of type String

TempHfs

public TempHfs(JobConf conf,
               String name,
               Class<? extends cascading.scheme.Scheme> schemeClass,
               boolean unique)
Method Detail

getSchemeClass

public Class<? extends cascading.scheme.Scheme> getSchemeClass()

outgoingScopeFor

public cascading.flow.planner.Scope outgoingScopeFor(Set<cascading.flow.planner.Scope> incomingScopes)
Specified by:
outgoingScopeFor in interface cascading.flow.FlowElement
Overrides:
outgoingScopeFor in class cascading.tap.Tap<JobConf,RecordReader,OutputCollector>

isTemporary

public boolean isTemporary()
Overrides:
isTemporary in class cascading.tap.Tap<JobConf,RecordReader,OutputCollector>

toString

public String toString()
Overrides:
toString in class cascading.tap.Tap<JobConf,RecordReader,OutputCollector>

equals

public boolean equals(Object object)
Overrides:
equals in class cascading.tap.Tap<JobConf,RecordReader,OutputCollector>

hashCode

public int hashCode()
Overrides:
hashCode in class cascading.tap.Tap<JobConf,RecordReader,OutputCollector>


Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.