|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use MemoryChannel.MemTransaction | |
|---|---|
| org.apache.flume.channel | |
| Uses of MemoryChannel.MemTransaction in org.apache.flume.channel |
|---|
| Methods in org.apache.flume.channel that return MemoryChannel.MemTransaction | |
|---|---|
protected MemoryChannel.MemTransaction |
MemoryChannel.findTransaction()
|
| Methods in org.apache.flume.channel with parameters of type MemoryChannel.MemTransaction | |
|---|---|
protected void |
MemoryChannel.forgetTransaction(MemoryChannel.MemTransaction myTxn)
Remove the given transaction from the list of open transactions |
protected void |
MemoryChannel.undoPut(MemoryChannel.MemTransaction myTxn)
undo of put for all the events in the undoPut queue, remove those from the event queue |
protected void |
MemoryChannel.undoTake(MemoryChannel.MemTransaction myTxn)
undo of take operation for each event in the undoTake list, add it back to the event queue |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||