fr.gouv.vitam.metadata.core.graph

Class GraphComputeServiceImpl

java.lang.Object

fr.gouv.vitam.metadata.core.graph.GraphComputeServiceImpl

All Implemented Interfaces:

VitamCache<String,org.bson.Document>, VitamAutoCloseable, GraphComputeService, AutoCloseable

public class GraphComputeServiceImpl
extends Object
implements GraphComputeService

This class compute graph for unit and object group Should only be called from GraphFactory

Field Summary

Fields inherited from interface fr.gouv.vitam.metadata.core.graph.api.GraphComputeService

$_SET, concurrencyLevel, executor, START_DEPTH

Method Summary

Modifier and Type	Method and Description
void	bulkElasticsearch(MetadataCollections metaDaCollection, List<org.bson.Document> collection) Bulk save in elasticsearch
void	bulkElasticsearch(MetadataCollections metaDaCollection, Set<String> collection) Bulk save in elasticsearch
void	bulkUpdateMongo(MetadataCollections metaDaCollection, List<com.mongodb.client.model.WriteModel<org.bson.Document>> collection) Bulk write in mongodb
void	close()
GraphComputeResponse	computeGraph(com.fasterxml.jackson.databind.JsonNode queryDSL) If workflow of compute graph in progress, do not execute this method Should be exposed in the API
GraphComputeResponse	computeGraph(MetadataCollections metadataCollections, Set<String> documentsId, boolean computeObjectGroupGraph) Compute graph for unit/got from all parents
com.google.common.cache.LoadingCache<String,org.bson.Document>	getCache()
static GraphComputeService	getInstance()
static GraphComputeService	initialize(VitamRepositoryProvider vitamRepositoryProvider, MetaData metaData)
static GraphComputeService	initialize(VitamRepositoryProvider vitamRepositoryProvider, MetaData metaData, VitamCache<String,org.bson.Document> cache, List<Integer> tenants)
boolean	isInProgress()

Methods inherited from class java.lang.Object

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

Methods inherited from interface fr.gouv.vitam.metadata.core.graph.api.GraphComputeService

computeGraph, computeObjectGroupGraph, computeObjectGroupGraph, computeUnitGraph, computeUnitGraphUsingDirectParents, preLoadCache

Method Detail

initialize

public static GraphComputeService initialize(VitamRepositoryProvider vitamRepositoryProvider,
                                             MetaData metaData,
                                             VitamCache<String,org.bson.Document> cache,
                                             List<Integer> tenants)

Parameters:

vitamRepositoryProvider -

metaData -

tenants -

Returns:

GraphComputeServiceImpl

initialize

public static GraphComputeService initialize(VitamRepositoryProvider vitamRepositoryProvider,
                                             MetaData metaData)

Parameters:

vitamRepositoryProvider -

metaData -

Returns:

GraphComputeServiceImpl

getInstance

public static GraphComputeService getInstance()

computeGraph

public GraphComputeResponse computeGraph(com.fasterxml.jackson.databind.JsonNode queryDSL)
                                  throws MetaDataException

Description copied from interface: GraphComputeService

If workflow of compute graph in progress, do not execute this method Should be exposed in the API

Specified by:

computeGraph in interface GraphComputeService

Returns:

the map of collection:number of treated documents

Throws:

MetaDataException

computeGraph

public GraphComputeResponse computeGraph(MetadataCollections metadataCollections,
                                         Set<String> documentsId,
                                         boolean computeObjectGroupGraph)

Description copied from interface: GraphComputeService

Compute graph for unit/got from all parents

Specified by:

computeGraph in interface GraphComputeService

Parameters:

metadataCollections - the collection concerned by the build of the graph

documentsId - the collection of units subject of computing graph

computeObjectGroupGraph - true mean compute graph

Returns:

The collection of object group treated or to be treated bu an other process. This collection contains got's id of concerning units. Empty collection is returned if computeGraph of object group.

bulkUpdateMongo

public void bulkUpdateMongo(MetadataCollections metaDaCollection,
                            List<com.mongodb.client.model.WriteModel<org.bson.Document>> collection)
                     throws DatabaseException

Description copied from interface: GraphComputeService

Bulk write in mongodb

Specified by:

bulkUpdateMongo in interface GraphComputeService

Throws:

DatabaseException

bulkElasticsearch

public void bulkElasticsearch(MetadataCollections metaDaCollection,
                              Set<String> collection)
                       throws DatabaseException

Description copied from interface: GraphComputeService

Bulk save in elasticsearch

Specified by:

bulkElasticsearch in interface GraphComputeService

collection - of id of documents

Throws:

DatabaseException

bulkElasticsearch

public void bulkElasticsearch(MetadataCollections metaDaCollection,
                              List<org.bson.Document> collection)
                       throws DatabaseException

Description copied from interface: GraphComputeService

Bulk save in elasticsearch

Specified by:

bulkElasticsearch in interface GraphComputeService

collection - of documents

Throws:

DatabaseException

close

public void close()

Specified by:

close in interface VitamAutoCloseable

Specified by:

close in interface AutoCloseable

isInProgress

public boolean isInProgress()

Specified by:

isInProgress in interface GraphComputeService

getCache

public com.google.common.cache.LoadingCache<String,org.bson.Document> getCache()

Specified by:

getCache in interface VitamCache<String,org.bson.Document>