public class MockZkStateReader extends ZkStateReader
ACTIVE, ALIASES, AUTO_ADD_REPLICAS, BASE_URL_PROP, CLUSTER_PROPS, CLUSTER_STATE, clusterState, COLLECTION_PROP, COLLECTIONS_ZKNODE, CONFIGNAME_PROP, CONFIGS_ZKNODE, CORE_NAME_PROP, CORE_NODE_NAME_PROP, DOWN, LEADER_ELECT_ZKNODE, LEADER_PROP, LEGACY_CLOUD, LIVE_NODES_ZKNODE, MAX_SHARDS_PER_NODE, NODE_NAME_PROP, NUM_SHARDS_PROP, RECOVERING, RECOVERY_FAILED, REPLICA_PROP, REPLICATION_FACTOR, ROLES, ROLES_PROP, SHARD_ID_PROP, SHARD_LEADERS_ZKNODE, SHARD_PARENT_PROP, SHARD_RANGE_PROP, SHARD_STATE_PROP, STATE_PROP, SYNC, URL_SCHEME
Constructor and Description |
---|
MockZkStateReader(ClusterState clusterState,
Set<String> collections) |
Modifier and Type | Method and Description |
---|---|
Set<String> |
getAllCollections() |
close, createClusterStateWatchersAndUpdate, fromJSON, getAliases, getBaseUrlForNodeName, getClusterProps, getClusterState, getLeaderRetry, getLeaderRetry, getLeaderUrl, getReplicaProps, getReplicaProps, getReplicaProps, getShardLeadersPath, getUpdateLock, getZkClient, readConfigName, toJSON, toUTF8, updateAliases, updateClusterState, updateLiveNodes
public MockZkStateReader(ClusterState clusterState, Set<String> collections)
Copyright © 2000–2015 The Apache Software Foundation. All rights reserved.