Package com.qfs.distribution

Interface ILocalityIdentifier

All Known Implementing Classes:

ClusterLocalityIdentifier

public interface ILocalityIdentifier

An object used to find the relevant cluster members to send messages to, considering the given locations or measures.

Author:

ActiveViam

Method Summary

Modifier and Type	Method	Description
boolean	belongsToSingleCube(String measure)	Returns whether the given measure belongs to a single data cube.
default boolean	canBeLocalized(String remoteAddress, ILocation location, String measure)	Returns whether the aggregates targeted by the given location and measure can be localized in the given remote instance.
Map<String,String>	getApplicationByAddress()	Returns the application ID of all the remote pivot instances, indexed by their addresses..
Collection<String>	getDataCubeIdsForMeasure(String measure)	Returns the names of the cubes that declare containing the provided measure.
Collection<String>	getLocality(ILocation location, Collection<? extends IMeasureMember> measures)	Returns a collection of addresses as strings, to know which cube in the cluster are relevant for this location or measures.
Collection<String>	getLocality(Collection<? extends ILocation> locations, Collection<String> measures)	Returns a collection of addresses as strings, to know which cube in the cluster are relevant for these locations or measures.
Set<String>	getRemoteAddresses()	Returns the addresses of the known remote instances.
Predicate<String>	localMeasurePredicate(String remoteAddress, ILocation location)	Returns the predicate filtering the measures that can be localized in the given remote instance.

Method Details

canBeLocalized

@DeprecatedApi(forRemoval="6.1.0",
               rationale="May be replaced by #localMeasurePredicate")
default boolean canBeLocalized(String remoteAddress,
 ILocation location,
 String measure)

Returns whether the aggregates targeted by the given location and measure can be localized in the given remote instance.

Parameters:

remoteAddress - the address of the remote instance

location - A location

measure - A measure

Returns:

Whether the aggregates targeted by the given location and measure can be localized to a sub-set of remote instances

localMeasurePredicate

Predicate<String> localMeasurePredicate(String remoteAddress,
 ILocation location)

Returns the predicate filtering the measures that can be localized in the given remote instance.

belongsToSingleCube

boolean belongsToSingleCube(String measure)

Returns whether the given measure belongs to a single data cube.

getDataCubeIdsForMeasure

Collection<String> getDataCubeIdsForMeasure(String measure)

Returns the names of the cubes that declare containing the provided measure.

Parameters:

measure - the name of the measure for which we enquire the valid data cubes

getLocality

Collection<String> getLocality(Collection<? extends ILocation> locations,
 Collection<String> measures)

Returns a collection of addresses as strings, to know which cube in the cluster are relevant for these locations or measures.

getLocality

Collection<String> getLocality(ILocation location,
 Collection<? extends IMeasureMember> measures)

Returns a collection of addresses as strings, to know which cube in the cluster are relevant for this location or measures.

getRemoteAddresses

Set<String> getRemoteAddresses()

Returns the addresses of the known remote instances.

getApplicationByAddress

Map<String,String> getApplicationByAddress()

Returns the application ID of all the remote pivot instances, indexed by their addresses..