org.apache.solr.analytics.stream

Class AnalyticsShardRequestManager.AnalyticsShardRequester

java.lang.Object

org.apache.solr.analytics.stream.AnalyticsShardRequestManager.AnalyticsShardRequester

All Implemented Interfaces:

Callable<SolrException>

Enclosing class:

AnalyticsShardRequestManager

protected class AnalyticsShardRequestManager.AnalyticsShardRequester
extends Object
implements Callable<SolrException>

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. The results are processed by an AnalyticsShardResponseParser constructed with the AnalyticsRequestManager passed to the parent AnalyticsShardRequestManager.

Constructor Summary

Constructors

Constructor and Description
AnalyticsShardRequester(String baseUrl) Create a requester for analytics shard data.

Method Summary

Modifier and Type	Method and Description
SolrException	call() Send the analytics request to the shard.
void	close() Close the connection to the solr instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsShardRequester

public AnalyticsShardRequester(String baseUrl)

Create a requester for analytics shard data.

Parameters:

baseUrl - of the replica to send the request to

Method Detail

call

public SolrException call()
                   throws Exception

Send the analytics request to the shard.

Specified by:

call in interface Callable<SolrException>

Throws:

Exception

close

public void close()
           throws IOException

Close the connection to the solr instance.

Throws:

IOException - if an error occurs while closing the connection