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
-
Method Summary
Modifier and TypeMethodDescriptionaddRotationAction
(RotationAction action) void
void
execute
(List<TridentTuple> tuples) long
withCompressionCodec
(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
-