Package org.apache.solr.update.processor
Class BufferingRequestProcessor
- java.lang.Object
-
- org.apache.solr.update.processor.UpdateRequestProcessor
-
- org.apache.solr.update.processor.BufferingRequestProcessor
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
public class BufferingRequestProcessor extends org.apache.solr.update.processor.UpdateRequestProcessor
-
-
Field Summary
Fields Modifier and Type Field Description List<org.apache.solr.update.AddUpdateCommand>
addCommands
List<org.apache.solr.update.CommitUpdateCommand>
commitCommands
List<org.apache.solr.update.DeleteUpdateCommand>
deleteCommands
List<org.apache.solr.update.RollbackUpdateCommand>
rollbackCommands
-
Constructor Summary
Constructors Constructor Description BufferingRequestProcessor(org.apache.solr.update.processor.UpdateRequestProcessor next)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
finish()
void
processAdd(org.apache.solr.update.AddUpdateCommand cmd)
void
processCommit(org.apache.solr.update.CommitUpdateCommand cmd)
void
processDelete(org.apache.solr.update.DeleteUpdateCommand cmd)
void
processRollback(org.apache.solr.update.RollbackUpdateCommand cmd)
-
-
-
Field Detail
-
addCommands
public List<org.apache.solr.update.AddUpdateCommand> addCommands
-
deleteCommands
public List<org.apache.solr.update.DeleteUpdateCommand> deleteCommands
-
commitCommands
public List<org.apache.solr.update.CommitUpdateCommand> commitCommands
-
rollbackCommands
public List<org.apache.solr.update.RollbackUpdateCommand> rollbackCommands
-
-
Method Detail
-
processAdd
public void processAdd(org.apache.solr.update.AddUpdateCommand cmd) throws IOException
- Overrides:
processAdd
in classorg.apache.solr.update.processor.UpdateRequestProcessor
- Throws:
IOException
-
processDelete
public void processDelete(org.apache.solr.update.DeleteUpdateCommand cmd) throws IOException
- Overrides:
processDelete
in classorg.apache.solr.update.processor.UpdateRequestProcessor
- Throws:
IOException
-
processCommit
public void processCommit(org.apache.solr.update.CommitUpdateCommand cmd) throws IOException
- Overrides:
processCommit
in classorg.apache.solr.update.processor.UpdateRequestProcessor
- Throws:
IOException
-
processRollback
public void processRollback(org.apache.solr.update.RollbackUpdateCommand cmd) throws IOException
- Overrides:
processRollback
in classorg.apache.solr.update.processor.UpdateRequestProcessor
- Throws:
IOException
-
finish
public void finish() throws IOException
- Overrides:
finish
in classorg.apache.solr.update.processor.UpdateRequestProcessor
- Throws:
IOException
-
-