org.atlasapi.equivalence

Class AbstractEquivalenceGraphStore

java.lang.Object

org.atlasapi.equivalence.AbstractEquivalenceGraphStore

All Implemented Interfaces:

EquivalenceGraphStore

public abstract class AbstractEquivalenceGraphStore
extends Object
implements EquivalenceGraphStore

Constructor Summary

Constructors

Constructor and Description
AbstractEquivalenceGraphStore(MessageSender messageSender)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	doStore(com.google.common.collect.ImmutableSet<EquivalenceGraph> graphs)
protected abstract GroupLock<Id>	lock()
protected abstract org.slf4j.Logger	log()
com.google.common.base.Optional<com.google.common.collect.ImmutableSet<EquivalenceGraph>>	updateEquivalences(ResourceRef subject, Set<ResourceRef> assertedAdjacents, Set<org.atlasapi.media.entity.Publisher> sources) Record a subject as equivalent to a set of other resources.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.atlasapi.equivalence.EquivalenceGraphStore

resolveIds

Constructor Detail

AbstractEquivalenceGraphStore

public AbstractEquivalenceGraphStore(MessageSender messageSender)

Method Detail

updateEquivalences

public final com.google.common.base.Optional<com.google.common.collect.ImmutableSet<EquivalenceGraph>> updateEquivalences(ResourceRef subject,
                                                                                                           Set<ResourceRef> assertedAdjacents,
                                                                                                           Set<org.atlasapi.media.entity.Publisher> sources)
                                                                                                                   throws WriteException

Description copied from interface: EquivalenceGraphStore

Record a subject as equivalent to a set of other resources.

An update overwrites all equivalences for resources which are sourced from elements of the supplied sources set.

The return value, if an update occurs, is the set of new EquivalenceGraphs formed as a result of the update.

Updates are idempotent - if the subject is asserted equivalent to the same resources and set of sources then no update occurs and Optional.absent() is returned.

An update may not occur if the update would create a equivalence set that is too large.

Specified by:

updateEquivalences in interface EquivalenceGraphStore

Parameters:

subject - - reference to the resource which is to be recorded equivalent to the asserted adjacent resources.

assertedAdjacents - - references to resources which are equivalent to the subject.

sources - - the Publishers for which this update should be applied.

Returns:

- the EquivalenceGraphs formed by this update, or Optional.absent() if no update occurs.

Throws:

WriteException - - if there is an exception recording the update of equivalences.

lock

protected abstract GroupLock<Id> lock()

doStore

protected abstract void doStore(com.google.common.collect.ImmutableSet<EquivalenceGraph> graphs)

log

protected abstract org.slf4j.Logger log()