org.springframework.cloud.task.jdbchdfs.common

Class HdfsTextItemWriter<T>

java.lang.Object

org.springframework.batch.item.ItemStreamSupport

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

org.springframework.cloud.task.jdbchdfs.common.HdfsTextItemWriter<T>

All Implemented Interfaces:

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

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

Writes items as a byte array to a destination as specified by the fsURI.

Author:

Glenn Renfro

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
HdfsTextItemWriter()

Method Summary

Modifier and Type	Method and Description
void	close()
org.springframework.data.hadoop.store.DataStoreWriter<byte[]>	getStoreWriter()
void	setLineAggregator(org.springframework.batch.item.file.transform.LineAggregator<T> lineAggregator) Public setter for the LineAggregator.
void	setStoreWriter(org.springframework.data.hadoop.store.DataStoreWriter<byte[]> storeWriter)
void	update(org.springframework.batch.item.ExecutionContext executionContext)
void	write(List list) Aggregates the items to a single string and writes the data out using OutputStreamWriter as a byte array.

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

getExecutionContextKey, open, setExecutionContextName, setName

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

Field Detail

logger

protected final org.slf4j.Logger logger

Constructor Detail

HdfsTextItemWriter

public HdfsTextItemWriter()

Method Detail

write

public void write(List list)
           throws Exception

Aggregates the items to a single string and writes the data out using OutputStreamWriter as a byte array.

Parameters:

list - of objects that will be written to the specified fsUri.

Throws:

Exception

update

public void update(org.springframework.batch.item.ExecutionContext executionContext)

Specified by:

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

Overrides:

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

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

getStoreWriter

public org.springframework.data.hadoop.store.DataStoreWriter<byte[]> getStoreWriter()

setStoreWriter

public void setStoreWriter(org.springframework.data.hadoop.store.DataStoreWriter<byte[]> storeWriter)