Package org.apache.storm.hdfs.spout
Class TextFileReader
- java.lang.Object
-
- org.apache.storm.hdfs.spout.TextFileReader
-
public class TextFileReader extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classTextFileReader.Offset
-
Field Summary
Fields Modifier and Type Field Description static StringBUFFER_SIZEstatic StringCHARSETstatic String[]defaultFields
-
Constructor Summary
Constructors Constructor Description TextFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String,Object> conf)TextFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String,Object> conf, String startOffset)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()booleanequals(Object o)TextFileReader.OffsetgetFileOffset()org.apache.hadoop.fs.PathgetFilePath()inthashCode()List<Object>next()
-
-
-
Field Detail
-
defaultFields
public static final String[] defaultFields
-
CHARSET
public static final String CHARSET
- See Also:
- Constant Field Values
-
BUFFER_SIZE
public static final String BUFFER_SIZE
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
TextFileReader
public TextFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String,Object> conf) throws IOException- Throws:
IOException
-
TextFileReader
public TextFileReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path file, Map<String,Object> conf, String startOffset) throws IOException- Throws:
IOException
-
-
Method Detail
-
getFileOffset
public TextFileReader.Offset getFileOffset()
-
next
public List<Object> next() throws IOException, ParseException
- Throws:
IOExceptionParseException
-
close
public void close()
-
getFilePath
public org.apache.hadoop.fs.Path getFilePath()
-
-