|
Spring for Apache Hadoop | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.springframework.data.hadoop.store.input.DelimitedTextFileReader
public class DelimitedTextFileReader
A DelimitedTextFileReader
is a DataStoreReader
implementation
able to read String
s from a raw hdfs files as delimited fields.
Field Summary | |
---|---|
static byte[] |
CSV
CSV Mode |
static byte[] |
TAB
TAB Mode |
Constructor Summary | |
---|---|
DelimitedTextFileReader(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec)
Instantiates a new delimited text file reader. |
|
DelimitedTextFileReader(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec,
byte[] fieldDelimiter)
Instantiates a new delimited text file reader. |
|
DelimitedTextFileReader(org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.fs.Path basePath,
CodecInfo codec,
Split inputSplit,
byte[] fieldDelimiter,
byte[] textDelimiter)
Instantiates a new delimited text file reader. |
Method Summary | |
---|---|
void |
close()
|
java.util.List<java.lang.String> |
read()
Read next entity from a reader. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final byte[] CSV
public static final byte[] TAB
Constructor Detail |
---|
public DelimitedTextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec)
configuration
- the configurationbasePath
- the base pathcodec
- the codecpublic DelimitedTextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, byte[] fieldDelimiter)
configuration
- the configurationbasePath
- the base pathcodec
- the codecfieldDelimiter
- the field delimiterpublic DelimitedTextFileReader(org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.fs.Path basePath, CodecInfo codec, Split inputSplit, byte[] fieldDelimiter, byte[] textDelimiter)
configuration
- the configurationbasePath
- the base pathcodec
- the codecfieldDelimiter
- the field delimitertextDelimiter
- the text delimiterMethod Detail |
---|
public java.util.List<java.lang.String> read() throws java.io.IOException
DataReader
read
in interface DataReader<java.util.List<java.lang.String>>
null
java.io.IOException
- if an I/O error occurspublic void close() throws java.io.IOException
close
in interface java.io.Closeable
java.io.IOException
|
Spring for Apache Hadoop | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |