Page History

package org.apache.kafka.streams.internals;

public class MockStoreFactory<K, V> {

    public final String storeName;
     Map<String, StoreBuilder> stateStores = new LinkedHashMap<>();

    public MockStoreFactory () {
    }

    public KeyValueStoreBuilder createKeyValueStoreBuilder(KeyValueBytesStoreSupplier keyValueBytesStoreSupplier,
                                                           final Serde<K> keySerde;
,
                                                           final Serde<V> valueSerde;
    final Time time;
    final Boolean persistent;
,
                                                           boolean persistent){
		String storeName = keyValueBytesStoreSupplier.name();
        stateStores.put(storeName, new MockKeyValueStoreBuilder<>(storeName, keyValueBytesStoreSupplier, keySerde, valueSerde, persistent));
        return (KeyValueStoreBuilder)stateStores.get(storeName);
    }

	public MockStoreFactoryWindowStoreBuilder createWindowStoreBuilder() {
		
    KeyValueBytesStoreSupplier keyValueBytesStoreSupplier,
                                                           final Serde<K> keySerde,
                                                           final Serde<V> valueSerde,
                                                           final Time time){
	...
	}

	public SessionStoreBuilder createSessionStoreBuilder(KeyValueBytesStoreSupplier keyValueBytesStoreSupplier,
                                                           final Serde<K> keySerde,
                                                           final Serde<V> valueSerde,
                                                           final Time time){
	...
	}

    public MockKeyValueStoreBuilderStoreBuilder createKeyValueStoreBuildergetStore(String storeName) {
        return new MockKeyValueStoreBuilder<K,V>(storeName, keySerde, valueSerde, timestateStores.get(storeName);
    }



}