Skip to content

Commit

Permalink
[fix] [doc] fix the class name of transaction exception. (apache#22687)
Browse files Browse the repository at this point in the history
  • Loading branch information
thetumbled authored May 10, 2024
1 parent 774a5d4 commit b7ec89a
Showing 1 changed file with 7 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@
import java.util.concurrent.CompletableFuture;
import org.apache.bookkeeper.mledger.Position;
import org.apache.bookkeeper.mledger.impl.PositionImpl;
import org.apache.pulsar.broker.transaction.exception.TransactionException;
import org.apache.pulsar.broker.transaction.exception.buffer.TransactionBufferException;
import org.apache.pulsar.client.api.transaction.TxnID;
import org.apache.pulsar.common.policies.data.TransactionBufferStats;
import org.apache.pulsar.common.policies.data.TransactionInBufferStats;
Expand Down Expand Up @@ -56,8 +58,7 @@ public interface TransactionBuffer {
*
* @param txnID the transaction id
* @return a future represents the result of the operation
* @throws org.apache.pulsar.broker.transaction.buffer.exceptions.TransactionNotFoundException if the transaction
* is not in the buffer.
* @throws TransactionBufferException.TransactionNotFoundException if the transaction is not in the buffer.
*/
CompletableFuture<TransactionMeta> getTransactionMeta(TxnID txnID);

Expand All @@ -70,8 +71,7 @@ public interface TransactionBuffer {
* @param sequenceId the sequence id of the entry in this transaction buffer.
* @param buffer the entry buffer
* @return a future represents the result of the operation.
* @throws org.apache.pulsar.broker.transaction.buffer.exceptions.TransactionSealedException if the transaction
* has been sealed.
* @throws TransactionException.TransactionSealedException if the transaction has been sealed.
*/
CompletableFuture<Position> appendBufferToTxn(TxnID txnId, long sequenceId, ByteBuf buffer);

Expand All @@ -82,8 +82,7 @@ public interface TransactionBuffer {
* @param txnID transaction id
* @param startSequenceId the sequence id to start read
* @return a future represents the result of open operation.
* @throws org.apache.pulsar.broker.transaction.buffer.exceptions.TransactionNotFoundException if the transaction
* is not in the buffer.
* @throws TransactionBufferException.TransactionNotFoundException if the transaction is not in the buffer.
*/
CompletableFuture<TransactionBufferReader> openTransactionBufferReader(TxnID txnID, long startSequenceId);

Expand All @@ -95,8 +94,7 @@ public interface TransactionBuffer {
* @param txnID the transaction id
* @param lowWaterMark the low water mark of this transaction
* @return a future represents the result of commit operation.
* @throws org.apache.pulsar.broker.transaction.buffer.exceptions.TransactionNotFoundException if the transaction
* is not in the buffer.
* @throws TransactionBufferException.TransactionNotFoundException if the transaction is not in the buffer.
*/
CompletableFuture<Void> commitTxn(TxnID txnID, long lowWaterMark);

Expand All @@ -107,8 +105,7 @@ public interface TransactionBuffer {
* @param txnID the transaction id
* @param lowWaterMark the low water mark of this transaction
* @return a future represents the result of abort operation.
* @throws org.apache.pulsar.broker.transaction.buffer.exceptions.TransactionNotFoundException if the transaction
* is not in the buffer.
* @throws TransactionBufferException.TransactionNotFoundException if the transaction is not in the buffer.
*/
CompletableFuture<Void> abortTxn(TxnID txnID, long lowWaterMark);

Expand Down

0 comments on commit b7ec89a

Please sign in to comment.