|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.flume.channel.AbstractChannel org.apache.flume.channel.jdbc.JdbcChannel
public class JdbcChannel
A JDBC based channel implementation.
Constructor Summary | |
---|---|
JdbcChannel()
Instantiates a new JDBC Channel. |
Method Summary | |
---|---|
void |
configure(Context context)
|
Transaction |
getTransaction()
|
void |
put(Event event)
Puts the given event into the channel. |
void |
stop()
Stops a service or component. |
Event |
take()
Returns the next event from the channel if available. |
Methods inherited from class org.apache.flume.channel.AbstractChannel |
---|
getLifecycleState, getName, setName, start |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JdbcChannel()
Method Detail |
---|
public void put(Event event) throws ChannelException
Channel
Puts the given event into the channel.
Note: This method must be invoked within an active
Transaction
boundary. Failure to do so can lead to unpredictable
results.
event
- the event to transport.
ChannelException
- in case this operation fails.Transaction.begin()
public Event take() throws ChannelException
Channel
Returns the next event from the channel if available. If the channel
does not have any events available, this method must return null
.
Note: This method must be invoked within an active
Transaction
boundary. Failure to do so can lead to unpredictable
results.
null
if no events are
available.
ChannelException
- in case this operation fails.Transaction.begin()
public Transaction getTransaction()
public void stop()
LifecycleAware
Stops a service or component.
Implementations should determine the result of any stop logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
stop
in interface LifecycleAware
stop
in class AbstractChannel
public void configure(Context context)
configure
in interface Configurable
configure
in class AbstractChannel
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |