Package org.apache.storm.hdfs.bolt.sync
Class CountSyncPolicy
java.lang.Object
org.apache.storm.hdfs.bolt.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 Summary
Constructors -
Method Summary
-
Constructor Details
-
CountSyncPolicy
public CountSyncPolicy(int count)
-
-
Method Details
-
mark
Description copied from interface:SyncPolicyCalled for every tuple the HdfsBolt executes.- Specified by:
markin interfaceSyncPolicy- Parameters:
tuple- The tuple executed.offset- current offset for the file being written- Returns:
- true if a sync should be performed
-
reset
public void reset()Description copied from interface:SyncPolicyCalled after the HdfsBolt performs a sync.- Specified by:
resetin interfaceSyncPolicy
-