Merge pull request #134 from FlorianLautenschlager/master

Configurable commit for the ingestion pipeline.
ChronixDB · May 9, 2017 · 90b5d93 · 90b5d93
2 parents b2b2789 + fc6ccb6
commit 90b5d93
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/...tion-handler/src/main/java/de/qaware/chronix/solr/ingestion/AbstractIngestionHandler.java b/...tion-handler/src/main/java/de/qaware/chronix/solr/ingestion/AbstractIngestionHandler.java
@@ -63,6 +63,8 @@ public void handleRequestBody(SolrQueryRequest req, SolrQueryResponse rsp) throw
             return;
         }
 
+        boolean commit = Boolean.parseBoolean(req.getParams().get("commit", "true"));
+
         InputStream stream = req.getContentStreams().iterator().next().getStream();
 
         MetricTimeSeriesConverter converter = new MetricTimeSeriesConverter();
@@ -76,9 +78,13 @@ public void handleRequestBody(SolrQueryRequest req, SolrQueryResponse rsp) throw
                 storeDocument(document, processor, req);
             }
 
-            LOGGER.debug("Committing transaction...");
-            processor.processCommit(new CommitUpdateCommand(req, false));
-            LOGGER.debug("Committed transaction");
+            if (commit) {
+                LOGGER.debug("Committing transaction...");
+                processor.processCommit(new CommitUpdateCommand(req, false));
+                LOGGER.debug("Committed transaction");
+            } else {
+                LOGGER.debug("Only adding documents.");
+            }
         } finally {
             processor.finish();
         }