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
-
mark
Called 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
-
reset
void reset()Called after the HdfsBolt rotates a file. -
copy
FileRotationPolicy copy()Must be able to copy the rotation policy.
-