Class MaterializedInternal<K,​V,​S extends StateStore>

    • Constructor Detail

      • MaterializedInternal

        public MaterializedInternal​(Materialized<K,​V,​S> materialized)
    • Method Detail

      • generateStoreNameIfNeeded

        public void generateStoreNameIfNeeded​(InternalNameProvider nameProvider,
                                              java.lang.String generatedStorePrefix)
      • storeName

        public java.lang.String storeName()
      • keySerde

        public org.apache.kafka.common.serialization.Serde<K> keySerde()
      • valueSerde

        public org.apache.kafka.common.serialization.Serde<V> valueSerde()
      • loggingEnabled

        public boolean loggingEnabled()
      • cachingEnabled

        public boolean cachingEnabled()
      • isQueryable

        public boolean isQueryable()