public class SimpleTimestampedMessageParser extends TimestampedMessageParser
TimestampedMessageParser which doesn't do any filtering when reading the lines from the Reader.
This is useful when processing a Reader where the lines have already been filtered, so we can be more efficient by not
doing the same filtering again.count, reader| Constructor and Description |
|---|
SimpleTimestampedMessageParser(java.io.BufferedReader reader,
XLogFilter filter) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.String |
parseNextLine()
This implementation simply returns the next line from the Reader.
|
closeReader, getLastMessage, getLastTimestamp, increment, processRemaining, processRemaining, processRemainingpublic SimpleTimestampedMessageParser(java.io.BufferedReader reader, XLogFilter filter)
protected java.lang.String parseNextLine() throws java.io.IOException
parseNextLine in class TimestampedMessageParserjava.io.IOExceptionCopyright © 2017 Apache Software Foundation. All Rights Reserved.