Package | Description |
---|---|
org.apache.flume.channel.jdbc.impl |
Modifier and Type | Method and Description |
---|---|
PersistableEvent |
PersistableEvent.Builder.build() |
PersistableEvent |
SchemaHandler.fetchAndDeleteEvent(String channel,
Connection connection)
Retrieves the next persistent event from the database.
|
PersistableEvent |
MySQLSchemaHandler.fetchAndDeleteEvent(String channel,
Connection connection) |
PersistableEvent |
DerbySchemaHandler.fetchAndDeleteEvent(String channel,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
void |
SchemaHandler.storeEvent(PersistableEvent pe,
Connection connection)
Inserts the given persistent event into the database.
|
void |
MySQLSchemaHandler.storeEvent(PersistableEvent pe,
Connection connection) |
void |
DerbySchemaHandler.storeEvent(PersistableEvent pe,
Connection connection) |
Copyright © 2009-2016 Apache Software Foundation. All Rights Reserved.