class JsonLoader extends ContentStreamLoader
| Modifier and Type | Field and Description |
|---|---|
protected int |
commitWithin |
(package private) static org.slf4j.Logger |
log |
protected boolean |
overwrite |
protected JSONParser |
parser |
protected UpdateRequestProcessor |
processor |
protected SolrQueryRequest |
req |
errHeader| Constructor and Description |
|---|
JsonLoader(SolrQueryRequest req,
UpdateRequestProcessor processor) |
| Modifier and Type | Method and Description |
|---|---|
(package private) static void |
addValToField(java.util.Stack stack,
java.lang.Object val,
boolean inArray,
JSONParser parser) |
(package private) void |
assertEvent(int ev,
int expected) |
(package private) int |
assertNextEvent(int expected) |
(package private) void |
handleAdds() |
void |
load(SolrQueryRequest req,
SolrQueryResponse rsp,
ContentStream stream)
Loaders are responsible for closing the stream
|
(package private) AddUpdateCommand |
parseAdd() |
(package private) void |
parseCommitOptions(CommitUpdateCommand cmd) |
(package private) DeleteUpdateCommand |
parseDelete() |
(package private) SolrInputDocument |
parseDoc(int ev) |
(package private) RollbackUpdateCommand |
parseRollback() |
(package private) void |
processUpdate() |
getErrHeader, setErrHeaderstatic final org.slf4j.Logger log
protected final UpdateRequestProcessor processor
protected final SolrQueryRequest req
protected JSONParser parser
protected final int commitWithin
protected final boolean overwrite
public JsonLoader(SolrQueryRequest req, UpdateRequestProcessor processor)
public void load(SolrQueryRequest req, SolrQueryResponse rsp, ContentStream stream) throws java.lang.Exception
ContentStreamLoaderload in class ContentStreamLoaderreq - The input SolrQueryRequestrsp - The response, in case the Loader wishes to add anythingstream - The ContentStream to addjava.lang.Exceptionvoid processUpdate()
throws java.io.IOException
java.io.IOExceptionDeleteUpdateCommand parseDelete() throws java.io.IOException
java.io.IOExceptionRollbackUpdateCommand parseRollback() throws java.io.IOException
java.io.IOExceptionvoid parseCommitOptions(CommitUpdateCommand cmd) throws java.io.IOException
java.io.IOExceptionAddUpdateCommand parseAdd() throws java.io.IOException
java.io.IOExceptionvoid handleAdds()
throws java.io.IOException
java.io.IOExceptionint assertNextEvent(int expected)
throws java.io.IOException
java.io.IOExceptionvoid assertEvent(int ev,
int expected)
SolrInputDocument parseDoc(int ev) throws java.io.IOException
java.io.IOExceptionstatic void addValToField(java.util.Stack stack,
java.lang.Object val,
boolean inArray,
JSONParser parser)
throws java.io.IOException
java.io.IOException