Package | Description |
---|---|
org.apache.solr.handler.component |
Class for tracking shard requests
|
Modifier and Type | Method and Description |
---|---|
TrackingShardHandlerFactory.ShardRequestAndParams |
TrackingShardHandlerFactory.RequestTrackingQueue.getShardRequestByPurpose(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
String collectionName,
String shardId,
int purpose)
Retrieve request recorded by this queue which were sent to given collection, shard and purpose
|
Modifier and Type | Method and Description |
---|---|
Map<String,List<TrackingShardHandlerFactory.ShardRequestAndParams>> |
TrackingShardHandlerFactory.RequestTrackingQueue.getAllRequests()
Retrieves all requests recorded by this collection as a Map of shard address (string url)
to a list of
TrackingShardHandlerFactory.ShardRequestAndParams |
List<TrackingShardHandlerFactory.ShardRequestAndParams> |
TrackingShardHandlerFactory.RequestTrackingQueue.getCoreAdminRequests()
Retrieves all core admin requests distributed to nodes by Collection API commands
|
List<TrackingShardHandlerFactory.ShardRequestAndParams> |
TrackingShardHandlerFactory.RequestTrackingQueue.getShardRequests(org.apache.solr.common.cloud.ZkStateReader zkStateReader,
String collectionName,
String shardId)
Retrieve all requests recorded by this queue which were sent to given collection and shard
|
Queue<TrackingShardHandlerFactory.ShardRequestAndParams> |
TrackingShardHandlerFactory.getTrackingQueue() |
Modifier and Type | Method and Description |
---|---|
boolean |
TrackingShardHandlerFactory.RequestTrackingQueue.offer(TrackingShardHandlerFactory.ShardRequestAndParams shardRequestAndParams) |
Modifier and Type | Method and Description |
---|---|
static void |
TrackingShardHandlerFactory.setTrackingQueue(List<org.apache.solr.client.solrj.embedded.JettySolrRunner> runners,
Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)
Sets the tracking queue for all nodes participating in this cluster.
|
static void |
TrackingShardHandlerFactory.setTrackingQueue(MiniSolrCloudCluster cluster,
Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)
Sets the tracking queue for all nodes participating in this cluster.
|
void |
TrackingShardHandlerFactory.setTrackingQueue(Queue<TrackingShardHandlerFactory.ShardRequestAndParams> queue)
Set the tracking queue for this factory.
|
Copyright © 2000-2017 Apache Software Foundation. All Rights Reserved.