org.springframework.xd.batch.item.hadoop

Class AbstractHdfsItemWriter<T>

java.lang.Object

org.springframework.batch.item.ItemStreamSupport

org.springframework.batch.item.support.AbstractItemStreamItemWriter<T>

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

All Implemented Interfaces:

org.springframework.batch.item.ItemStream, org.springframework.batch.item.ItemStreamWriter<T>, org.springframework.batch.item.ItemWriter<T>

Direct Known Subclasses:

HdfsTextItemWriter

public abstract class AbstractHdfsItemWriter<T>
extends org.springframework.batch.item.support.AbstractItemStreamItemWriter<T>

Author:

Mark Pollack

Field Summary

Fields

Modifier and Type	Field and Description
protected org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
AbstractHdfsItemWriter()

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()
protected void	reset()
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 org.springframework.batch.item.ItemStreamSupport

close, getExecutionContextKey, open, setExecutionContextName, setName, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.batch.item.ItemStream

close, open, update

Field Detail

logger

protected final org.slf4j.Logger logger

Constructor Detail

AbstractHdfsItemWriter

public AbstractHdfsItemWriter()

Method Detail

write

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

Throws:

java.lang.Exception

getFileSystem

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

initializeCounterIfNecessary

protected void initializeCounterIfNecessary()
                                     throws java.io.IOException

Throws:

java.io.IOException

reset

protected void reset()

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