org.apache.unomi.services.impl.segments

Class SegmentServiceImpl

java.lang.Object

org.apache.unomi.services.impl.AbstractServiceImpl

org.apache.unomi.services.impl.segments.SegmentServiceImpl

All Implemented Interfaces:

EventListener, org.apache.unomi.api.services.SegmentService, org.osgi.framework.BundleListener, org.osgi.framework.SynchronousBundleListener

public class SegmentServiceImpl
extends AbstractServiceImpl
implements org.apache.unomi.api.services.SegmentService, org.osgi.framework.SynchronousBundleListener

Field Summary

Fields inherited from class org.apache.unomi.services.impl.AbstractServiceImpl

definitionsService, persistenceService

Constructor Summary

Constructors

Constructor and Description
SegmentServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	bundleChanged(org.osgi.framework.BundleEvent event)
void	createScoringDefinition(String scope, String scoringId, String name, String description)
String	getGeneratedPropertyKey(org.apache.unomi.api.conditions.Condition condition, org.apache.unomi.api.conditions.Condition parentCondition)
org.apache.unomi.api.PartialList<org.apache.unomi.api.Profile>	getMatchingIndividuals(String segmentID, int offset, int size, String sortBy)
long	getMatchingIndividualsCount(String segmentID)
org.apache.unomi.api.segments.Scoring	getScoringDefinition(String scoringId)
org.apache.unomi.api.segments.DependentMetadata	getScoringDependentMetadata(String scoringId)
org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata>	getScoringMetadatas(int offset, int size, String sortBy)
org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata>	getScoringMetadatas(org.apache.unomi.api.query.Query query)
org.apache.unomi.api.segments.Segment	getSegmentDefinition(String segmentId)
org.apache.unomi.api.segments.DependentMetadata	getSegmentDependentMetadata(String segmentId)
org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata>	getSegmentMetadatas(int offset, int size, String sortBy)
org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata>	getSegmentMetadatas(org.apache.unomi.api.query.Query query)
org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata>	getSegmentMetadatas(String scope, int offset, int size, String sortBy)
List<org.apache.unomi.api.Metadata>	getSegmentMetadatasForProfile(org.apache.unomi.api.Profile profile)
org.apache.unomi.api.segments.SegmentsAndScores	getSegmentsAndScoresForProfile(org.apache.unomi.api.Profile profile)
Boolean	isProfileInSegment(org.apache.unomi.api.Profile profile, String segmentId)
void	postConstruct()
void	preDestroy()
void	recalculatePastEventConditions()
org.apache.unomi.api.segments.DependentMetadata	removeScoringDefinition(String scoringId, boolean validate)
org.apache.unomi.api.segments.DependentMetadata	removeSegmentDefinition(String segmentId, boolean validate)
void	setAggregateQueryBucketSize(int aggregateQueryBucketSize)
void	setBatchSegmentProfileUpdate(boolean batchSegmentProfileUpdate)
void	setBundleContext(org.osgi.framework.BundleContext bundleContext)
void	setDailyDateExprEvaluationHourUtc(int dailyDateExprEvaluationHourUtc)
void	setEventService(org.apache.unomi.api.services.EventService eventService)
void	setMaximumIdsQueryCount(int maximumIdsQueryCount)
void	setMaxRetriesForUpdateProfileSegment(int maxRetriesForUpdateProfileSegment)
void	setPastEventsDisablePartitions(boolean pastEventsDisablePartitions)
void	setRulesService(org.apache.unomi.api.services.RulesService rulesService)
void	setSchedulerService(org.apache.unomi.api.services.SchedulerService schedulerService)
void	setScoringDefinition(org.apache.unomi.api.segments.Scoring scoring)
void	setSecondsDelayForRetryUpdateProfileSegment(long secondsDelayForRetryUpdateProfileSegment)
void	setSegmentDefinition(org.apache.unomi.api.segments.Segment segment)
void	setSegmentRefreshInterval(long segmentRefreshInterval)
void	setSegmentUpdateBatchSize(int segmentUpdateBatchSize)
void	setSendProfileUpdateEventForSegmentUpdate(boolean sendProfileUpdateEventForSegmentUpdate)
void	setTaskExecutionPeriod(long taskExecutionPeriod)
void	updateAutoGeneratedRules(org.apache.unomi.api.Metadata metadata, org.apache.unomi.api.conditions.Condition condition)

