org.infinispan.distexec.mapreduce

Class MapReduceManagerImpl.DeltaAwareList<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractList<E>

java.util.AbstractSequentialList<E>

java.util.LinkedList<E>

org.infinispan.distexec.mapreduce.MapReduceManagerImpl.DeltaAwareList<E>

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.lang.Iterable<E>, java.util.Collection<E>, java.util.Deque<E>, java.util.List<E>, java.util.Queue<E>, org.infinispan.atomic.Delta, org.infinispan.atomic.DeltaAware

Enclosing class:

MapReduceManagerImpl

private static final class MapReduceManagerImpl.DeltaAwareList<E>
extends java.util.LinkedList<E>
implements org.infinispan.atomic.DeltaAware, org.infinispan.atomic.Delta

Field Summary

Fields

Modifier and Type	Field and Description
private static long	serialVersionUID The serialVersionUID

Fields inherited from class java.util.AbstractList

modCount

Constructor Summary

Constructors

Constructor and Description
MapReduceManagerImpl.DeltaAwareList(java.util.Collection<? extends E> c)

Method Summary

Methods

Modifier and Type	Method and Description
void	commit() Indicate that all deltas collected to date has been extracted (via a call to DeltaAware.delta()) and can be discarded.
org.infinispan.atomic.Delta	delta() Extracts changes made to implementations, in an efficient format that can easily and cheaply be serialized and deserialized.
org.infinispan.atomic.DeltaAware	merge(org.infinispan.atomic.DeltaAware d) Merge the current Delta instance with a given DeltaAware instance, and return a coherent and complete DeltaAware instance.

Methods inherited from class java.util.LinkedList

add, add, addAll, addAll, addFirst, addLast, clear, clone, contains, descendingIterator, element, get, getFirst, getLast, indexOf, lastIndexOf, listIterator, offer, offerFirst, offerLast, peek, peekFirst, peekLast, poll, pollFirst, pollLast, pop, push, remove, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, set, size, toArray, toArray

Methods inherited from class java.util.AbstractSequentialList

iterator

Methods inherited from class java.util.AbstractList

equals, hashCode, listIterator, removeRange, subList

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.List

containsAll, equals, hashCode, isEmpty, iterator, listIterator, removeAll, retainAll, subList

Methods inherited from interface java.util.Deque

iterator

Field Detail

serialVersionUID

private static final long serialVersionUID

The serialVersionUID

See Also:

Constant Field Values

Constructor Detail

MapReduceManagerImpl.DeltaAwareList

public MapReduceManagerImpl.DeltaAwareList(java.util.Collection<? extends E> c)

Method Detail

delta

public org.infinispan.atomic.Delta delta()

Description copied from interface: org.infinispan.atomic.DeltaAware

Extracts changes made to implementations, in an efficient format that can easily and cheaply be serialized and deserialized. This method will only be called once for each changeset as it is assumed that any implementation's internal changelog is wiped and reset after generating and submitting the delta to the caller.

Specified by:

delta in interface org.infinispan.atomic.DeltaAware

Returns:

an instance of Delta

commit

public void commit()

Description copied from interface: org.infinispan.atomic.DeltaAware

Indicate that all deltas collected to date has been extracted (via a call to DeltaAware.delta()) and can be discarded. Often used as an optimization if the delta isn't really needed, but the cleaning and resetting of internal state is desirable.

Specified by:

commit in interface org.infinispan.atomic.DeltaAware

merge

public org.infinispan.atomic.DeltaAware merge(org.infinispan.atomic.DeltaAware d)

Description copied from interface: org.infinispan.atomic.Delta

Merge the current Delta instance with a given DeltaAware instance, and return a coherent and complete DeltaAware instance. Implementations should be able to deal with null values passed in, or values of a different type from the expected DeltaAware instance. Usually the approach would be to ignore what is passed in, create a new instance of the DeltaAware implementation that the current Delta implementation is written for, apply changes and pass it back.

Specified by:

merge in interface org.infinispan.atomic.Delta

Parameters:

d - instance to merge with, or null if no merging is needed

Returns:

a fully coherent and usable instance of DeltaAware which may or may not be the same instance passed in