[pulsar] branch master updated (99e9543 -> 9aaa1cc)

[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 99e9543  [Tests] Avoid use Thread.sleep() in TopicPoliciesTest (#8557)
     add 9aaa1cc  [Functions] Refactor Context and State API to allow plugging different state store implementations (#8537)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/pulsar/client/api/Consumer.java     |   3 +-
 .../org/apache/pulsar/client/api/Producer.java     |   3 +-
 .../org/apache/pulsar/functions/api/Context.java   |  37 ++++-
 .../api/{Function.java => StateStore.java}         |  59 +++++--
 .../api/{SerDe.java => StateStoreContext.java}     |  16 +-
 .../functions/api/state/ByteBufferStateStore.java  |  76 +++++++++
 .../functions/api/state/CounterStateStore.java     |  63 +++++++
 .../pulsar/functions/api/state}/package-info.java  |   4 +-
 .../pulsar/functions/instance/ContextImpl.java     | 112 +++++++------
 .../functions/instance/JavaInstanceRunnable.java   | 179 +++++---------------
 ...StateContextImpl.java => BKStateStoreImpl.java} | 108 ++++++++++--
 .../instance/state/BKStateStoreProviderImpl.java   | 182 +++++++++++++++++++++
 .../instance/state/DefaultStateStore.java          |  17 +-
 .../instance/state/InstanceStateManager.java       |  81 +++++++++
 .../functions/instance/state/StateContext.java     |  78 ---------
 .../functions/instance/state/StateManager.java     |  30 ++--
 .../instance/state/StateStoreContextImpl.java      |  10 +-
 .../instance/state/StateStoreProvider.java         |  70 ++++++++
 .../pulsar/functions/instance/ContextImplTest.java |  25 +--
 ...textImplTest.java => BKStateStoreImplTest.java} |  33 +++-
 .../instance/state/InstanceStateManagerTest.java   | 122 ++++++++++++++
 .../apache/pulsar/io/core/ConnectorContext.java    |  15 ++
 22 files changed, 955 insertions(+), 368 deletions(-)
 copy pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/{Function.java => StateStore.java} (58%)
 copy pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/{SerDe.java => StateStoreContext.java} (83%)
 create mode 100644 pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/state/ByteBufferStateStore.java
 create mode 100644 pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/state/CounterStateStore.java
 copy {pulsar-common/src/main/java/org/apache/pulsar/common/policies => pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/state}/package-info.java (92%)
 rename pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/{StateContextImpl.java => BKStateStoreImpl.java} (56%)
 create mode 100644 pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/BKStateStoreProviderImpl.java
 copy pulsar-broker-common/src/main/java/org/apache/pulsar/common/configuration/Category.java => pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/DefaultStateStore.java (72%)
 create mode 100644 pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/InstanceStateManager.java
 delete mode 100644 pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/StateContext.java
 copy pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/ProxyStats.java => pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/StateManager.java (56%)
 copy pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/Sink.java => pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/StateStoreContextImpl.java (77%)
 create mode 100644 pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/StateStoreProvider.java
 rename pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/state/{StateContextImplTest.java => BKStateStoreImplTest.java} (80%)
 create mode 100644 pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/state/InstanceStateManagerTest.java