Methods inherited from class org.apache.unomi.services.impl.AbstractServiceImpl

getMetadatas, getMetadatas, setDefinitionsService, setPersistenceService

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentServiceImpl

public SegmentServiceImpl()

Method Detail

setBundleContext

public void setBundleContext(org.osgi.framework.BundleContext bundleContext)

setEventService

public void setEventService(org.apache.unomi.api.services.EventService eventService)

setRulesService

public void setRulesService(org.apache.unomi.api.services.RulesService rulesService)

setSchedulerService

public void setSchedulerService(org.apache.unomi.api.services.SchedulerService schedulerService)

setSegmentUpdateBatchSize

public void setSegmentUpdateBatchSize(int segmentUpdateBatchSize)

setAggregateQueryBucketSize

public void setAggregateQueryBucketSize(int aggregateQueryBucketSize)

setMaximumIdsQueryCount

public void setMaximumIdsQueryCount(int maximumIdsQueryCount)

setPastEventsDisablePartitions

public void setPastEventsDisablePartitions(boolean pastEventsDisablePartitions)

setSegmentRefreshInterval

public void setSegmentRefreshInterval(long segmentRefreshInterval)

setMaxRetriesForUpdateProfileSegment

public void setMaxRetriesForUpdateProfileSegment(int maxRetriesForUpdateProfileSegment)

setSecondsDelayForRetryUpdateProfileSegment

public void setSecondsDelayForRetryUpdateProfileSegment(long secondsDelayForRetryUpdateProfileSegment)

setBatchSegmentProfileUpdate

public void setBatchSegmentProfileUpdate(boolean batchSegmentProfileUpdate)

setSendProfileUpdateEventForSegmentUpdate

public void setSendProfileUpdateEventForSegmentUpdate(boolean sendProfileUpdateEventForSegmentUpdate)

setDailyDateExprEvaluationHourUtc

public void setDailyDateExprEvaluationHourUtc(int dailyDateExprEvaluationHourUtc)

postConstruct

public void postConstruct()
                   throws IOException

Throws:

IOException

preDestroy

public void preDestroy()

getSegmentMetadatas

public org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata> getSegmentMetadatas(int offset,
                                                                                           int size,
                                                                                           String sortBy)

Specified by:

getSegmentMetadatas in interface org.apache.unomi.api.services.SegmentService

getSegmentMetadatas

public org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata> getSegmentMetadatas(String scope,
                                                                                           int offset,
                                                                                           int size,
                                                                                           String sortBy)

Specified by:

getSegmentMetadatas in interface org.apache.unomi.api.services.SegmentService

getSegmentMetadatas

public org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata> getSegmentMetadatas(org.apache.unomi.api.query.Query query)

Specified by:

getSegmentMetadatas in interface org.apache.unomi.api.services.SegmentService

getSegmentDefinition

public org.apache.unomi.api.segments.Segment getSegmentDefinition(String segmentId)

Specified by:

getSegmentDefinition in interface org.apache.unomi.api.services.SegmentService

setSegmentDefinition

public void setSegmentDefinition(org.apache.unomi.api.segments.Segment segment)

Specified by:

setSegmentDefinition in interface org.apache.unomi.api.services.SegmentService

getSegmentDependentMetadata

public org.apache.unomi.api.segments.DependentMetadata getSegmentDependentMetadata(String segmentId)

Specified by:

getSegmentDependentMetadata in interface org.apache.unomi.api.services.SegmentService

removeSegmentDefinition

public org.apache.unomi.api.segments.DependentMetadata removeSegmentDefinition(String segmentId,
                                                                               boolean validate)

