Package org.aksw.jenax.sparql.datasource.observable

Class RdfDataSourceObservableImpl

java.lang.Object
org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSourceWrapperBase
org.aksw.jenax.sparql.datasource.observable.RdfDataSourceObservableImpl
All Implemented Interfaces:
org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSource, org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSourceWrapper, RdfDataSourceObservable
public class RdfDataSourceObservableImpl extends org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSourceWrapperBase implements RdfDataSourceObservable

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected ObservableSourceImpl<org.apache.jena.query.Query,org.aksw.jenax.arq.util.binding.ResultTable>
    mapRx
     

    Fields inherited from class org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSourceWrapperBase

    delegate

  • Constructor Summary

    Constructors
    Constructor
    Description
    RdfDataSourceObservableImpl(org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSource delegate)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.aksw.jenax.arq.util.binding.ResultTable
    createResultTable(org.apache.jena.query.ResultSet rs)
     
    static org.aksw.jenax.arq.util.binding.ResultTable
    execSelect(org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSource dataSource, org.apache.jena.query.Query query)
     
    static void
    main(String[] args)
     
    io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.arq.util.binding.ResultTable>
    observeSelect(org.apache.jena.query.Query query)
    Returns a flowable for the result table of the given query.
    void
    refreshAll(boolean cancelRunning)
     

    Methods inherited from class org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSourceWrapperBase

    getDelegate

    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.dataaccess.sparql.datasource.RDFDataSource

    asLinkSource, asQef, getDataset, newQuery, newUpdate, query, query, update, update, update

    Methods inherited from interface org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSourceWrapper

    getConnection

  • Field Details

    • mapRx

      protected ObservableSourceImpl<org.apache.jena.query.Query,org.aksw.jenax.arq.util.binding.ResultTable> mapRx

  • Constructor Details

    • RdfDataSourceObservableImpl

      public RdfDataSourceObservableImpl(org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSource delegate)

  • Method Details

    • observeSelect

      public io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.arq.util.binding.ResultTable> observeSelect(org.apache.jena.query.Query query)
      Description copied from interface: RdfDataSourceObservable
      Returns a flowable for the result table of the given query. The flowable is idle until subscription. Upon subscription either the query is executed or if there is a cached value from a prior execution then this one will be re-emitted. To re-execute a query it needs to be refreshed e.g. via
      invalid reference 
      #refreshAll()
      . If no change is detected after a refresh then no additional event should be sent.
      Specified by:
      observeSelect in interface RdfDataSourceObservable

    • execSelect

      public static org.aksw.jenax.arq.util.binding.ResultTable execSelect(org.aksw.jenax.dataaccess.sparql.datasource.RDFDataSource dataSource, org.apache.jena.query.Query query)

    • createResultTable

      public static org.aksw.jenax.arq.util.binding.ResultTable createResultTable(org.apache.jena.query.ResultSet rs)

    • refreshAll

      public void refreshAll(boolean cancelRunning)
      Specified by:
      refreshAll in interface RdfDataSourceObservable

    • main

      public static void main(String[] args)