|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface SyncPolicy
Interface for controlling when the HdfsBolt syncs and flushes the filesystem.
Method Summary | |
---|---|
boolean |
mark(Tuple tuple,
long offset)
Called for every tuple the HdfsBolt executes. |
void |
reset()
Called after the HdfsBolt performs a sync. |
Method Detail |
---|
boolean mark(Tuple tuple, long offset)
tuple
- The tuple executed.offset
- current offset for the file being written
void reset()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |