Class TaskCollectors.LastOfCollector<T>
- java.lang.Object
-
- com.oracle.coherence.concurrent.executor.AbstractCollector<T,T>
-
- com.oracle.coherence.concurrent.executor.TaskCollectors.LastOfCollector<T>
-
- Type Parameters:
T
- the type of result
- All Implemented Interfaces:
Task.Collector<T,List<T>,T>
,ExternalizableLite
,PortableObject
,Serializable
- Enclosing class:
- TaskCollectors
public static class TaskCollectors.LastOfCollector<T> extends com.oracle.coherence.concurrent.executor.AbstractCollector<T,T>
ATask.Collector
that collects and returns the last contributed result.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description LastOfCollector()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Function<List<T>,T>
finisher()
Perform the final transformation from the intermediate accumulation type A to the final result type R.void
readExternal(PofReader in)
Restore the contents of a user type instance by reading its state using the specified PofReader object.void
readExternal(DataInput in)
Restore the contents of this object by loading the object's state from the passed DataInput object.void
writeExternal(PofWriter out)
Save the contents of a POF user type instance by writing its state using the specified PofWriter object.void
writeExternal(DataOutput out)
Save the contents of this object by storing the object's state into the passed DataOutput object.
-
-
-
Method Detail
-
finisher
public Function<List<T>,T> finisher()
Description copied from interface:Task.Collector
Perform the final transformation from the intermediate accumulation type A to the final result type R.- Returns:
- a function which transforms the intermediate result to the final result
-
readExternal
public void readExternal(DataInput in) throws IOException
Description copied from interface:ExternalizableLite
Restore the contents of this object by loading the object's state from the passed DataInput object.- Parameters:
in
- the DataInput stream to read data from in order to restore the state of this object- Throws:
IOException
- if an I/O exception occursNotActiveException
- if the object is not in its initial state, and therefore cannot be deserialized into
-
writeExternal
public void writeExternal(DataOutput out) throws IOException
Description copied from interface:ExternalizableLite
Save the contents of this object by storing the object's state into the passed DataOutput object.- Parameters:
out
- the DataOutput stream to write the state of this object to- Throws:
IOException
- if an I/O exception occurs
-
readExternal
public void readExternal(PofReader in) throws IOException
Description copied from interface:PortableObject
Restore the contents of a user type instance by reading its state using the specified PofReader object.- Parameters:
in
- the PofReader from which to read the object's state- Throws:
IOException
- if an I/O error occurs
-
writeExternal
public void writeExternal(PofWriter out) throws IOException
Description copied from interface:PortableObject
Save the contents of a POF user type instance by writing its state using the specified PofWriter object.- Parameters:
out
- the PofWriter to which to write the object's state- Throws:
IOException
- if an I/O error occurs
-
-