Package org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.accumulators

Class EntitySummaryAccumulator

java.lang.Object

org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.accumulators.ExceptionAccumulatorBase

org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.accumulators.MaintenanceAccumulator

org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.accumulators.ClassificationAccumulator

org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.accumulators.EntitySummaryAccumulator

public class EntitySummaryAccumulator
extends ClassificationAccumulator

ClassificationAccumulator accumulates and validates an entity received from a collection of open metadata repositories. It removes duplicates from the list by choosing the latest entity details object. This class may be called simultaneously from different threads, so it must be thread-safe.

Constructor Summary

Constructors

Constructor	Description
EntitySummaryAccumulator(AuditLog auditLog)	Construct an entity accumulator.

Method Summary

Modifier and Type	Method	Description
void	addEntity(EntitySummary incomingEntity, String metadataCollectionId)	Provide an entity received from an open metadata repository.
EntitySummary	getResult()	Extract the resulting entity and accumulated classifications.
List<String>	getResultsForAugmentation()	Return the list of GUIDs for the entities returned from the query.

Methods inherited from class org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.accumulators.ClassificationAccumulator

addContributingMetadataCollection, getContributingMetadataCollections, isInPhaseOne, saveClassifications

Methods inherited from class org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.accumulators.MaintenanceAccumulator

captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureException, captureGenericException

Methods inherited from class org.odpi.openmetadata.repositoryservices.enterprise.repositoryconnector.accumulators.ExceptionAccumulatorBase

throwCapturedClassificationErrorException, throwCapturedEntityNotDeletedException, throwCapturedEntityNotKnownException, throwCapturedEntityProxyOnlyException, throwCapturedFunctionNotSupportedException, throwCapturedGenericException, throwCapturedInvalidParameterException, throwCapturedInvalidTypeDefException, throwCapturedPagingErrorException, throwCapturedPropertyErrorException, throwCapturedRelationshipNotDeletedException, throwCapturedRelationshipNotKnownException, throwCapturedRepositoryErrorException, throwCapturedStatusNotSupportedException, throwCapturedTypeDefConflictException, throwCapturedTypeDefNotKnownException, throwCapturedTypeDefNotSupportedException, throwCapturedTypeErrorException, throwCapturedUserNotAuthorizedException

Methods inherited from class java.lang.Object

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

Constructor Details

EntitySummaryAccumulator

public EntitySummaryAccumulator(AuditLog auditLog)

Construct an entity accumulator. Its base class manages the common variables needed to control the execution of requests across all members of the cohort(s).

Parameters:

auditLog - audit log provides destination for log messages

Method Details

addEntity

public void addEntity(EntitySummary incomingEntity,
 String metadataCollectionId)

Provide an entity received from an open metadata repository.

Parameters:

incomingEntity - entity returned from an open metadata repository

metadataCollectionId - unique identifier for the collection of metadata stored in this repository This is used for error reporting.

getResultsForAugmentation

public List<String> getResultsForAugmentation()

Return the list of GUIDs for the entities returned from the query.

Specified by:

getResultsForAugmentation in class ClassificationAccumulator

Returns:

null or list of GUIDs

getResult

public EntitySummary getResult()

Extract the resulting entity and accumulated classifications. It should be called once all the executors have completed processing their request(s).

Returns:

list of entities