Class CountSyncPolicy
java.lang.Object
org.apache.storm.hdfs.trident.sync.CountSyncPolicy
- All Implemented Interfaces:
- Serializable,- SyncPolicy
SyncPolicy implementation that will trigger a
 file system sync after a certain number of tuples
 have been processed.
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionbooleanmark(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes.voidreset()Called after the HdfsBolt performs a sync.
- 
Constructor Details- 
CountSyncPolicypublic CountSyncPolicy(int count) 
 
- 
- 
Method Details- 
markDescription copied from interface:SyncPolicyCalled for every tuple the HdfsBolt executes.- Specified by:
- markin interface- SyncPolicy
- Parameters:
- tuple- The tuple executed.
- offset- current offset for the file being written
- Returns:
- true if a sync should be performed
 
- 
resetpublic void reset()Description copied from interface:SyncPolicyCalled after the HdfsBolt performs a sync.- Specified by:
- resetin interface- SyncPolicy
 
 
-