org.apache.solr.client.solrj.request

Class JavaBinUpdateRequestCodec

java.lang.Object

org.apache.solr.client.solrj.request.JavaBinUpdateRequestCodec

public class JavaBinUpdateRequestCodec
extends java.lang.Object

Provides methods for marshalling an UpdateRequest to a NamedList which can be serialized in the javabin format and vice versa.

Since:

solr 1.4

Version:

$Id: JavaBinUpdateRequestCodec.java 1235304 2012-01-24 15:39:17Z janhoy $

See Also:

JavaBinCodec

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	JavaBinUpdateRequestCodec.StreamingUpdateHandler

Constructor Summary

Constructors

Constructor and Description
JavaBinUpdateRequestCodec()

Method Summary

Modifier and Type	Method and Description
private SolrInputDocument	listToSolrInputDocument(java.util.List<NamedList> namedList)
void	marshal(UpdateRequest updateRequest, java.io.OutputStream os) Converts an UpdateRequest to a NamedList which can be serialized to the given OutputStream in the javabin format
private java.util.List<NamedList>	solrInputDocumentToList(SolrInputDocument doc)
private NamedList	solrParamsToNamedList(SolrParams params)
UpdateRequest	unmarshal(java.io.InputStream is, JavaBinUpdateRequestCodec.StreamingUpdateHandler handler) Reads a NamedList from the given InputStream, converts it into a SolrInputDocument and passes it to the given StreamingDocumentHandler

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaBinUpdateRequestCodec

public JavaBinUpdateRequestCodec()

Method Detail

marshal

public void marshal(UpdateRequest updateRequest,
                    java.io.OutputStream os)
             throws java.io.IOException

Converts an UpdateRequest to a NamedList which can be serialized to the given OutputStream in the javabin format

Parameters:

updateRequest - the UpdateRequest to be written out

os - the OutputStream to which the request is to be written

Throws:

java.io.IOException - in case of an exception during marshalling or writing to the stream

unmarshal

public UpdateRequest unmarshal(java.io.InputStream is,
                               JavaBinUpdateRequestCodec.StreamingUpdateHandler handler)
                        throws java.io.IOException

Reads a NamedList from the given InputStream, converts it into a SolrInputDocument and passes it to the given StreamingDocumentHandler

Parameters:

is - the InputStream from which to read

handler - an instance of StreamingDocumentHandler to which SolrInputDocuments are streamed one by one

Returns:

the UpdateRequest

Throws:

java.io.IOException - in case of an exception while reading from the input stream or unmarshalling

solrInputDocumentToList

private java.util.List<NamedList> solrInputDocumentToList(SolrInputDocument doc)

listToSolrInputDocument

private SolrInputDocument listToSolrInputDocument(java.util.List<NamedList> namedList)

solrParamsToNamedList

private NamedList solrParamsToNamedList(SolrParams params)