svn commit: r1618179 - /jena/trunk/jena-arq/src/main/java/riotcmd/CmdLangParse.java

[andy]

Author: andy
Date: Fri Aug 15 14:19:27 2014
New Revision: 1618179

URL: http://svn.apache.org/r1618179
Log:
Allow subclasses to create the destination for parsing.

Modified:
    jena/trunk/jena-arq/src/main/java/riotcmd/CmdLangParse.java

Modified: jena/trunk/jena-arq/src/main/java/riotcmd/CmdLangParse.java
URL: 
http://svn.apache.org/viewvc/jena/trunk/jena-arq/src/main/java/riotcmd/CmdLangParse.java?rev=1618179&r1=1618178&r2=1618179&view=diff
==============================================================================
--- jena/trunk/jena-arq/src/main/java/riotcmd/CmdLangParse.java (original)
+++ jena/trunk/jena-arq/src/main/java/riotcmd/CmdLangParse.java Fri Aug 15 
14:19:27 2014
@@ -240,9 +240,7 @@ public abstract class CmdLangParse exten
         if ( labelsAsGiven )
             labels = NodeToLabel.createBNodeByLabelEncoded() ;
         
-        StreamRDF s = StreamRDFLib.sinkNull() ;
-        if ( ! modLangParse.toBitBucket() )
-            s = StreamRDFLib.writer(output) ;
+        StreamRDF s = createSink() ;
         if ( setup != null )
             s = InfFactory.inf(s, setup) ;
         StreamRDFCounting sink = StreamRDFLib.count(s) ;
@@ -283,6 +281,13 @@ public abstract class CmdLangParse exten
         totalTuples += n ;
     }
     
+    protected StreamRDF createSink() {
+        StreamRDF s = StreamRDFLib.sinkNull() ;
+        if ( ! modLangParse.toBitBucket() )
+            s = StreamRDFLib.writer(output) ;
+        return s ;
+    }
+    
     protected Tokenizer makeTokenizer(InputStream in)
     {
         Tokenizer tokenizer = TokenizerFactory.makeTokenizerUTF8(in) ;