org.springframework.data.hadoop.batch
Class HdfsItemReader<T>
java.lang.Object
org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader<T>
org.springframework.batch.item.file.FlatFileItemReader<T>
org.springframework.data.hadoop.batch.HdfsItemReader<T>
- Type Parameters:
T - the generic type
- All Implemented Interfaces:
- ResourceAwareItemReaderItemStream<T>, ItemReader<T>, ItemStream, ItemStreamReader<T>, InitializingBean
public class HdfsItemReader<T>
- extends FlatFileItemReader<T>
Spring Batch ItemReader implementation for Hadoop FileSystem.
- Author:
- Costin Leau
| Methods inherited from class org.springframework.batch.item.file.FlatFileItemReader |
doClose, doOpen, doRead, jumpToItem, setBufferedReaderFactory, setComments, setEncoding, setLineMapper, setLinesToSkip, setRecordSeparatorPolicy, setResource, setSkippedLinesCallback, setStrict |
| Methods inherited from class org.springframework.batch.item.support.AbstractItemCountingItemStreamItemReader |
close, getCurrentItemCount, getExecutionContextUserSupport, isSaveState, open, read, setCurrentItemCount, setMaxItemCount, setName, setSaveState, 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.ItemReader |
read |
HdfsItemReader
public HdfsItemReader(Configuration configuration)
- Instantiates a new hdfs item reader.
- Parameters:
configuration - the configuration
HdfsItemReader
public HdfsItemReader(FileSystem fs)
- Instantiates a new hdfs item reader.
- Parameters:
fs - the fs
HdfsItemReader
public HdfsItemReader(HdfsResourceLoader hdfsLoader)
- Instantiates a new hdfs item reader.
- Parameters:
hdfsLoader - the hdfs loader
afterPropertiesSet
public void afterPropertiesSet()
throws Exception
- After properties set.
- Specified by:
afterPropertiesSet in interface InitializingBean- Overrides:
afterPropertiesSet in class FlatFileItemReader<T>
- Throws:
Exception - the exception
setLocation
public void setLocation(String location)
- Sets the location.
- Parameters:
location - the new location