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
-
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.
-