Package org.apache.pulsar.functions.api

Interface StateStore

All Superinterfaces:
AutoCloseable
All Known Subinterfaces:
ByteBufferStateStore, CounterStateStore
@Public @Evolving public interface StateStore extends AutoCloseable

  • Method Details

    • tenant

      String tenant()
      The tenant of this store.
      Returns:
      the state store tenant.

    • namespace

      String namespace()
      The namespace of this store.
      Returns:
      the state store namespace.

    • name

      String name()
      The name of this store.
      Returns:
      the state store name.

    • fqsn

      String fqsn()
      The fully qualified state store name.
      Returns:
      the fully qualified state store name.

    • init

      void init(StateStoreContext ctx)
      Initialize the state store.
      Parameters:
      ctx - the state store context

    • close

      void close()
      Specified by:
      close in interface AutoCloseable