Specified by:

removeSegmentDefinition in interface org.apache.unomi.api.services.SegmentService

getMatchingIndividuals

public org.apache.unomi.api.PartialList<org.apache.unomi.api.Profile> getMatchingIndividuals(String segmentID,
                                                                                             int offset,
                                                                                             int size,
                                                                                             String sortBy)

Specified by:

getMatchingIndividuals in interface org.apache.unomi.api.services.SegmentService

getMatchingIndividualsCount

public long getMatchingIndividualsCount(String segmentID)

Specified by:

getMatchingIndividualsCount in interface org.apache.unomi.api.services.SegmentService

isProfileInSegment

public Boolean isProfileInSegment(org.apache.unomi.api.Profile profile,
                                  String segmentId)

Specified by:

isProfileInSegment in interface org.apache.unomi.api.services.SegmentService

getSegmentsAndScoresForProfile

public org.apache.unomi.api.segments.SegmentsAndScores getSegmentsAndScoresForProfile(org.apache.unomi.api.Profile profile)

Specified by:

getSegmentsAndScoresForProfile in interface org.apache.unomi.api.services.SegmentService

getSegmentMetadatasForProfile

public List<org.apache.unomi.api.Metadata> getSegmentMetadatasForProfile(org.apache.unomi.api.Profile profile)

Specified by:

getSegmentMetadatasForProfile in interface org.apache.unomi.api.services.SegmentService

getScoringMetadatas

public org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata> getScoringMetadatas(int offset,
                                                                                           int size,
                                                                                           String sortBy)

Specified by:

getScoringMetadatas in interface org.apache.unomi.api.services.SegmentService

getScoringMetadatas

public org.apache.unomi.api.PartialList<org.apache.unomi.api.Metadata> getScoringMetadatas(org.apache.unomi.api.query.Query query)

Specified by:

getScoringMetadatas in interface org.apache.unomi.api.services.SegmentService

getScoringDefinition

public org.apache.unomi.api.segments.Scoring getScoringDefinition(String scoringId)

Specified by:

getScoringDefinition in interface org.apache.unomi.api.services.SegmentService

setScoringDefinition

public void setScoringDefinition(org.apache.unomi.api.segments.Scoring scoring)

Specified by:

setScoringDefinition in interface org.apache.unomi.api.services.SegmentService

createScoringDefinition

public void createScoringDefinition(String scope,
                                    String scoringId,
                                    String name,
                                    String description)

Specified by:

createScoringDefinition in interface org.apache.unomi.api.services.SegmentService

getScoringDependentMetadata

public org.apache.unomi.api.segments.DependentMetadata getScoringDependentMetadata(String scoringId)

Specified by:

getScoringDependentMetadata in interface org.apache.unomi.api.services.SegmentService

removeScoringDefinition

public org.apache.unomi.api.segments.DependentMetadata removeScoringDefinition(String scoringId,
                                                                               boolean validate)

Specified by:

removeScoringDefinition in interface org.apache.unomi.api.services.SegmentService

updateAutoGeneratedRules

public void updateAutoGeneratedRules(org.apache.unomi.api.Metadata metadata,
                                     org.apache.unomi.api.conditions.Condition condition)

getGeneratedPropertyKey

public String getGeneratedPropertyKey(org.apache.unomi.api.conditions.Condition condition,
                                      org.apache.unomi.api.conditions.Condition parentCondition)

Specified by:

getGeneratedPropertyKey in interface org.apache.unomi.api.services.SegmentService

recalculatePastEventConditions

public void recalculatePastEventConditions()

Specified by:

recalculatePastEventConditions in interface org.apache.unomi.api.services.SegmentService

bundleChanged

public void bundleChanged(org.osgi.framework.BundleEvent event)

Specified by:

bundleChanged in interface org.osgi.framework.BundleListener

setTaskExecutionPeriod

public void setTaskExecutionPeriod(long taskExecutionPeriod)