You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2014/08/26 13:25:22 UTC
svn commit: r1620572 -
/jena/trunk/jena-arq/src/main/java/org/apache/jena/riot/writer/WriterStreamRDFBatched.java
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) ;