Page History

package org.apache.kafka.streams.internals;

public class MockStoreFactory<K, V extends StoreBuilder>V> {

    final String storeName;
    final Serde<K> keySerde;
    final Serde<V> valueSerde;
    final Time time;
    final Boolean persistent;

    public MockStoreFactory (final String storeName,
                             final Serde<K> keySerde,
                             final Serde<V> valueSerde,
                             final Time time) {

,
          this.storeName = storeName;
        this.keySerde = keySerde;
       final this.valueSerde = valueSerde;Boolean persistent) {

        this.timestoreName = timestoreName;
    }

    publicthis.keySerde MockKeyValueStoreBuilder createKeyValueStoreBuilder(){= keySerde;
        return new MockKeyValueStoreBuilder<>(storeName, keySerde, valueSerde, time)this.valueSerde = valueSerde;
    }

	public  MockWindowStoreBuilder createWindowStoreBuilder(){
    this.time = time;
     return new MockWindowStoreBuilder<>(storeName, keySerde, valueSerde, time) this.persistent = persistent;
    }

	    public MockSessionStoreBuilderMockKeyValueStoreBuilder createSessionStoreBuildercreateKeyValueStoreBuilder(){
        return new MockSessionStoreBuilder<>MockKeyValueStoreBuilder<K,V>(storeName, keySerde, valueSerde, time, persistent);
    }
}