Class NoRotationPolicy
java.lang.Object
org.apache.storm.hdfs.trident.rotation.NoRotationPolicy
- All Implemented Interfaces:
Serializable
,FileRotationPolicy
File rotation policy that will never rotate...
Just one big file. Intended for testing purposes.
- See Also:
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionboolean
mark
(long offset) Check if a file rotation should be performed based on the offset at which file is being written.boolean
mark
(TridentTuple tuple, long offset) Called for every tuple the HdfsBolt executes.void
reset()
Called after the HdfsBolt rotates a file.void
start()
Start the policy.
-
Constructor Details
-
NoRotationPolicy
public NoRotationPolicy()
-
-
Method Details
-
mark
Description copied from interface:FileRotationPolicy
Called for every tuple the HdfsBolt executes.- Specified by:
mark
in interfaceFileRotationPolicy
- Parameters:
tuple
- The tuple executed.offset
- current offset of file being written- Returns:
- true if a file rotation should be performed
-
mark
public boolean mark(long offset) Description copied from interface:FileRotationPolicy
Check if a file rotation should be performed based on the offset at which file is being written.- Specified by:
mark
in interfaceFileRotationPolicy
- Parameters:
offset
- the current offset of file being written- Returns:
- true if a file rotation should be performed.
-
reset
public void reset()Description copied from interface:FileRotationPolicy
Called after the HdfsBolt rotates a file.- Specified by:
reset
in interfaceFileRotationPolicy
-
start
public void start()Description copied from interface:FileRotationPolicy
Start the policy. Useful in case of policies like timed rotation where the timer can be started.- Specified by:
start
in interfaceFileRotationPolicy
-