org.apache.solr.analytics.stream

Class AnalyticsShardRequestManager

java.lang.Object

org.apache.solr.analytics.stream.AnalyticsShardRequestManager

public class AnalyticsShardRequestManager
extends Object

This class manages the requesting of shard responses from all shards in the queried collection.

Shard Requests are sent to the AnalyticsHandler instead of the AnalyticsComponent, which is the entrance to the analytics component for all client requests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AnalyticsShardRequestManager.AnalyticsShardRequester A class that opens a connection to a given solr instance, a selected replica of the queried collection, and sends a analytics request to the AnalyticsHandler.

Field Summary

Fields

Modifier and Type	Field and Description
protected CloudSolrClient	cloudSolrClient
protected List<String>	replicaUrls

Constructor Summary

Constructors

Constructor and Description
AnalyticsShardRequestManager(SolrParams params, AnalyticsRequestManager manager)

Method Summary

Modifier and Type	Method and Description
protected void	pickShards(String collection) Pick one replica from each shard to send the shard requests to.
void	sendRequests(String collection, String zkHost) Send out shard requests to each shard in the given collection.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

cloudSolrClient

protected transient CloudSolrClient cloudSolrClient

replicaUrls

protected transient List<String> replicaUrls

Constructor Detail

AnalyticsShardRequestManager

public AnalyticsShardRequestManager(SolrParams params,
                                    AnalyticsRequestManager manager)

Method Detail

sendRequests

public void sendRequests(String collection,
                         String zkHost)
                  throws IOException

Send out shard requests to each shard in the given collection.

Parameters:

collection - that is being queried

zkHost - of the solr cloud hosting the collection

Throws:

IOException - if an exception occurs while picking shards or sending requests

pickShards

protected void pickShards(String collection)
                   throws IOException

Pick one replica from each shard to send the shard requests to.

Parameters:

collection - that is being queried

Throws:

IOException - if an exception occurs while finding replicas