org.springframework.xd.batch.item.hadoop

Class HdfsTextItemWriter<T>

java.lang.Object

org.springframework.batch.item.ItemStreamSupport

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

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

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

All Implemented Interfaces:

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

public class HdfsTextItemWriter<T>
extends AbstractHdfsItemWriter<T>
implements org.springframework.beans.factory.InitializingBean

Author:

Mark Pollack

Field Summary

Fields inherited from class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

logger

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	close()
org.apache.hadoop.fs.FileSystem	getFileSystem()
void	setLineAggregator(org.springframework.batch.item.file.transform.LineAggregator<T> lineAggregator) Public setter for the LineAggregator.
void	write(java.util.List<? extends T> items)

Methods inherited from class org.springframework.xd.batch.item.hadoop.AbstractHdfsItemWriter

getBaseFilename, getBasePath, getBytesWritten, getCounter, getCounterFromName, getFileName, getFileSuffix, getRolloverThresholdInBytes, incrementBytesWritten, incrementCounter, initializeCounterIfNecessary, reset, resetBytesWritten, setBaseFilename, setBasePath, setCounter, setFileSuffix, setRolloverThresholdInBytes

Methods inherited from class org.springframework.batch.item.ItemStreamSupport

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

open, update

Constructor Detail

HdfsTextItemWriter

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

Method Detail

write

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

Specified by:

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

Specified by:

write in class AbstractHdfsItemWriter<T>

Throws:

java.lang.Exception

getFileSystem

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

Specified by:

getFileSystem in class AbstractHdfsItemWriter<T>

close

public void close()

Specified by:

close in interface org.springframework.batch.item.ItemStream

Overrides:

close in class org.springframework.batch.item.ItemStreamSupport

setLineAggregator

public void setLineAggregator(org.springframework.batch.item.file.transform.LineAggregator<T> lineAggregator)

Public setter for the LineAggregator. This will be used to translate the item into a line for output.

Parameters:

lineAggregator - the LineAggregator to set

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception