@FunctionalInterface public static interface FileWritingMessageHandler.FlushPredicate
FileExistsMode.APPEND_NO_FLUSH
, an implementation of this
interface is called for each file that has pending data to flush and close when
FileWritingMessageHandler.flushIfNeeded(FlushPredicate)
is invoked.Modifier and Type | Method and Description |
---|---|
boolean |
shouldFlush(String fileAbsolutePath,
long firstWrite,
long lastWrite)
Return true to cause the file to be flushed and closed.
|
boolean shouldFlush(String fileAbsolutePath, long firstWrite, long lastWrite)
fileAbsolutePath
- the path to the file.firstWrite
- the time of the first write to a new or previously closed
file.lastWrite
- the time of the last write -
System.currentTimeMillis()
.