Class InMemoryWindowBytesStoreSupplier

    • Constructor Summary

      Constructors 
      Constructor Description
      InMemoryWindowBytesStoreSupplier​(java.lang.String name, long retentionPeriod, long windowSize, boolean retainDuplicates)  
    • Method Summary

      All Methods Instance Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      WindowStore<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.
      boolean retainDuplicates()
      Whether or not this store is retaining duplicate keys.
      long retentionPeriod()
      The time period for which the WindowStore will retain historic data.
      long segmentIntervalMs()
      The size of the segments (in milliseconds) the store has.
      int segments()
      Deprecated.
      java.lang.String toString()  
      long windowSize()
      The size of the windows (in milliseconds) any store created from this supplier is creating.
      • Methods inherited from class java.lang.Object

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

      • InMemoryWindowBytesStoreSupplier

        public InMemoryWindowBytesStoreSupplier​(java.lang.String name,
                                                long retentionPeriod,
                                                long windowSize,
                                                boolean retainDuplicates)
    • 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<WindowStore<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<WindowStore<org.apache.kafka.common.utils.Bytes,​byte[]>>
        Returns:
        metricsScope
      • segments

        @Deprecated
        public int segments()
        Deprecated.
        Description copied from interface: WindowBytesStoreSupplier
        The number of segments the store has. If your store is segmented then this should be the number of segments in the underlying store. It is also used to reduce the amount of data that is scanned when caching is enabled.
        Specified by:
        segments in interface WindowBytesStoreSupplier
        Returns:
        number of segments
      • segmentIntervalMs

        public long segmentIntervalMs()
        Description copied from interface: WindowBytesStoreSupplier
        The size of the segments (in milliseconds) the store has. If your store is segmented then this should be the size of segments in the underlying store. It is also used to reduce the amount of data that is scanned when caching is enabled.
        Specified by:
        segmentIntervalMs in interface WindowBytesStoreSupplier
        Returns:
        size of the segments (in milliseconds)
      • retainDuplicates

        public boolean retainDuplicates()
        Description copied from interface: WindowBytesStoreSupplier
        Whether or not this store is retaining duplicate keys. Usually only true if the store is being used for joins. Note this should return false if caching is enabled.
        Specified by:
        retainDuplicates in interface WindowBytesStoreSupplier
        Returns:
        true if duplicates should be retained
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object