org.springframework.xd.hadoop.fs

Class HdfsTextFileWriterFactory

java.lang.Object

org.springframework.xd.hadoop.fs.HdfsTextFileWriterFactory

All Implemented Interfaces:

HdfsWriterFactory

public class HdfsTextFileWriterFactory
extends java.lang.Object
implements HdfsWriterFactory

Author:

Mark Pollack

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	DEFAULT_BASE_FILENAME
static java.lang.String	DEFAULT_BASE_PATH
static java.lang.String	DEFAULT_FILE_SUFFIX
static long	DEFAULT_ROLLOVER_THRESHOLD_IN_BYTES

Constructor Summary

Constructors

Constructor and Description
HdfsTextFileWriterFactory(org.apache.hadoop.fs.FileSystem fileSystem)

Method Summary

Methods

Modifier and Type	Method and Description
HdfsWriter	createWriter()
java.lang.String	getBaseFilename()
java.lang.String	getBasePath()
java.lang.String	getFileSuffix()
long	getRolloverThresholdInBytes()
void	setBaseFilename(java.lang.String baseFilename)
void	setBasePath(java.lang.String basePath)
void	setFileSuffix(java.lang.String fileSuffix)
void	setRolloverThresholdInBytes(long rolloverThresholdInBytes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_BASE_FILENAME

public static final java.lang.String DEFAULT_BASE_FILENAME

See Also:

Constant Field Values

DEFAULT_BASE_PATH

public static final java.lang.String DEFAULT_BASE_PATH

See Also:

Constant Field Values

DEFAULT_FILE_SUFFIX

public static final java.lang.String DEFAULT_FILE_SUFFIX

See Also:

Constant Field Values

DEFAULT_ROLLOVER_THRESHOLD_IN_BYTES

public static long DEFAULT_ROLLOVER_THRESHOLD_IN_BYTES

Constructor Detail

HdfsTextFileWriterFactory

public HdfsTextFileWriterFactory(org.apache.hadoop.fs.FileSystem fileSystem)

Method Detail

getFileSuffix

public java.lang.String getFileSuffix()

setFileSuffix

public void setFileSuffix(java.lang.String fileSuffix)

getBaseFilename

public java.lang.String getBaseFilename()

setBaseFilename

public void setBaseFilename(java.lang.String baseFilename)

getBasePath

public java.lang.String getBasePath()

setBasePath

public void setBasePath(java.lang.String basePath)

getRolloverThresholdInBytes

public long getRolloverThresholdInBytes()

setRolloverThresholdInBytes

public void setRolloverThresholdInBytes(long rolloverThresholdInBytes)

createWriter

public HdfsWriter createWriter()

Specified by:

createWriter in interface HdfsWriterFactory