svn commit: r1612545 - /jena/Experimental/jena-fuseki2/src/main/java/org/apache/jena/fuseki/migrate/StreamRDFLimited.java

[andy]

Author: andy
Date: Tue Jul 22 11:12:30 2014
New Revision: 1612545

URL: http://svn.apache.org/r1612545
Log:
Remove tuples handling from StreamRDF interface.

Modified:
    
jena/Experimental/jena-fuseki2/src/main/java/org/apache/jena/fuseki/migrate/StreamRDFLimited.java

Modified: 
jena/Experimental/jena-fuseki2/src/main/java/org/apache/jena/fuseki/migrate/StreamRDFLimited.java
URL: 
http://svn.apache.org/viewvc/jena/Experimental/jena-fuseki2/src/main/java/org/apache/jena/fuseki/migrate/StreamRDFLimited.java?rev=1612545&r1=1612544&r2=1612545&view=diff
==============================================================================
--- 
jena/Experimental/jena-fuseki2/src/main/java/org/apache/jena/fuseki/migrate/StreamRDFLimited.java
 (original)
+++ 
jena/Experimental/jena-fuseki2/src/main/java/org/apache/jena/fuseki/migrate/StreamRDFLimited.java
 Tue Jul 22 11:12:30 2014
@@ -18,12 +18,10 @@
 
 package org.apache.jena.fuseki.migrate ;
 
-import org.apache.jena.atlas.lib.Tuple ;
 import org.apache.jena.riot.RiotException ;
 import org.apache.jena.riot.system.StreamRDF ;
 import org.apache.jena.riot.system.StreamRDFWrapper ;
 
-import com.hp.hpl.jena.graph.Node ;
 import com.hp.hpl.jena.graph.Triple ;
 import com.hp.hpl.jena.sparql.core.Quad ;
 
@@ -55,14 +53,6 @@ public class StreamRDFLimited extends St
         super.quad(quad) ;
     }
 
-    @Override
-    public void tuple(Tuple<Node> tuple) {
-        count++ ;
-        if ( count > limit )
-            throw new RiotException("Limit ("+limit+") reached") ; 
-        super.tuple(tuple) ;
-    }
-
     public long getCount() {
         return count ;
     }