public class StoreQueryParameters<T>
extends java.lang.Object
StoreQueryParameters
allows you to pass a variety of parameters when fetching a store for interactive query.Modifier and Type | Method and Description |
---|---|
StoreQueryParameters<T> |
enableStaleStores()
Enable querying of stale state stores, i.e., allow to query active tasks during restore as well as standby tasks.
|
boolean |
equals(java.lang.Object obj) |
static <T> StoreQueryParameters<T> |
fromNameAndType(java.lang.String storeName,
QueryableStoreType<T> queryableStoreType) |
int |
hashCode() |
java.lang.Integer |
partition()
Get the store partition that will be queried.
|
QueryableStoreType<T> |
queryableStoreType()
Get the queryable store type for which key is queried by the user.
|
boolean |
staleStoresEnabled()
Get the flag staleStores.
|
java.lang.String |
storeName()
Get the name of the state store that should be queried.
|
java.lang.String |
toString() |
StoreQueryParameters<T> |
withPartition(java.lang.Integer partition)
Set a specific partition that should be queried exclusively.
|
public static <T> StoreQueryParameters<T> fromNameAndType(java.lang.String storeName, QueryableStoreType<T> queryableStoreType)
public StoreQueryParameters<T> withPartition(java.lang.Integer partition)
partition
- The specific integer partition to be fetched from the stores list by using StoreQueryParameters
.StoreQueryParameters
instance configured with the specified partitionpublic StoreQueryParameters<T> enableStaleStores()
StoreQueryParameters
instance configured with serving from stale stores enabledpublic java.lang.String storeName()
public QueryableStoreType<T> queryableStoreType()
public java.lang.Integer partition()
null
, it would mean that no specific partition has been requested,
so all the local partitions for the store will be queried.public boolean staleStoresEnabled()
true
, include standbys and recovering stores along with running stores.public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object