[pulsar] branch master updated (92f0cee -> a81d234)

[si...@apache.org]

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