public class FileSizeRotationPolicy extends Object implements FileRotationPolicy
// rotate when files reach 5MB FileSizeRotationPolicy policy = new FileSizeRotationPolicy(5.0, Units.MB);
Modifier and Type | Class and Description |
---|---|
static class |
FileSizeRotationPolicy.Units |
Constructor and Description |
---|
FileSizeRotationPolicy(float count,
FileSizeRotationPolicy.Units units) |
Modifier and Type | Method and Description |
---|---|
boolean |
mark(Tuple tuple,
long offset)
Called for every tuple the HdfsBolt executes.
|
void |
reset()
Called after the HdfsBolt rotates a file.
|
public FileSizeRotationPolicy(float count, FileSizeRotationPolicy.Units units)
public boolean mark(Tuple tuple, long offset)
FileRotationPolicy
mark
in interface FileRotationPolicy
tuple
- The tuple executed.offset
- current offset of file being writtenpublic void reset()
FileRotationPolicy
reset
in interface FileRotationPolicy
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.