org.springframework.xd.batch.item.hadoop

Class SimpleAbstractHdfsItemWriter<T>

java.lang.Object

org.springframework.xd.batch.item.hadoop.SimpleAbstractHdfsItemWriter<T>

All Implemented Interfaces:

org.springframework.batch.item.ItemWriter<T>

Direct Known Subclasses:

SimpleHdfsTextItemWriter

public abstract class SimpleAbstractHdfsItemWriter<T>
extends java.lang.Object
implements org.springframework.batch.item.ItemWriter<T>

Author:

Mark Pollack

Constructor Summary

Constructors

Constructor and Description
SimpleAbstractHdfsItemWriter()

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)
abstract void	write(java.util.List<? extends T> items)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleAbstractHdfsItemWriter

public SimpleAbstractHdfsItemWriter()

Method Detail

write

public abstract void write(java.util.List<? extends T> items)
                    throws java.lang.Exception

Specified by:

write in interface org.springframework.batch.item.ItemWriter<T>

Throws:

java.lang.Exception

getFileSystem

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

initializeCounterIfNecessary

protected void initializeCounterIfNecessary()

getCounterFromName

protected int getCounterFromName(java.lang.String shortName)

getRolloverThresholdInBytes

public long getRolloverThresholdInBytes()

setRolloverThresholdInBytes

public void setRolloverThresholdInBytes(long rolloverThresholdInBytes)

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)

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()