org.apache.flume.serialization
Class LineDeserializer

java.lang.Object
  extended by org.apache.flume.serialization.LineDeserializer
All Implemented Interfaces:
Closeable, EventDeserializer, Resettable

@InterfaceAudience.Private
@InterfaceStability.Evolving
public class LineDeserializer
extends Object
implements EventDeserializer

A deserializer that parses text lines from a file.


Nested Class Summary
static class LineDeserializer.Builder
           
 
Field Summary
static String CHARSET_DFLT
           
static int MAXLINE_DFLT
           
static String MAXLINE_KEY
           
static String OUT_CHARSET_KEY
           
 
Method Summary
 void close()
          Calls EventDeserializer.reset() on the stream and then closes it.
 void mark()
          Marks the underlying input stream, indicating that the events previously returned by this EventDeserializer have been successfully committed.
 Event readEvent()
          Reads a line from a file and returns an event
 List<Event> readEvents(int numEvents)
          Batch line read
 void reset()
          Resets the underlying input stream to the last known mark (or beginning of the stream if EventDeserializer.mark() was never previously called.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

OUT_CHARSET_KEY

public static final String OUT_CHARSET_KEY
See Also:
Constant Field Values

CHARSET_DFLT

public static final String CHARSET_DFLT
See Also:
Constant Field Values

MAXLINE_KEY

public static final String MAXLINE_KEY
See Also:
Constant Field Values

MAXLINE_DFLT

public static final int MAXLINE_DFLT
See Also:
Constant Field Values
Method Detail

readEvent

public Event readEvent()
                throws IOException
Reads a line from a file and returns an event

Specified by:
readEvent in interface EventDeserializer
Returns:
Event containing parsed line
Throws:
IOException
See Also:
EventDeserializer.mark(), EventDeserializer.reset()

readEvents

public List<Event> readEvents(int numEvents)
                       throws IOException
Batch line read

Specified by:
readEvents in interface EventDeserializer
Parameters:
numEvents - Maximum number of events to return.
Returns:
List of events containing read lines
Throws:
IOException
See Also:
EventDeserializer.mark(), EventDeserializer.reset()

mark

public void mark()
          throws IOException
Description copied from interface: EventDeserializer
Marks the underlying input stream, indicating that the events previously returned by this EventDeserializer have been successfully committed.

Specified by:
mark in interface EventDeserializer
Specified by:
mark in interface Resettable
Throws:
IOException
See Also:
EventDeserializer.reset()

reset

public void reset()
           throws IOException
Description copied from interface: EventDeserializer
Resets the underlying input stream to the last known mark (or beginning of the stream if EventDeserializer.mark() was never previously called. This should be done in the case of inability to commit previously-deserialized events.

Specified by:
reset in interface EventDeserializer
Specified by:
reset in interface Resettable
Throws:
IOException
See Also:
EventDeserializer.mark()

close

public void close()
           throws IOException
Description copied from interface: EventDeserializer
Calls EventDeserializer.reset() on the stream and then closes it. In the case of successful completion of event consumption, EventDeserializer.mark() MUST be called before close().

Specified by:
close in interface Closeable
Specified by:
close in interface EventDeserializer
Throws:
IOException
See Also:
EventDeserializer.mark(), EventDeserializer.reset()


Copyright © 2009-2014 Apache Software Foundation. All Rights Reserved.