svn commit: r1620572 - /jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/writer/WriterStreamRDFBatched.java

[andy]

Author: andy
Date: Tue Aug 26 11:25:21 2014
New Revision: 1620572

URL: http://svn.apache.org/r1620572
Log:
Clear batch when processed.

Modified:
    
jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/writer/WriterStreamRDFBatched.java

Modified: 
jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/writer/WriterStreamRDFBatched.java
URL: 
http://svn.apache.org/viewvc/jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/writer/WriterStreamRDFBatched.java?rev=1620572&r1=1620571&r2=1620572&view=diff
==============================================================================
--- 
jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/writer/WriterStreamRDFBatched.java
 (original)
+++ 
jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/writer/WriterStreamRDFBatched.java
 Tue Aug 26 11:25:21 2014
@@ -121,8 +121,10 @@ abstract class WriterStreamRDFBatched ex
 
     private void finishBatchTriple(Node subject)
     {
-        if ( batchTriples != null && batchTriples.size() > 0 )
+        if ( batchTriples != null && batchTriples.size() > 0 ) {
             printBatchTriples(currentSubject, batchTriples) ;
+            batchTriples.clear() ;
+        }
     }
 
     private void startBatchQuad(Node graph, Node subject)
@@ -137,8 +139,10 @@ abstract class WriterStreamRDFBatched ex
 
     private void finishBatchQuad(Node graph, Node subject)
     {
-        if ( batchQuads != null && batchQuads.size() > 0 )
+        if ( batchQuads != null && batchQuads.size() > 0 ) {
             printBatchQuads(currentGraph, currentSubject, batchQuads) ;
+            batchQuads.clear();
+        }
     }
 
     protected abstract void printBatchQuads(Node g, Node s, List<Quad> batch) ;