public interface FileRotationPolicy extends Serializable
Used by the HdfsBolt to decide when to rotate files.
The HdfsBolt will call the
mark() method for every tuple received. If the
mark() method returns
true the HdfsBolt will perform a file rotation.
After file rotation, the HdfsBolt will call the
boolean mark(Tuple tuple, long offset)
Called for every tuple the HdfsBolt executes.
tuple- The tuple executed.
offset- current offset of file being written
Called after the HdfsBolt rotates a file.
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.