|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.tap.Tap cascading.tap.Hfs cascading.tap.Lfs
public class Lfs
Class Lfs is a Tap
class that provides access to the Local File System via Hadoop.
Tap
instance in a Flow
will force a portion of not the whole Flow to be executed
in "local" mode forcing 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.
Constructor Summary | |
---|---|
Lfs(Fields fields,
String stringPath)
Constructor Lfs creates a new Lfs instance. |
|
Lfs(Fields fields,
String stringPath,
SinkMode sinkMode)
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 replace)
Constructor Lfs creates a new Lfs instance. |
|
Lfs(Scheme scheme,
String stringPath,
SinkMode sinkMode)
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 |
---|
deletePath, equals, getDefaultFileSystem, getDefaultFileSystemURIScheme, getPath, getPathModified, getQualifiedPath, getTemporaryDirectory, getTempPath, getURIScheme, hashCode, isWriteDirect, makeDirs, makeTemporaryPathDir, makeURIScheme, openForRead, openForWrite, pathExists, setTemporaryDirectory, setUriScheme, sinkInit, sourceInit, toString |
Methods inherited from class cascading.tap.Tap |
---|
flowInit, getIdentifier, getScheme, getSinkFields, getSinkMode, getSourceFields, isAppend, isEquivalentTo, isKeep, isReplace, isSink, isSource, isUpdate, outgoingScopeFor, resolveFields, resolveIncomingOperationFields, setScheme, setWriteDirect, sink, source, taps |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
@ConstructorProperties(value={"fields","stringPath"}) public Lfs(Fields fields, String stringPath)
fields
- of type FieldsstringPath
- of type String@ConstructorProperties(value={"scheme","stringPath"}) public Lfs(Scheme scheme, String stringPath)
scheme
- of type SchemestringPath
- of type String@ConstructorProperties(value={"scheme","stringPath","replace"}) public Lfs(Scheme scheme, String stringPath, boolean replace)
scheme
- of type SchemestringPath
- of type Stringreplace
- of type boolean@ConstructorProperties(value={"fields","stringPath","sinkMode"}) public Lfs(Fields fields, String stringPath, SinkMode sinkMode)
fields
- of type FieldsstringPath
- of type StringsinkMode
- of type SinkMode@ConstructorProperties(value={"scheme","stringPath","sinkMode"}) public Lfs(Scheme scheme, String stringPath, SinkMode sinkMode)
scheme
- of type SchemestringPath
- of type StringsinkMode
- of type SinkModeMethod Detail |
---|
protected void setStringPath(String stringPath)
setStringPath
in class Hfs
protected FileSystem getFileSystem(JobConf conf) throws IOException
getFileSystem
in class Hfs
IOException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |