Class InMemorySessionBytesStoreSupplier

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      SessionStore<org.apache.kafka.common.utils.Bytes,​byte[]> get()
      Return a new StateStore instance.
      java.lang.String metricsScope()
      Return a String that is used as the scope for metrics recorded by Metered stores.
      java.lang.String name()
      Return the name of this state store supplier.
      long retentionPeriod()
      The time period for which the SessionStore will retain historic data.
      long segmentIntervalMs()
      The size of a segment, in milliseconds.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • InMemorySessionBytesStoreSupplier

        public InMemorySessionBytesStoreSupplier​(java.lang.String name,
                                                 long retentionPeriod)
    • Method Detail

      • name

        public java.lang.String name()
        Description copied from interface: StoreSupplier
        Return the name of this state store supplier. This must be a valid Kafka topic name; valid characters are ASCII alphanumerics, '.', '_' and '-'.
        Specified by:
        name in interface StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,​byte[]>>
        Returns:
        the name of this state store supplier
      • metricsScope

        public java.lang.String metricsScope()
        Description copied from interface: StoreSupplier
        Return a String that is used as the scope for metrics recorded by Metered stores.
        Specified by:
        metricsScope in interface StoreSupplier<SessionStore<org.apache.kafka.common.utils.Bytes,​byte[]>>
        Returns:
        metricsScope
      • segmentIntervalMs

        public long segmentIntervalMs()
        Description copied from interface: SessionBytesStoreSupplier
        The size of a segment, in milliseconds. Used when caching is enabled to segment the cache and reduce the amount of data that needs to be scanned when performing range queries.
        Specified by:
        segmentIntervalMs in interface SessionBytesStoreSupplier
        Returns:
        segmentInterval in milliseconds