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, setErrHeader
static 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
ContentStreamLoader
load
in class ContentStreamLoader
req
- The input SolrQueryRequest
rsp
- The response, in case the Loader wishes to add anythingstream
- The ContentStream
to addjava.lang.Exception
void processUpdate() throws java.io.IOException
java.io.IOException
DeleteUpdateCommand parseDelete() throws java.io.IOException
java.io.IOException
RollbackUpdateCommand parseRollback() throws java.io.IOException
java.io.IOException
void parseCommitOptions(CommitUpdateCommand cmd) throws java.io.IOException
java.io.IOException
AddUpdateCommand parseAdd() throws java.io.IOException
java.io.IOException
void handleAdds() throws java.io.IOException
java.io.IOException
int assertNextEvent(int expected) throws java.io.IOException
java.io.IOException
void assertEvent(int ev, int expected)
SolrInputDocument parseDoc(int ev) throws java.io.IOException
java.io.IOException
static void addValToField(java.util.Stack stack, java.lang.Object val, boolean inArray, JSONParser parser) throws java.io.IOException
java.io.IOException