Package org.apache.storm.hdfs.common
Class HDFSWriter
java.lang.Object
org.apache.storm.hdfs.common.AbstractHDFSWriter
org.apache.storm.hdfs.common.HDFSWriter
- All Implemented Interfaces:
Writer
-
Field Summary
Fields inherited from class org.apache.storm.hdfs.common.AbstractHDFSWriter
filePath, lastUsedTime, needsRotation, offset, rotationPolicy
-
Constructor Summary
ConstructorDescriptionHDFSWriter
(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.FSDataOutputStream out, RecordFormat format) -
Method Summary
Methods inherited from class org.apache.storm.hdfs.common.AbstractHDFSWriter
close, getFilePath, needsRotation, sync, write
-
Constructor Details
-
HDFSWriter
public HDFSWriter(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.FSDataOutputStream out, RecordFormat 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
-