Interface SyncPolicy
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
CountSyncPolicy
Interface for controlling when the HdfsBolt
syncs and flushes the filesystem.
-
Method Summary
Modifier and TypeMethodDescriptionbooleanmark(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes.voidreset()Called after the HdfsBolt performs a sync.
-
Method Details
-
mark
Called for every tuple the HdfsBolt executes.- Parameters:
tuple- The tuple executed.offset- current offset for the file being written- Returns:
- true if a sync should be performed
-
reset
void reset()Called after the HdfsBolt performs a sync.
-