Package | Description |
---|---|
org.apache.flume | |
org.apache.flume.channel | |
org.apache.flume.channel.jdbc | |
org.apache.flume.channel.jdbc.impl |
Modifier and Type | Method and Description |
---|---|
Transaction |
Channel.getTransaction() |
Modifier and Type | Class and Description |
---|---|
class |
BasicTransactionSemantics
An implementation of basic
Transaction semantics designed
to work in concert with BasicChannelSemantics to simplify
creation of robust Channel implementations. |
static class |
PseudoTxnMemoryChannel.NoOpTransaction
A no-op transaction implementation that does nothing at all.
|
Modifier and Type | Method and Description |
---|---|
Transaction |
PseudoTxnMemoryChannel.getTransaction() |
Transaction |
BasicChannelSemantics.getTransaction()
Initializes the channel if it is not already, then checks to see
if there is an open transaction for this thread, creating a new
one via
createTransaction if not. |
static Transaction |
PseudoTxnMemoryChannel.NoOpTransaction.sharedInstance() |
Modifier and Type | Method and Description |
---|---|
Transaction |
JdbcChannelProvider.getTransaction() |
Transaction |
JdbcChannel.getTransaction() |
Modifier and Type | Class and Description |
---|---|
class |
JdbcTransactionImpl |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.