org.apache.storm.hdfs.bolt

Interface Writer

All Known Implementing Classes:

AbstractHDFSWriter, AvroGenericRecordHDFSWriter, HDFSWriter, SequenceFileWriter

public interface Writer

Method Summary

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.fs.Path	getFilePath()
boolean	needsRotation()
void	sync()
long	write(Tuple tuple)

Method Detail

write

long write(Tuple tuple)
    throws IOException

Throws:

IOException

sync

void sync()
   throws IOException

Throws:

IOException

close

void close()
    throws IOException

Throws:

IOException

needsRotation

boolean needsRotation()

getFilePath

org.apache.hadoop.fs.Path getFilePath()