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 Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbooleanmark(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes.voidreset()Called after the HdfsBolt performs a sync.
-
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
-