org.apache.solr.analytics.stream

Class AnalyticsShardResponseParser

java.lang.Object

org.apache.solr.client.solrj.ResponseParser

org.apache.solr.analytics.stream.AnalyticsShardResponseParser

public class AnalyticsShardResponseParser
extends ResponseParser

This parser initiates a merge of an Analytics Shard Response, sent from the AnalyticsHandler. The input stream is immediately sent to the given AnalyticsRequestManager to merge.

Field Summary

Fields

Modifier and Type	Field and Description
static String	BINARY_CONTENT_TYPE
static String	STREAM

Constructor Summary

Constructors

Constructor and Description
AnalyticsShardResponseParser(AnalyticsRequestManager manager)

Method Summary

Modifier and Type	Method and Description
String	getContentType()
String	getVersion()
String	getWriterType()
NamedList<Object>	processResponse(InputStream body, String encoding)
NamedList<Object>	processResponse(Reader reader)

Methods inherited from class java.lang.Object

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

Field Detail

BINARY_CONTENT_TYPE

public static final String BINARY_CONTENT_TYPE

See Also:

Constant Field Values

STREAM

public static final String STREAM

See Also:

Constant Field Values

Constructor Detail

AnalyticsShardResponseParser

public AnalyticsShardResponseParser(AnalyticsRequestManager manager)

Parameters:

manager - the manager of the current Analytics Request, will manage the merging of shard data

Method Detail

getWriterType

public String getWriterType()

Specified by:

getWriterType in class ResponseParser

processResponse

public NamedList<Object> processResponse(InputStream body,
                                         String encoding)

Specified by:

processResponse in class ResponseParser

getContentType

public String getContentType()

Overrides:

getContentType in class ResponseParser

getVersion

public String getVersion()

Overrides:

getVersion in class ResponseParser

processResponse

public NamedList<Object> processResponse(Reader reader)

Specified by:

processResponse in class ResponseParser