Class TimedRotationPolicy
java.lang.Object
org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy
- All Implemented Interfaces:
- Serializable,- FileRotationPolicy
- See Also:
- 
Nested Class SummaryNested Classes
- 
Constructor SummaryConstructorsModifierConstructorDescriptionTimedRotationPolicy(float count, TimedRotationPolicy.TimeUnit units) protectedTimedRotationPolicy(long interval) 
- 
Method Summary
- 
Constructor Details- 
TimedRotationPolicy
- 
TimedRotationPolicyprotected TimedRotationPolicy(long interval) 
 
- 
- 
Method Details- 
markCalled for every tuple the HdfsBolt executes.- Specified by:
- markin interface- FileRotationPolicy
- Parameters:
- tuple- The tuple executed.
- offset- current offset of file being written
- Returns:
- true if a file rotation should be performed
 
- 
resetpublic void reset()Called after the HdfsBolt rotates a file.- Specified by:
- resetin interface- FileRotationPolicy
 
- 
copyDescription copied from interface:FileRotationPolicyMust be able to copy the rotation policy.- Specified by:
- copyin interface- FileRotationPolicy
 
- 
getIntervalpublic long getInterval()
 
-