THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
package org.apache.kafka.streams; // Represents all the query options that a user can provide to state what kind of stores it is expecting public class StoreQueryParameters<T> { public static <T> StoreQueryParameters<T> fromNameAndType(final String storeName, final QueryableStoreType<T> queryableStoreType); public StoreQueryParameters<T> withPartition(final Integer partition); public StoreQueryParameters<T> enableStaleStores(); public Integer partition(); public boolean staleStoresEnabled(); public String storeName(); public QueryableStoreType<T> queryableStoreType(); } |
...