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 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).
      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.
      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
      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).
      list of entities