Package org.aksw.jenax.sparql.query.rx

Class ResultSetRxImpl

java.lang.Object
org.aksw.jenax.sparql.query.rx.ResultSetRxImpl
All Implemented Interfaces:
ResultSetRx
public class ResultSetRxImpl extends Object implements ResultSetRx

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding>
    bindings
     
    protected org.aksw.jenax.stmt.core.SparqlStmtQuery
    queryStmt
     
    protected List<org.apache.jena.sparql.core.Var>
    vars
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ResultSetRxImpl(org.aksw.jenax.stmt.core.SparqlStmtQuery queryStmt, List<org.apache.jena.sparql.core.Var> vars, io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding> bindings)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static ResultSetRxImpl
    create(List<org.apache.jena.sparql.core.Var> vars, io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding> bindings)
     
    static ResultSetRxImpl
    create(org.apache.jena.query.Query query, List<org.apache.jena.sparql.core.Var> vars, io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding> bindings)
     
    io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding>
    getBindings()
     
    org.aksw.jenax.stmt.core.SparqlStmtQuery
    getQueryStmt()
     
    List<org.apache.jena.sparql.core.Var>
    getVars()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.aksw.jenax.sparql.query.rx.ResultSetRx

    asQueryExec, asQueryExecution, asQueryIterator

  • Field Details

    • queryStmt

      protected org.aksw.jenax.stmt.core.SparqlStmtQuery queryStmt

    • vars

      protected List<org.apache.jena.sparql.core.Var> vars

    • bindings

      protected io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding> bindings

  • Constructor Details

    • ResultSetRxImpl

      public ResultSetRxImpl(org.aksw.jenax.stmt.core.SparqlStmtQuery queryStmt, List<org.apache.jena.sparql.core.Var> vars, io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding> bindings)

  • Method Details

    • getQueryStmt

      public org.aksw.jenax.stmt.core.SparqlStmtQuery getQueryStmt()
      Specified by:
      getQueryStmt in interface ResultSetRx

    • getVars

      public List<org.apache.jena.sparql.core.Var> getVars()
      Specified by:
      getVars in interface ResultSetRx

    • getBindings

      public io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding> getBindings()
      Specified by:
      getBindings in interface ResultSetRx

    • create

      public static ResultSetRxImpl create(List<org.apache.jena.sparql.core.Var> vars, io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding> bindings)

    • create

      public static ResultSetRxImpl create(org.apache.jena.query.Query query, List<org.apache.jena.sparql.core.Var> vars, io.reactivex.rxjava3.core.Flowable<org.apache.jena.sparql.engine.binding.Binding> bindings)