Package org.apache.storm.hdfs.trident
Class HdfsState.Options
java.lang.Object
org.apache.storm.hdfs.trident.HdfsState.Options
- All Implemented Interfaces:
- Serializable
- Direct Known Subclasses:
- HdfsState.HdfsFileOptions,- HdfsState.SequenceFileOptions
- Enclosing class:
- HdfsState
- See Also:
- 
Field SummaryFieldsModifier and TypeFieldDescriptionprotected Stringprotected FileNameFormatprotected org.apache.hadoop.fs.FileSystemprotected Stringprotected org.apache.hadoop.conf.Configurationprotected intprotected ArrayList<RotationAction>protected FileRotationPolicy
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionprotected voidprotected voidrotateOutputFile(boolean doRotateAction) 
- 
Field Details- 
fsUrl
- 
configKey
- 
fsprotected transient org.apache.hadoop.fs.FileSystem fs
- 
rotationPolicy
- 
fileNameFormat
- 
rotationprotected int rotation
- 
hdfsConfigprotected transient org.apache.hadoop.conf.Configuration hdfsConfig
- 
rotationActions
 
- 
- 
Constructor Details- 
Optionspublic Options()
 
- 
- 
Method Details- 
rotateOutputFile- Throws:
- IOException
 
- 
rotateOutputFile- Throws:
- IOException
 
 
-