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(BufferedReader reader,
XLogFilter filter) |
Modifier and Type | Method and Description |
---|---|
protected String |
parseNextLine()
This implementation simply returns the next line from the Reader.
|
closeReader, getLastMessage, getLastTimestamp, increment, processRemaining, processRemaining, processRemaining
public SimpleTimestampedMessageParser(BufferedReader reader, XLogFilter filter)
protected String parseNextLine() throws IOException
parseNextLine
in class TimestampedMessageParser
IOException
Copyright © 2015 Apache Software Foundation. All Rights Reserved.