public class HdfsTextItemWriter<T> extends AbstractHdfsItemWriter<T> implements org.springframework.beans.factory.InitializingBean
logger
コンストラクターと説明 |
---|
HdfsTextItemWriter(org.apache.hadoop.fs.FileSystem fileSystem) |
修飾子と型 | メソッドと説明 |
---|---|
void | afterPropertiesSet() |
void | close() |
org.apache.hadoop.fs.FileSystem | getFileSystem() |
void | setLineAggregator(org.springframework.batch.item.file.transform.LineAggregator<T> lineAggregator) LineAggregator の公開 setter。 |
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, setRolloverThresholdInBytes
getExecutionContextKey, open, setExecutionContextName, setName
public void write(java.util.List<? extends T> items) throws java.lang.Exception
org.springframework.batch.item.ItemWriter<T>
の write
AbstractHdfsItemWriter<T>
の write
java.lang.Exception
public org.apache.hadoop.fs.FileSystem getFileSystem()
AbstractHdfsItemWriter<T>
の getFileSystem
public void update(org.springframework.batch.item.ExecutionContext executionContext)
org.springframework.batch.item.ItemStream
の update
org.springframework.batch.item.ItemStreamSupport
の update
public void close()
org.springframework.batch.item.ItemStream
の close
org.springframework.batch.item.ItemStreamSupport
の close
public void setLineAggregator(org.springframework.batch.item.file.transform.LineAggregator<T> lineAggregator)
LineAggregator
のパブリック setter。これは、項目を出力用の行に変換するために使用されます。lineAggregator
- 設定する LineAggregator
public void afterPropertiesSet() throws java.lang.Exception
org.springframework.beans.factory.InitializingBean
の afterPropertiesSet
java.lang.Exception