Package org.apache.storm.hdfs.common
Class AvroGenericRecordHDFSWriter
java.lang.Object
org.apache.storm.hdfs.common.AbstractHDFSWriter
org.apache.storm.hdfs.common.AvroGenericRecordHDFSWriter
- All Implemented Interfaces:
- Writer
- 
Field SummaryFields inherited from class org.apache.storm.hdfs.common.AbstractHDFSWriterfilePath, lastUsedTime, needsRotation, offset, rotationPolicy
- 
Constructor SummaryConstructorsConstructorDescriptionAvroGenericRecordHDFSWriter(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.FSDataOutputStream stream, org.apache.avro.Schema schema) 
- 
Method SummaryMethods inherited from class org.apache.storm.hdfs.common.AbstractHDFSWriterclose, getFilePath, needsRotation, sync, write
- 
Constructor Details- 
AvroGenericRecordHDFSWriterpublic AvroGenericRecordHDFSWriter(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.FSDataOutputStream stream, org.apache.avro.Schema schema) throws IOException - Throws:
- IOException
 
 
- 
- 
Method Details- 
doWrite- Specified by:
- doWritein class- AbstractHDFSWriter
- Throws:
- IOException
 
- 
doSync- Specified by:
- doSyncin class- AbstractHDFSWriter
- Throws:
- IOException
 
- 
doClose- Specified by:
- doClosein class- AbstractHDFSWriter
- Throws:
- IOException
 
 
-