public class HdfsTextItemWriter<T> extends AbstractHdfsItemWriter<T> implements org.springframework.beans.factory.InitializingBean
logger| Constructor and Description |
|---|
HdfsTextItemWriter(org.apache.hadoop.fs.FileSystem fileSystem) |
| 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 |
update(org.springframework.batch.item.ExecutionContext executionContext) |
void |
write(java.util.List<? extends T> items) |
getBaseFilename, getBasePath, getBytesWritten, getCounter, getCounterFromName, getFileName, getFileSuffix, getRolloverThresholdInBytes, incrementBytesWritten, incrementCounter, initializeCounterIfNecessary, reset, resetBytesWritten, setBaseFilename, setBasePath, setCounter, setFileSuffix, setRolloverThresholdInBytesgetExecutionContextKey, open, setExecutionContextName, setNamepublic HdfsTextItemWriter(org.apache.hadoop.fs.FileSystem fileSystem)
public void write(java.util.List<? extends T> items) throws java.lang.Exception
write in interface org.springframework.batch.item.ItemWriter<T>write in class AbstractHdfsItemWriter<T>java.lang.Exceptionpublic org.apache.hadoop.fs.FileSystem getFileSystem()
getFileSystem in class AbstractHdfsItemWriter<T>public void update(org.springframework.batch.item.ExecutionContext executionContext)
update in interface org.springframework.batch.item.ItemStreamupdate in class org.springframework.batch.item.ItemStreamSupportpublic void close()
close in interface org.springframework.batch.item.ItemStreamclose in class org.springframework.batch.item.ItemStreamSupportpublic void setLineAggregator(org.springframework.batch.item.file.transform.LineAggregator<T> lineAggregator)
LineAggregator. This will be used to translate the item into a line for output.lineAggregator - the LineAggregator to setpublic void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanjava.lang.Exception