Interface FileRotationPolicy
- All Superinterfaces:
- Serializable
- All Known Implementing Classes:
- FileSizeRotationPolicy,- NoRotationPolicy,- TimedRotationPolicy
Used by the HdfsBolt to decide when to rotate files.
 
The HdfsBolt will call the mark() method for every
 tuple received. If the mark() method returns
 true the HdfsBolt will perform a file rotation.
 
After file rotation, the HdfsBolt will call the reset()
 method.
- 
Method Details- 
markCalled for every tuple the HdfsBolt executes.- Parameters:
- tuple- The tuple executed.
- offset- current offset of file being written
- Returns:
- true if a file rotation should be performed
 
- 
resetvoid reset()Called after the HdfsBolt rotates a file.
- 
copyFileRotationPolicy copy()Must be able to copy the rotation policy.
 
-