org.springframework.xd.batch.item.hadoop

Class SimpleHdfsTextItemWriter<T>

java.lang.Object

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

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

All Implemented Interfaces:

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

public class SimpleHdfsTextItemWriter<T>
extends SimpleAbstractHdfsItemWriter<T>
implements org.springframework.beans.factory.InitializingBean

Author:

Mark Pollack

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	close()
void	copy(byte[] in, org.apache.hadoop.fs.FSDataOutputStream out) Simple not optimized copy
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.SimpleAbstractHdfsItemWriter

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleHdfsTextItemWriter

public SimpleHdfsTextItemWriter(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 SimpleAbstractHdfsItemWriter<T>

Throws:

java.lang.Exception

copy

public void copy(byte[] in,
        org.apache.hadoop.fs.FSDataOutputStream out)
          throws java.io.IOException

Simple not optimized copy

Throws:

java.io.IOException

getFileSystem

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

Specified by:

getFileSystem in class SimpleAbstractHdfsItemWriter<T>

close

public void close()

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