Package com.orientechnologies.orient.core.sql.executor.stream

Interface OExecutionStream

All Known Implementing Classes:

OCostMeasureExecutionStream, OEdgeTraverserExcutionStream, OEmptyExecutionStream, OFilterExecutionStream, OFlatMapExecutionStream, OInterruptExecutionStream, OIteratorExecutionStream, OLimitedExecutionStream, OLoaderExecutionStream, OMapExecutionStream, OMultipleExecutionStream, OnCloseExecutionStream, OProduceExecutionStream, OResultCollectionExecutionStream, OResultIteratorExecutionStream, OSingletonExecutionStream, OTerminationExecutionStream, OTimeoutExecutionStream

public interface OExecutionStream

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	OExecutionStream.OnClose

Method Summary

Modifier and Type	Method	Description
void	close(OCommandContext ctx)
static OExecutionStream	collectAll(OExecutionStream from, OCommandContext ctx)
static void	consume(OExecutionStream toConsume, OCommandContext ctx)
static OExecutionStream	empty()
default OExecutionStream	filter(OFilterResult filter)
default OExecutionStream	flatMap(OFlatMapResult map)
boolean	hasNext(OCommandContext ctx)
default OExecutionStream	interruptable()
default boolean	isFullInMemory(OCommandContext ctx)	Check if the current stream has all the data in memory, without much computation need to get the final result.
boolean	isTermination(OCommandContext ctx)	Flag used to terminate scripts early in the execution, used by the return statement via the terminate execution stream The only implementation that tour true is OTerminationExecutionStream created with terminate() the other implementation return false if they provide content themselves, or delegate the method if are wrapper (independently of the modifications) of another stream.
static OExecutionStream	iterator(Iterator<Object> iterator)
default OExecutionStream	limit(long limit)
static OExecutionStream	loadIterator(Iterator<OIdentifiable> iterator)
default OExecutionStream	map(OMapResult mapper)
static OExecutionStream	multipleStreams(OExecutionStreamProducer producer)
OResult	next(OCommandContext ctx)
default OExecutionStream	onClose(OExecutionStream.OnClose onClose)
static OExecutionStream	produce(OProduceResult producer)
default OCostMeasureExecutionStream	profile(OExecutionStepInternal step)
static OExecutionStream	resultCollection(Collection<OResult> iterator)
static OExecutionStream	resultIterator(Iterator<OResult> iterator)
static OExecutionStream	singleton(OResult result)
default Stream<OResult>	stream(OCommandContext ctx)
static <T> OExecutionStream	streamsFromIterator(Iterator<T> producer, OExecutionStreamProducerValueMap<T> map)
default OExecutionStream	terminate()
default OExecutionStream	timeout(long timeInMills, OTimeoutExecutionStream.TimedOut timedout)

Method Details

hasNext

boolean hasNext(OCommandContext ctx)

next

OResult next(OCommandContext ctx)

close

void close(OCommandContext ctx)

isTermination

boolean isTermination(OCommandContext ctx)

Flag used to terminate scripts early in the execution, used by the return statement via the terminate execution stream The only implementation that tour true is OTerminationExecutionStream created with terminate() the other implementation return false if they provide content themselves, or delegate the method if are wrapper (independently of the modifications) of another stream.

Parameters:

ctx - context of the query

Returns:

true if this is last execution stream, false if there are more

produce

static OExecutionStream produce(OProduceResult producer)

multipleStreams

static OExecutionStream multipleStreams(OExecutionStreamProducer producer)

streamsFromIterator

static <T> OExecutionStream streamsFromIterator(Iterator<T> producer,
 OExecutionStreamProducerValueMap<T> map)

map

default OExecutionStream map(OMapResult mapper)

filter

default OExecutionStream filter(OFilterResult filter)

flatMap

default OExecutionStream flatMap(OFlatMapResult map)

interruptable

default OExecutionStream interruptable()

timeout

default OExecutionStream timeout(long timeInMills,
 OTimeoutExecutionStream.TimedOut timedout)

limit

default OExecutionStream limit(long limit)

terminate

default OExecutionStream terminate()

iterator

static OExecutionStream iterator(Iterator<Object> iterator)

resultIterator

static OExecutionStream resultIterator(Iterator<OResult> iterator)

resultCollection

static OExecutionStream resultCollection(Collection<OResult> iterator)

profile

default OCostMeasureExecutionStream profile(OExecutionStepInternal step)

loadIterator

static OExecutionStream loadIterator(Iterator<OIdentifiable> iterator)

empty

static OExecutionStream empty()

singleton

static OExecutionStream singleton(OResult result)

isFullInMemory

default boolean isFullInMemory(OCommandContext ctx)

Check if the current stream has all the data in memory, without much computation need to get the final result. Only implementation with all the content inside can return true, wrappers with no computation can just delegate, if the wrapper do a logic computation should return false.

Parameters:

ctx - the current query context

Returns:

true if the data is all in memory

onClose

default OExecutionStream onClose(OExecutionStream.OnClose onClose)

collectAll

static OExecutionStream collectAll(OExecutionStream from,
 OCommandContext ctx)

consume

static void consume(OExecutionStream toConsume,
 OCommandContext ctx)

stream

default Stream<OResult> stream(OCommandContext ctx)