THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.kafka.streams; /** * Represents all the query options that a user can provide to state what kind of stores it is expecting. * The options would be whether a user would want to enable/disable stale stores * or whether it knows the list of partitions that it specifically wants to fetch. * If this information is not provided the default behavior is to fetch the stores for all the * partitions available on that instance* for for that particular store name. * It contains a list of partitions, which for a point queries can be populated from the KeyQueryMetadata. */ public class StoreQueryParams { private final List<Integer> partitions; private final boolean includeStaleStores; public StoreQueryParams(final List<Integer> partitions, final boolean includeStaleStores) { this.partitions = partitions; this.includeStaleStores = includeStaleStores; } /** * Get the list of partitions to be used to fetch list of Queryable store from QueryableStoreProvider. * * @return list of partitions */ public List<Integer> getPartitions() { return partitions; } /** * Get the flag includeStaleStores. If true, include standbys and recovering stores along with running stores * * @return includeStaleStores */ public boolean getIncludeStaleStores() { return includeStaleStores; } @Override public boolean equals(final Object obj) { if (!(obj instanceof StoreQueryParams)) { return false; } final StoreQueryParams storeQueryParams = (KeyQueryMetadataStoreQueryParams) obj; return Objects.equals(storeQueryParams.partitions, partitions) && Objects.equals(storeQueryParams.includeStaleStores, includeStaleStores); } @Override public String toString() { return "StoreQueryParams {" + "partitions=" + partitions + ", includeStaleStores=" + includeStaleStores + '}'; } @Override public int hashCode() { return Objects.hash(partitions, includeStaleStores); } } |
...