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

public class HDFSWriter
extends AbstractHDFSWriter

Field Summary

Fields inherited from class org.apache.storm.hdfs.common.AbstractHDFSWriter

filePath, lastUsedTime, needsRotation, offset, rotationPolicy

Constructor Summary

Constructors

Constructor	Description
HDFSWriter(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.FSDataOutputStream out, RecordFormat format)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
protected void	doSync()
protected void	doWrite(Tuple tuple)

Methods inherited from class org.apache.storm.hdfs.common.AbstractHDFSWriter

close, getFilePath, needsRotation, sync, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

HDFSWriter

public HDFSWriter(FileRotationPolicy policy,
 org.apache.hadoop.fs.Path path,
 org.apache.hadoop.fs.FSDataOutputStream out,
 RecordFormat format)

Method Details

doWrite

protected void doWrite(Tuple tuple)
                throws IOException

Specified by:

doWrite in class AbstractHDFSWriter

Throws:

IOException

doSync

protected void doSync()
               throws IOException

Specified by:

doSync in class AbstractHDFSWriter

Throws:

IOException

doClose

protected void doClose()
                throws IOException

Specified by:

doClose in class AbstractHDFSWriter

Throws:

IOException