org.apache.flume.client.avro
Interface ReliableEventReader
- All Superinterfaces:
- Closeable, EventReader
- All Known Implementing Classes:
- ReliableSpoolingFileEventReader
@InterfaceAudience.Private
@InterfaceStability.Evolving
public interface ReliableEventReader
- extends EventReader
A reliable event reader.
Clients must call commit() after each read operation, otherwise the
implementation must reset its internal buffers and return the same events
as it did previously.
Method Summary |
void |
commit()
Indicate to the implementation that the previously-returned events have
been successfully processed and committed. |
commit
void commit()
throws IOException
- Indicate to the implementation that the previously-returned events have
been successfully processed and committed.
- Throws:
IOException
Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.