Package org.apache.storm.hdfs.bolt.sync
Interface SyncPolicy
- All Superinterfaces:
- Serializable
- All Known Implementing Classes:
- CountSyncPolicy
Interface for controlling when the HdfsBolt
 syncs and flushes the filesystem.
- 
Method Summary
- 
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.
 
-