org.infinispan.stream.impl.termop

Class SingleRunOperation<E,R,S extends BaseStream<R,S>>

java.lang.Object

org.infinispan.stream.impl.termop.BaseTerminalOperation

org.infinispan.stream.impl.termop.SingleRunOperation<E,R,S>

Type Parameters:

E - type of the output of the function

R - type of the stream entries

S - type of the stream itself

All Implemented Interfaces:

SegmentAwareOperation, TerminalOperation<E>

public class SingleRunOperation<E,R,S extends BaseStream<R,S>>
extends BaseTerminalOperation
implements TerminalOperation<E>

Runs the provided function once only and returns the result. This is useful for operations that can be performed and its result is still valid even when a segment is lost.

Field Summary

Fields inherited from class org.infinispan.stream.impl.termop.BaseTerminalOperation

intermediateOperations, supplier

Constructor Summary

Constructors

Constructor and Description
SingleRunOperation(Iterable<IntermediateOperation> intermediateOperations, Supplier<? extends BaseStream<?,?>> supplier, Function<S,? extends E> function)

Method Summary

Modifier and Type	Method and Description
Function<S,? extends E>	getFunction()
boolean	lostSegment(boolean stopIfLost) This method will be invoked when the operation is known to be performing on a given set of segments and this node no longer owns 1 or many of them.
E	performOperation() Actually runs the terminal operation returning the result from the operation

Methods inherited from class org.infinispan.stream.impl.termop.BaseTerminalOperation

getIntermediateOperations, handleInjection, setSupplier

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.stream.impl.TerminalOperation

handleInjection, setSupplier

Constructor Detail

SingleRunOperation

public SingleRunOperation(Iterable<IntermediateOperation> intermediateOperations,
                          Supplier<? extends BaseStream<?,?>> supplier,
                          Function<S,? extends E> function)

Method Detail

lostSegment

public boolean lostSegment(boolean stopIfLost)

Description copied from interface: SegmentAwareOperation

This method will be invoked when the operation is known to be performing on a given set of segments and this node no longer owns 1 or many of them. Returns whether the lost segment affected the results or not. If stopIfLost is true then doneWithOperation will not be invoked as it would normally.

Specified by:

lostSegment in interface SegmentAwareOperation

Parameters:

stopIfLost - argument to tell the operation that if this segment affects that it should not perform any more operations if possible as all segments have been lost.

Returns:

whether or not this operation was affected by the loss of segments

performOperation

public E performOperation()

Description copied from interface: TerminalOperation

Actually runs the terminal operation returning the result from the operation

Specified by:

performOperation in interface TerminalOperation<E>

Returns:

the value retrieved for the operation

getFunction

public Function<S,? extends E> getFunction()