This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 92f0cee add get message method in Record interface (#4341)
add a81d234 [transaction][buffer] add interfaces for transaction buffer
and an in-memory implementation (#4165)
No new revisions were added by this update.
Summary of changes:
pulsar-transaction/{coordinator => buffer}/pom.xml | 19 +-
.../transaction/buffer/TransactionBuffer.java | 131 ++++++++++
.../buffer/TransactionBufferProvider.java} | 26 +-
.../buffer/TransactionBufferReader.java | 51 ++++
.../transaction/buffer/TransactionEntry.java | 50 ++--
.../transaction/buffer/TransactionMeta.java} | 34 +--
.../exceptions/EndOfTransactionException.java | 15 +-
.../exceptions/TransactionBufferException.java} | 13 +-
.../exceptions/TransactionNotFoundException.java | 15 +-
.../exceptions/TransactionNotSealedException.java | 15 +-
.../exceptions/TransactionSealedException.java | 17 +-
.../exceptions/UnexpectedTxnStatusException.java} | 23 +-
.../buffer/exceptions}/package-info.java | 5 +-
.../buffer/impl/InMemTransactionBuffer.java | 291 +++++++++++++++++++++
.../impl/InMemTransactionBufferProvider.java | 18 +-
.../buffer/impl/InMemTransactionBufferReader.java | 97 +++++++
.../buffer/impl/TransactionEntryImpl.java | 79 ++++++
.../transaction/buffer/impl}/package-info.java | 5 +-
.../pulsar/transaction/buffer}/package-info.java | 5 +-
.../impl/InMemTransactionBufferReaderTest.java | 152 +++++++++++
.../buffer/impl/TransactionBufferTest.java | 280 ++++++++++++++++++++
.../buffer/impl/TransactionEntryImplTest.java | 41 ++-
pulsar-transaction/common/pom.xml | 2 +-
pulsar-transaction/pom.xml | 1 +
24 files changed, 1239 insertions(+), 146 deletions(-)
copy pulsar-transaction/{coordinator => buffer}/pom.xml (75%)
create mode 100644
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionBuffer.java
copy
pulsar-transaction/{coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/TransactionMetadataStoreProvider.java
=>
buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionBufferProvider.java}
(64%)
create mode 100644
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionBufferReader.java
copy managed-ledger/src/main/java/org/apache/bookkeeper/mledger/Entry.java =>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionEntry.java
(50%)
copy
pulsar-transaction/{common/src/main/java/org/apache/pulsar/transaction/impl/common/TxnID.java
=>
buffer/src/main/java/org/apache/pulsar/transaction/buffer/TransactionMeta.java}
(59%)
copy
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SchemaSerializationException.java
=>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/EndOfTransactionException.java
(73%)
copy
pulsar-transaction/{coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/CoordinatorException.java
=>
buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/TransactionBufferException.java}
(71%)
copy
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SchemaSerializationException.java
=>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/TransactionNotFoundException.java
(71%)
copy
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SchemaSerializationException.java
=>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/TransactionNotSealedException.java
(71%)
copy
pulsar-client-api/src/main/java/org/apache/pulsar/client/api/SchemaSerializationException.java
=>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/TransactionSealedException.java
(66%)
copy
pulsar-transaction/{coordinator/src/main/java/org/apache/pulsar/transaction/coordinator/exceptions/InvalidTxnStatusException.java
=>
buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions/UnexpectedTxnStatusException.java}
(61%)
copy
{pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime =>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/exceptions}/package-info.java
(86%)
create mode 100644
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/InMemTransactionBuffer.java
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionsChangedListener.java
=>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/InMemTransactionBufferProvider.java
(62%)
create mode 100644
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/InMemTransactionBufferReader.java
create mode 100644
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl/TransactionEntryImpl.java
copy
{pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime =>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer/impl}/package-info.java
(89%)
copy
{pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime =>
pulsar-transaction/buffer/src/main/java/org/apache/pulsar/transaction/buffer}/package-info.java
(90%)
create mode 100644
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction/buffer/impl/InMemTransactionBufferReaderTest.java
create mode 100644
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction/buffer/impl/TransactionBufferTest.java
copy
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/BytesSchemaTest.java
=>
pulsar-transaction/buffer/src/test/java/org/apache/pulsar/transaction/buffer/impl/TransactionEntryImplTest.java
(56%)
