Package org.apache.storm.hdfs.trident
Class HdfsState.SequenceFileOptions
java.lang.Object
org.apache.storm.hdfs.trident.HdfsState.Options
org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
- All Implemented Interfaces:
Serializable
- Enclosing class:
- HdfsState
- See Also:
-
Field Summary
Fields inherited from class org.apache.storm.hdfs.trident.HdfsState.Options
configKey, fileNameFormat, fs, fsUrl, hdfsConfig, rotation, rotationActions, rotationPolicy -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionaddRotationAction(RotationAction action) voidvoidexecute(List<TridentTuple> tuples) longwithCompressionCodec(String codec) withCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType) withConfigKey(String configKey) withFileNameFormat(FileNameFormat fileNameFormat) withRotationPolicy(FileRotationPolicy rotationPolicy) withSequenceFormat(SequenceFormat format) Methods inherited from class org.apache.storm.hdfs.trident.HdfsState.Options
rotateOutputFile, rotateOutputFile
-
Constructor Details
-
SequenceFileOptions
public SequenceFileOptions()
-
-
Method Details
-
withCompressionCodec
-
withFsUrl
-
withConfigKey
-
withFileNameFormat
-
withSequenceFormat
-
withRotationPolicy
-
withCompressionType
public HdfsState.SequenceFileOptions withCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType) -
addRotationAction
-
getCurrentOffset
- Throws:
IOException
-
doCommit
- Throws:
IOException
-
execute
- Throws:
IOException
-