Class NoRotationPolicy
java.lang.Object
org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy
- All Implemented Interfaces:
- Serializable,- FileRotationPolicy
File rotation policy that will never rotate...
 Just one big file. Intended for testing purposes.
- See Also:
- 
Constructor Details- 
NoRotationPolicypublic NoRotationPolicy()
 
- 
- 
Method Details- 
markDescription copied from interface:FileRotationPolicyCalled 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()Description copied from interface:FileRotationPolicyCalled 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
 
 
-