Package org.aksw.jenax.dataaccess.rx

Class ListServiceEntityQuery.ListPaginatorEntityQuery

java.lang.Object
org.aksw.jenax.dataaccess.rx.ListServiceEntityQuery.ListPaginatorEntityQuery
All Implemented Interfaces:
Function<com.google.common.collect.Range<Long>,io.reactivex.rxjava3.core.Flowable<org.apache.jena.rdf.model.RDFNode>>, org.aksw.commons.rx.lookup.ListPaginator<org.apache.jena.rdf.model.RDFNode>, org.aksw.commons.rx.range.RangedSupplier<Long,org.apache.jena.rdf.model.RDFNode>, org.aksw.commons.util.delegate.Unwrappable
Enclosing class:
ListServiceEntityQuery
public class ListServiceEntityQuery.ListPaginatorEntityQuery extends Object implements org.aksw.commons.rx.lookup.ListPaginator<org.apache.jena.rdf.model.RDFNode>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected org.aksw.jena_sparql_api.rx.entity.model.EntityBaseQuery
    baseQuery
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ListPaginatorEntityQuery(org.aksw.jena_sparql_api.rx.entity.model.EntityBaseQuery baseQuery)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.reactivex.rxjava3.core.Flowable<org.apache.jena.rdf.model.RDFNode>
    apply(com.google.common.collect.Range<Long> t)
     
    io.reactivex.rxjava3.core.Single<com.google.common.collect.Range<Long>>
    fetchCount(Long itemLimit, Long rowLimit)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface java.util.function.Function

    andThen, compose

    Methods inherited from interface org.aksw.commons.rx.lookup.ListPaginator

    batch, fetchList, map

    Methods inherited from interface org.aksw.commons.util.delegate.Unwrappable

    unwrap

  • Field Details

    • baseQuery

      protected org.aksw.jena_sparql_api.rx.entity.model.EntityBaseQuery baseQuery

  • Constructor Details

    • ListPaginatorEntityQuery

      public ListPaginatorEntityQuery(org.aksw.jena_sparql_api.rx.entity.model.EntityBaseQuery baseQuery)

  • Method Details

    • apply

      public io.reactivex.rxjava3.core.Flowable<org.apache.jena.rdf.model.RDFNode> apply(com.google.common.collect.Range<Long> t)
      Specified by:
      apply in interface Function<com.google.common.collect.Range<Long>,io.reactivex.rxjava3.core.Flowable<org.apache.jena.rdf.model.RDFNode>>

    • fetchCount

      public io.reactivex.rxjava3.core.Single<com.google.common.collect.Range<Long>> fetchCount(Long itemLimit, Long rowLimit)
      Specified by:
      fetchCount in interface org.aksw.commons.rx.lookup.ListPaginator<org.apache.jena.rdf.model.RDFNode>