Interface SyncPolicy
- All Superinterfaces:
- Serializable
- All Known Implementing Classes:
- CountSyncPolicy
Interface for controlling when the HdfsBolt
 syncs and flushes the filesystem.
- 
Method SummaryModifier and TypeMethodDescriptionbooleanmark(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes.voidreset()Called after the HdfsBolt performs a sync.
- 
Method Details- 
markCalled 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
 
- 
resetvoid reset()Called after the HdfsBolt performs a sync.
 
-