Package org.apache.storm.hdfs.common
Class SequenceFileWriter
java.lang.Object
org.apache.storm.hdfs.common.AbstractHDFSWriter
org.apache.storm.hdfs.common.SequenceFileWriter
- All Implemented Interfaces:
Writer
-
Field Summary
Fields inherited from class org.apache.storm.hdfs.common.AbstractHDFSWriter
filePath, lastUsedTime, needsRotation, offset, rotationPolicy
-
Constructor Summary
ConstructorDescriptionSequenceFileWriter
(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.io.SequenceFile.Writer writer, SequenceFormat format) -
Method Summary
Methods inherited from class org.apache.storm.hdfs.common.AbstractHDFSWriter
close, getFilePath, needsRotation, sync, write
-
Constructor Details
-
SequenceFileWriter
public SequenceFileWriter(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.io.SequenceFile.Writer writer, SequenceFormat format)
-
-
Method Details
-
doWrite
- Specified by:
doWrite
in classAbstractHDFSWriter
- Throws:
IOException
-
doSync
- Specified by:
doSync
in classAbstractHDFSWriter
- Throws:
IOException
-
doClose
- Specified by:
doClose
in classAbstractHDFSWriter
- Throws:
IOException
-