Package com._1c.g5.v8.internal.derived

Class BmDerivedDataInfoRepository

java.lang.Object

com._1c.g5.v8.internal.derived.BmDerivedDataInfoRepository

All Implemented Interfaces:

IDerivedDataInfoRepository

public class BmDerivedDataInfoRepository
extends Object
implements IDerivedDataInfoRepository

Default implementation of IDerivedDataInfoRepository that uses persistent index to store derived data info.

Field Summary

Fields inherited from interface com._1c.g5.v8.internal.derived.IDerivedDataInfoRepository

SERVICE_NAME

Constructor Summary

Constructors

Constructor	Description
BmDerivedDataInfoRepository(Path rootPath, int storeSegments, Function<Long,Integer> longSegmentHasher, Function<String,Integer> stringSegmentHasher)	Constructs a new instance.

Method Summary

Modifier and Type	Method	Description
void	confirmSegmentComputation(Object objectId, String segmentId)	Confirms computation of DD segment for the given object.
void	deactivateContexts(String segmentId, IObjectContextFactory objectContextFactory)	Perform mass deactivation of contexts
Iterable<DerivedDataInfo>	getAllInfos()	Gets all registered info records from the repository
DerivedDataInfo	getInfo(Object objectId)	Gets the registered DerivedDataInfo using the BM object identifier.
DerivedDataInfo	getOrCreateInfo(Object objectId)	Gets the registered DerivedDataInfo using the BM object identifier.
IObjectDerivedDataContext	loadExistingContext(Object objectId, String segmentId, DerivedDataInfo.SegmentContextData segmentData, IObjectContextFactory objectContextFactory)	Loads an existing context with a data being stored in the repository
void	markAsBroken(Object objectId)	Marks the corresponding DerivedDataInfo as broken.
void	remove(DerivedDataInfo info)	Removes descriptor from the store.
void	save(DerivedDataInfo info)	Saves the descriptor of DS for a specific object.
void	start(boolean delete, IBmModel bmModel)	Starts the repository as the part of DD startup cycle.
void	stop(boolean delete)	Stops the repository as the part of DD shutdown cycle.
void	updateDerivedDataInfo(IObjectDerivedDataContext context)	Updates derived data info according to provided context
void	updateDerivedDataInfo(IObjectDerivedDataContext context, long version)	Updates derived data info according to provided context

Methods inherited from class java.lang.Object

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

Constructor Details

BmDerivedDataInfoRepository

public BmDerivedDataInfoRepository(Path rootPath,
 int storeSegments,
 Function<Long,Integer> longSegmentHasher,
 Function<String,Integer> stringSegmentHasher)

Constructs a new instance.

Parameters:

rootPath - The root storage path of the repository. May not be null

Method Details

confirmSegmentComputation

public void confirmSegmentComputation(Object objectId,
 String segmentId)

Description copied from interface: IDerivedDataInfoRepository

Confirms computation of DD segment for the given object.

Specified by:

confirmSegmentComputation in interface IDerivedDataInfoRepository

Parameters:

objectId - The identifier of the corresponding BM object.

segmentId - DD segment. Cannot be null.

getAllInfos

public Iterable<DerivedDataInfo> getAllInfos()

Description copied from interface: IDerivedDataInfoRepository

Gets all registered info records from the repository

Specified by:

getAllInfos in interface IDerivedDataInfoRepository

Returns:

An iterable with all remaining records. May not be null

getInfo

public DerivedDataInfo getInfo(Object objectId)

Description copied from interface: IDerivedDataInfoRepository

Gets the registered DerivedDataInfo using the BM object identifier.

Specified by:

getInfo in interface IDerivedDataInfoRepository

Parameters:

objectId - The identifier of the corresponding BM object.

Returns:

The instance of the DerivedDataInfo holding the data for the given identifier. null in case if there is no info registered for the given object identifier.

getOrCreateInfo

public DerivedDataInfo getOrCreateInfo(Object objectId)

Description copied from interface: IDerivedDataInfoRepository

Gets the registered DerivedDataInfo using the BM object identifier. Creates a new instance in case if there is no info registered for the given object identifier.

Specified by:

getOrCreateInfo in interface IDerivedDataInfoRepository

Parameters:

objectId - The identifier of the corresponding BM object.

Returns:

The instance of the DerivedDataInfo holding the data for the given identifier, never null.

markAsBroken

public void markAsBroken(Object objectId)

Description copied from interface: IDerivedDataInfoRepository

Marks the corresponding DerivedDataInfo as broken. Works only in case if the info is registered in the repository. Does nothing in case if no info is registered for the given object identifier.

Specified by:

markAsBroken in interface IDerivedDataInfoRepository

Parameters:

objectId - The identifier of the corresponding BM object.

remove

public void remove(DerivedDataInfo info)

Description copied from interface: IDerivedDataInfoRepository

Removes descriptor from the store.

Specified by:

remove in interface IDerivedDataInfoRepository

Parameters:

info - The info to remove.

save

public void save(DerivedDataInfo info)

Description copied from interface: IDerivedDataInfoRepository

Saves the descriptor of DS for a specific object.

Specified by:

save in interface IDerivedDataInfoRepository

Parameters:

info - The descriptor to save.

start

public void start(boolean delete,
 IBmModel bmModel)

Description copied from interface: IDerivedDataInfoRepository

Starts the repository as the part of DD startup cycle.

Specified by:

start in interface IDerivedDataInfoRepository

Parameters:

delete - The flag showing whether all the contents must be deleted.

bmModel - Corresponding BM model reference. May not be null

stop

public void stop(boolean delete)

Description copied from interface: IDerivedDataInfoRepository

Stops the repository as the part of DD shutdown cycle.

Specified by:

stop in interface IDerivedDataInfoRepository

Parameters:

delete - The flag showing whether all the contents must be deleted.

updateDerivedDataInfo

public void updateDerivedDataInfo(IObjectDerivedDataContext context)

Description copied from interface: IDerivedDataInfoRepository

Updates derived data info according to provided context

Specified by:

updateDerivedDataInfo in interface IDerivedDataInfoRepository

Parameters:

context - The provided context, may not be null

updateDerivedDataInfo

public void updateDerivedDataInfo(IObjectDerivedDataContext context,
 long version)

Description copied from interface: IDerivedDataInfoRepository

Updates derived data info according to provided context

Specified by:

updateDerivedDataInfo in interface IDerivedDataInfoRepository

Parameters:

context - The provided context, may not be null

version - The context creation timestamp

loadExistingContext

public IObjectDerivedDataContext loadExistingContext(Object objectId,
 String segmentId,
 DerivedDataInfo.SegmentContextData segmentData,
 IObjectContextFactory objectContextFactory)

Description copied from interface: IDerivedDataInfoRepository

Loads an existing context with a data being stored in the repository

Specified by:

loadExistingContext in interface IDerivedDataInfoRepository

Parameters:

objectId - A target object identifier. May not be null

segmentId - A target object identifier. May not be null

segmentData - A custom data of a context. May not be null

objectContextFactory - The object context creation factory. May not be null

Returns:

Loaded async. computation context. Can be null in case if context doesn't exist

deactivateContexts

public void deactivateContexts(String segmentId,
 IObjectContextFactory objectContextFactory)

Description copied from interface: IDerivedDataInfoRepository

Perform mass deactivation of contexts

Specified by:

deactivateContexts in interface IDerivedDataInfoRepository

Parameters:

segmentId - Target segment of async. processing pipeline for the deactivation

objectContextFactory - The object context creation factory. May not be null