cascading.tap
Class Lfs

java.lang.Object
  cascading.tap.Tap
      cascading.tap.Hfs
          cascading.tap.Lfs

All Implemented Interfaces:

FlowElement, Serializable

public class Lfs
extends Hfs

Class Lfs is a Tap class that provides access to the Local File System via Hadoop.

Note that using a Lfs Tap instance in a Flow will force the flow to be executed in "local" mode force the flow to execute in the current JVM. Mixing with Dfs and other Tap types is possible, providing a means to implement complex file/data management functions.

Use Hfs if you need a Tap instance that inherits the default FileSystem used by Hadoop.

See Also:

Serialized Form

Constructor Summary

Lfs(Fields sourceFields, String stringPath)
Constructor Lfs creates a new Lfs instance.

Lfs(Scheme scheme, String stringPath)
Constructor Lfs creates a new Lfs instance.

Lfs(Scheme scheme, String stringPath, boolean deleteOnSinkInit)
Constructor Lfs creates a new Lfs instance.

Method Summary

protected FileSystem	getFileSystem(JobConf conf)
protected void	setStringPath(String stringPath)

Methods inherited from class cascading.tap.Hfs

containsFile, deletePath, equals, getDefaultFileSystem, getPath, getPathModified, getQualifiedPath, getTempPath, getURIScheme, hashCode, isDeleteOnSinkInit, isUseTapCollector, makeDirs, makeTemporaryPathDir, makeURIScheme, pathExists, setUriScheme, sinkInit, sourceInit, toString

Methods inherited from class cascading.tap.Tap

getScheme, getSinkFields, getSourceFields, isSink, isSource, openForRead, openForWrite, outgoingScopeFor, resolveFields, resolveIncomingOperationFields, setScheme, setUseTapCollector, sink, source, taps

Methods inherited from class java.lang.Object

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

Constructor Detail

Lfs

public Lfs(Fields sourceFields,
           String stringPath)

Constructor Lfs creates a new Lfs instance.

Parameters:

sourceFields - of type Fields

stringPath - of type String

Lfs

public Lfs(Scheme scheme,
           String stringPath)

Constructor Lfs creates a new Lfs instance.

Parameters:

scheme - of type Scheme

stringPath - of type String

Lfs

public Lfs(Scheme scheme,
           String stringPath,
           boolean deleteOnSinkInit)

Constructor Lfs creates a new Lfs instance.

Parameters:

scheme - of type Scheme

stringPath - of type String

deleteOnSinkInit - of type boolean

Method Detail

setStringPath

protected void setStringPath(String stringPath)

Overrides:

setStringPath in class Hfs

getFileSystem

protected FileSystem getFileSystem(JobConf conf)
                            throws IOException

Overrides:

getFileSystem in class Hfs

Throws:

IOException