|
||||||||||
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 |