org.springframework.xd.hadoop.fs

Class AbstractHdfsWriter

java.lang.Object

org.springframework.xd.hadoop.fs.AbstractHdfsWriter

All Implemented Interfaces:

HdfsWriter

Direct Known Subclasses:

HdfsTextFileWriter

public abstract class AbstractHdfsWriter
extends java.lang.Object
implements HdfsWriter

Logic for writing to files of a specified size or other strategies go here as they are shared across implementations

Author:

Mark Pollack

Constructor Summary

Constructors

Constructor and Description
AbstractHdfsWriter()

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getBaseFilename()
java.lang.String	getBasePath()
long	getBytesWritten()
long	getCounter()
protected int	getCounterFromName(java.lang.String shortName)
java.lang.String	getFileName()
java.lang.String	getFileSuffix()
abstract org.apache.hadoop.fs.FileSystem	getFileSystem()
long	getRolloverThresholdInBytes()
void	incrementBytesWritten(long bytesWritten)
void	incrementCounter()
protected void	initializeCounterIfNecessary()
void	resetBytesWritten()
void	setBaseFilename(java.lang.String baseFilename)
void	setBasePath(java.lang.String basePath)
void	setCounter(long value)
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

Methods inherited from interface org.springframework.xd.hadoop.fs.HdfsWriter

close, write

Constructor Detail

AbstractHdfsWriter

public AbstractHdfsWriter()

Method Detail

getFileSystem

public abstract org.apache.hadoop.fs.FileSystem getFileSystem()

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)

initializeCounterIfNecessary

protected void initializeCounterIfNecessary()

getCounterFromName

protected int getCounterFromName(java.lang.String shortName)

getCounter

public long getCounter()

setCounter

public void setCounter(long value)

incrementCounter

public void incrementCounter()

incrementBytesWritten

public void incrementBytesWritten(long bytesWritten)

resetBytesWritten

public void resetBytesWritten()

getBytesWritten

public long getBytesWritten()

getFileName

public java.lang.String getFileName()