Package one.microstream.util.cql

Interface CqlTransfer<I,R extends XIterable<I>>

All Superinterfaces:

CqlIteration<I,I,R>, CqlQuery<I,I,R>, XIterable<I>

All Known Subinterfaces:

CqlSelection<I>

All Known Implementing Classes:

CqlSelection.Default, CqlTransfer.Default

public interface CqlTransfer<I,R extends XIterable<I>>
extends CqlIteration<I,I,R>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	CqlTransfer.Default<I,R extends XIterable<I>>

Nested classes/interfaces inherited from interface one.microstream.util.cql.CqlQuery

CqlQuery.Abstract<I,O,R>

Nested classes/interfaces inherited from interface one.microstream.collections.types.XIterable

XIterable.Executor<E>

Method Summary

Modifier and Type	Method	Description
default R	execute()
default <P extends Consumer<I>> P	executeInto(XIterable<? extends I> source, P target)
default R	executeOn(XIterable<? extends I> source)
default CqlTransfer<I,R>	from(XIterable<? extends I> source)
default <P extends Consumer<? super I>> P	iterate(P procedure)	Executes the given procedure for each element of the XIterable until all elements have been processed or the action throws an exception.
default CqlTransfer<I,R>	limit(Number count)
static <I> CqlTransfer<I,XSequence<I>>	New()
static <I> CqlTransfer<I,XSequence<I>>	New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Comparator<? super I> order)
static <I, R extends XIterable<I>> CqlTransfer<I,R>	New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Comparator<? super I> order, CqlResultor<I,R> resultor)
static <I, T extends Consumer<I> & XIterable<I>> CqlTransfer<I,T>	New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Comparator<? super I> order, T target)
default CqlTransfer<I,R>	orderBy(Comparator<? super I> order)
default CqlTransfer<I,R>	select(Predicate<? super I> selector)
default CqlTransfer<I,R>	skip(Number count)

Methods inherited from interface one.microstream.util.cql.CqlQuery

executeInto, executeInto, executeInto, executeSelection, getLimit, getOrder, getProjector, getResultor, getSelector, getSkip, getSource, into, into, into, over, project, targeting

Method Details

skip

default CqlTransfer<I,R> skip(Number count)

Specified by:

skip in interface CqlIteration<I,I,R extends XIterable<I>>

Specified by:

skip in interface CqlQuery<I,I,R extends XIterable<I>>

limit

default CqlTransfer<I,R> limit(Number count)

Specified by:

limit in interface CqlIteration<I,I,R extends XIterable<I>>

Specified by:

limit in interface CqlQuery<I,I,R extends XIterable<I>>

from

default CqlTransfer<I,R> from(XIterable<? extends I> source)

Specified by:

from in interface CqlIteration<I,I,R extends XIterable<I>>

Specified by:

from in interface CqlQuery<I,I,R extends XIterable<I>>

orderBy

default CqlTransfer<I,R> orderBy(Comparator<? super I> order)

Specified by:

orderBy in interface CqlIteration<I,I,R extends XIterable<I>>

Specified by:

orderBy in interface CqlQuery<I,I,R extends XIterable<I>>

select

default CqlTransfer<I,R> select(Predicate<? super I> selector)

Specified by:

select in interface CqlIteration<I,I,R extends XIterable<I>>

Specified by:

select in interface CqlQuery<I,I,R extends XIterable<I>>

execute

default R execute()

Specified by:

execute in interface CqlQuery<I,I,R extends XIterable<I>>

iterate

default <P extends Consumer<? super I>> P iterate(P procedure)

Description copied from interface: XIterable

Executes the given procedure for each element of the XIterable until all elements have been processed or the action throws an exception. Unless otherwise specified by the implementing class, procedures are performed in the order of iteration (if an iteration order is specified). Exceptions thrown by the procedure are relayed to the caller.
Should be identical to Iterable.forEach(Consumer).

Specified by:

iterate in interface CqlIteration<I,I,R extends XIterable<I>>

Specified by:

iterate in interface XIterable<I>

Type Parameters:

P - type of procedure

Parameters:

procedure - The procedure to be performed for each element

Returns:

Given procedure

executeOn

default R executeOn(XIterable<? extends I> source)

Specified by:

executeOn in interface CqlQuery<I,I,R extends XIterable<I>>

executeInto

default <P extends Consumer<I>> P executeInto(XIterable<? extends I> source, P target)

Specified by:

executeInto in interface CqlQuery<I,I,R extends XIterable<I>>

New

static <I> CqlTransfer<I,XSequence<I>> New()

New

static <I> CqlTransfer<I,XSequence<I>> New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Comparator<? super I> order)

New

static <I, T extends Consumer<I> & XIterable<I>> CqlTransfer<I,T> New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Comparator<? super I> order, T target)

New

static <I, R extends XIterable<I>> CqlTransfer<I,R> New(XIterable<? extends I> source, Long skip, Long limit, Predicate<? super I> selector, Comparator<? super I> order, CqlResultor<I,R> resultor)