|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface FileRotationPolicy
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 Summary | |
---|---|
boolean |
mark(TridentTuple tuple,
long offset)
Called for every tuple the HdfsBolt executes. |
void |
reset()
Called after the HdfsBolt rotates a file. |
Method Detail |
---|
boolean mark(TridentTuple tuple, long offset)
tuple
- The tuple executed.offset
- current offset of file being written
void reset()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |