Examples of com.hp.hpl.jena.sparql.engine.ResultSetStream

com.hp.hpl.jena.sparql.engine.ResultSetStream
The main ResultSet implementation for returning results from queries. This version is "use once" - you can not reset the result set because the results of the query are not remembered so as not to consume potentially large amounts of memory.

            Binding b = BuilderBinding.build(itemRow) ;
            bindings.add(b) ;
        }
        
        QueryIterator qIter = new QueryIterPlainWrapper(bindings.listIterator()) ;
        return new ResultSetStream(Var.varNames(vars), null, qIter) ;
    }

View Full Code Here


    private static void dump(Table table)
    {
        System.out.println("Table: "+Utils.className(table)) ;
        QueryIterator qIter = table.iterator(null) ;
        ResultSet rs = new ResultSetStream(table.getVarNames(), null, table.iterator(null)) ;
        ResultSetFormatter.out(rs) ;
    }

View Full Code Here

        try {
            // Run first without optimization
            ARQ.set(opt, false);
            QueryEngineMain engine = new QueryEngineMain(op, ds.asDatasetGraph(), BindingFactory.binding(), ARQ.getContext());
            QueryIterator iter = engine.eval(op, ds.asDatasetGraph(), BindingFactory.binding(), ARQ.getContext());
            ResultSetRewindable rs = ResultSetFactory.makeRewindable(new ResultSetStream(vars, ModelFactory.createDefaultModel(),
                    iter));
            if (expected != rs.size()) {
                System.err.println("Non-optimized results not as expected");
                TextOutput output = new TextOutput((SerializationContext)null);
                output.format(System.out, rs);
                rs.reset();
            }
            Assert.assertEquals(expected, rs.size());
            iter.close();


            // Run with optimization
            ARQ.set(opt, true);
            engine = new QueryEngineMain(op, ds.asDatasetGraph(), BindingFactory.binding(), ARQ.getContext());
            QueryIterator iterOpt = engine.eval(op, ds.asDatasetGraph(), BindingFactory.binding(), ARQ.getContext());
            ResultSetRewindable rsOpt = ResultSetFactory.makeRewindable(new ResultSetStream(vars, ModelFactory
                    .createDefaultModel(), iterOpt));
            if (expected != rsOpt.size()) {
                System.err.println("Optimized results not as expected");
                TextOutput output = new TextOutput((SerializationContext)null);
                output.format(System.out, rsOpt);

View Full Code Here

            // -------- Or make ResultSet from it (but not both - reading an
            //          iterator consumes the current solution)
            List<String> varNames = new ArrayList<String>() ;
            varNames.add("x") ;
            varNames.add("z") ;
            ResultSet rs = new ResultSetStream(varNames, m, qIter);
            ResultSetFormatter.out(rs) ;
            qIter.close() ;
        }
        System.exit(0) ;
    }

View Full Code Here

            Binding b = BuilderBinding.build(itemRow) ;
            bindings.add(b) ;
        }
        
        QueryIterator qIter = new QueryIterPlainWrapper(bindings.listIterator()) ;
        return new ResultSetStream(Var.varNames(vars), null, qIter) ;
    }

View Full Code Here

            throw new ARQException(ex) ;
        }


        //Generate an instance of ResultSetStream using TSVInputIterator
        //This will parse actual result rows as needed thus minimising memory usage
        return new ResultSetStream(varNames, null, new CSVInputIterator(reader, vars));
    }

View Full Code Here

    
    @Override
    public ResultSet toResultSet()
    {
        QueryIterator qIter = iterator(null) ;
        ResultSet rs = new ResultSetStream(getVarNames(), null, qIter) ;
        rs = ResultSetFactory.makeRewindable(rs) ;
        qIter.close() ;
        return rs ;
    }

View Full Code Here

                // Set superclass member
                set(handler.askResult) ;
                return ;
            }


            ResultSetStream rss = new ResultSetStream(handler.variables, model,
                                                      new QueryIterPlainWrapper(handler.results.iterator())) ;
            // Set superclass member
            set(rss) ;
        }
        catch (SAXException ex)

View Full Code Here

     *  @param vars     List of variables, by name, for the result set
     *  @return ResultSet 
     */
    static public ResultSet create(QueryIterator queryIterator, List<String> vars)
    {
        return new ResultSetStream(vars, null, queryIterator) ;
    }

View Full Code Here

                if ( ! vars.contains(v) )
                    vars.add(v) ;
            }
        }
        QueryIterator qIter = new QueryIterPlainWrapper(bindings.iterator()) ;
        return new ResultSetStream(Var.varNames(vars), m, qIter) ;
    }

View Full Code Here

0 1 2 3 4 5 6 7

TOP

Related Classes of com.hp.hpl.jena.sparql.engine.ResultSetStream

arq.examples.AlgebraExec

com.hp.hpl.jena.query.BIOInput

com.hp.hpl.jena.query.ResultSetFactory

com.hp.hpl.jena.sparql.algebra.optimize.TestSemanticEquivalence

com.hp.hpl.jena.sparql.algebra.table.TableBase

com.hp.hpl.jena.sparql.core.ResultBinding

com.hp.hpl.jena.sparql.engine.binding.Binding

com.hp.hpl.jena.sparql.engine.ref.EvaluatorSimple

com.hp.hpl.jena.sparql.junit.QueryTest

com.hp.hpl.jena.sparql.resultset.CSVInput

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.