atg.endeca.index

Class DynamicPropertySchemaSynchronization

java.lang.Object

atg.nucleus.logging.VariableArgumentApplicationLoggingImpl

atg.nucleus.GenericService

atg.endeca.index.ExporterHelperIndexingSynchronization<SchemaExporter>

atg.endeca.index.DynamicPropertySchemaSynchronization

All Implemented Interfaces:

atg.core.logging.Logging, atg.core.logging.TraceLogging, atg.naming.AbsoluteNameable, NameContextBindingListener, NameContextElement, atg.naming.NameContextParentable, NameResolver, AdminableService, atg.nucleus.Configured, ApplicationLogging, atg.nucleus.logging.ApplicationLoggingSender, atg.nucleus.logging.TraceApplicationLogging, VariableArgumentApplicationLogging, ComponentNameResolver, Service, ServiceListener, atg.repository.search.indexing.IndexingSynchronization, atg.repository.search.indexing.ProcessingPropertiesCallback, java.util.EventListener

public class DynamicPropertySchemaSynchronization
extends atg.endeca.index.ExporterHelperIndexingSynchronization<SchemaExporter>
implements atg.repository.search.indexing.IndexingSynchronization, atg.repository.search.indexing.ProcessingPropertiesCallback

A synchronization that tracks dynamic properties generated in an indexing run (via the ProcessingPropertiesCallback interface), then submits schema entries for those properties a SchemaGenerator.

Created: January 25 2012

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DynamicPropertySchemaSynchronization.DynamicOutputPropertyInfo A class that to track dynamic output property info.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ATTR_DYNAMIC_PROPERTIES The context attribute used to store dynamic properties.
static java.lang.String	CLASS_VERSION Class version string

Fields inherited from class atg.nucleus.GenericService

SERVICE_INFO_KEY

Fields inherited from interface atg.nucleus.logging.TraceApplicationLogging

DEFAULT_LOG_TRACE_STATUS

Fields inherited from interface atg.nucleus.logging.ApplicationLogging

DEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS

Constructor Summary

Constructors

Constructor and Description
DynamicPropertySchemaSynchronization()

Method Summary

Modifier and Type	Method and Description
void	afterSessionStart(Context pContext) This method is invoked immediately after a DocumentSubmitter session is started.
protected Records	createAdditionalRecordsForCurrentApplication(EndecaContext pContext)
void	doStartService() This is called after a Service has been created, placed into the naming hierarchy, and initialized with its configured property values.
java.util.Map<java.lang.String,java.lang.String>	getEveryDynamicSchemaRecordProperties() Returns property everyDynamicSchemaRecordProperties.
protected java.util.List<atg.repository.search.indexing.specifier.OutputProperty>	getOutputPropertiesForApplication(java.util.Collection<DynamicPropertySchemaSynchronization.DynamicOutputPropertyInfo> pInfos, java.lang.String pApplicationName) Return the list of output properties associated with the specified locale.
SchemaExporter	getSchemaExporter() Returns property schemaExporter.
java.lang.String	getSchemaExporterPath() Returns property schemaExporterPath.
protected void	modifyRecords(java.util.List<atg.repository.search.indexing.specifier.OutputProperty> pSourceProperties, Records pRecords, java.util.Locale pLocale) Make any modifications to the records generated by the specified locale.
protected void	processDynamicOutputProperties(Context pContext, RepositoryItem pItem, atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier, java.util.Collection<atg.repository.search.indexing.specifier.OutputProperty> pOutputProperties, boolean pIsMeta) Process any dynamic output properties by adding them to ATTR_DYNAMIC_PROPERTIES as needed.
void	processingProperties(Context pContext, RepositoryItem pItem, atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier, atg.repository.search.indexing.specifier.OutputProperty[] pProperties, boolean pIsMeta, java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,java.lang.Object> pGeneratorMap)
void	setEveryDynamicSchemaRecordProperties(java.util.Map<java.lang.String,java.lang.String> pEveryDynamicSchemaRecordProperties) Sets property everyDynamicSchemaRecordProperties.
void	setSchemaExporter(SchemaExporter pSchemaExporter) Sets property schemaExporter.
void	setSchemaExporterPath(java.lang.String pSchemaExporterPath) Sets property schemaExporterPath.
protected boolean	shouldSubmitAdditionalRecords(EndecaContext pEndecaContext)

Methods inherited from class atg.endeca.index.ExporterHelperIndexingSynchronization

beforeSessionEnd, getCurrentApplicationKey, getCurrentApplicationName, getDocumentSubmitter, getExporter, getIndexingTaskOfExporter, setExporter

Methods inherited from class atg.nucleus.GenericService

addLogListener, createAdminServlet, doStopService, getAbsoluteName, getAdminServlet, getAdminServletOutputStreamEncoding, getLoggingForVlogging, getLogListenerCount, getLogListeners, getName, getNameContext, getNucleus, getRoot, getServiceConfiguration, getServiceInfo, isAdminServletUseServletOutputStream, isLoggingDebug, isLoggingError, isLoggingInfo, isLoggingTrace, isLoggingWarning, isRunning, logDebug, logDebug, logDebug, logError, logError, logError, logInfo, logInfo, logInfo, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, nameContextElementBound, nameContextElementUnbound, removeLogListener, reResolveThis, resolveName, resolveName, resolveName, resolveName, sendLogEvent, setAdminServletOutputStreamEncoding, setAdminServletUseServletOutputStream, setLoggingDebug, setLoggingError, setLoggingInfo, setLoggingTrace, setLoggingWarning, setNucleus, setServiceInfo, startService, stopService, toString

Methods inherited from class atg.nucleus.logging.VariableArgumentApplicationLoggingImpl

vlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogDebugTrace, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarning

Methods inherited from class java.lang.Object

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

Methods inherited from interface atg.repository.search.indexing.IndexingSynchronization

beforeSessionEnd

Field Detail

CLASS_VERSION

public static java.lang.String CLASS_VERSION

Class version string

ATTR_DYNAMIC_PROPERTIES

public static final java.lang.String ATTR_DYNAMIC_PROPERTIES

The context attribute used to store dynamic properties.

See Also:

Constant Field Values

Constructor Detail

DynamicPropertySchemaSynchronization

public DynamicPropertySchemaSynchronization()

Method Detail

setEveryDynamicSchemaRecordProperties

public void setEveryDynamicSchemaRecordProperties(java.util.Map<java.lang.String,java.lang.String> pEveryDynamicSchemaRecordProperties)

Sets property everyDynamicSchemaRecordProperties. Properties to add to each dynamically generated schema record.

getEveryDynamicSchemaRecordProperties

public java.util.Map<java.lang.String,java.lang.String> getEveryDynamicSchemaRecordProperties()

Returns property everyDynamicSchemaRecordProperties. Properties to add to each dynamically generated schema record.

setSchemaExporter

public void setSchemaExporter(SchemaExporter pSchemaExporter)

Sets property schemaExporter. The schema exporter to use. Alias for exporter property.

getSchemaExporter

public SchemaExporter getSchemaExporter()

Returns property schemaExporter. The schema exporter to use. Alias for exporter property.

setSchemaExporterPath

public void setSchemaExporterPath(java.lang.String pSchemaExporterPath)

Sets property schemaExporterPath. Path to the schema exporter. Will be resolved after startup if schemaExport is not set explicitly.

getSchemaExporterPath

public java.lang.String getSchemaExporterPath()

Returns property schemaExporterPath. Path to the schema exporter. Will be resolved after startup if schemaExport is not set explicitly.

afterSessionStart

public void afterSessionStart(Context pContext)
                       throws IndexingException

This method is invoked immediately after a DocumentSubmitter session is started.

Specified by:

afterSessionStart in interface atg.repository.search.indexing.IndexingSynchronization

Specified by:

afterSessionStart in class atg.endeca.index.ExporterHelperIndexingSynchronization<SchemaExporter>

Parameters:

pContext - the Context for the current indexing operation. The DocumentSubmitterSession is available as a property, as is the IndexingOutputConfig and other state information.

Throws:

IndexingException

shouldSubmitAdditionalRecords

protected boolean shouldSubmitAdditionalRecords(EndecaContext pEndecaContext)

Specified by:

shouldSubmitAdditionalRecords in class atg.endeca.index.ExporterHelperIndexingSynchronization<SchemaExporter>

createAdditionalRecordsForCurrentApplication

protected Records createAdditionalRecordsForCurrentApplication(EndecaContext pContext)

Specified by:

createAdditionalRecordsForCurrentApplication in class atg.endeca.index.ExporterHelperIndexingSynchronization<SchemaExporter>

modifyRecords

protected void modifyRecords(java.util.List<atg.repository.search.indexing.specifier.OutputProperty> pSourceProperties,
                             Records pRecords,
                             java.util.Locale pLocale)

Make any modifications to the records generated by the specified locale.

getOutputPropertiesForApplication

protected java.util.List<atg.repository.search.indexing.specifier.OutputProperty> getOutputPropertiesForApplication(java.util.Collection<DynamicPropertySchemaSynchronization.DynamicOutputPropertyInfo> pInfos,
                                                                                                                    java.lang.String pApplicationName)

Return the list of output properties associated with the specified locale.

Parameters:

pTryWithoutVariantAndCountry. - If set to true tries to match the locale firstly with the language_country_variant. If this is not successful try to match without the variant and country

processingProperties

public void processingProperties(Context pContext,
                                 RepositoryItem pItem,
                                 atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
                                 atg.repository.search.indexing.specifier.OutputProperty[] pProperties,
                                 boolean pIsMeta,
                                 java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,java.lang.Object> pGeneratorMap)

Specified by:

processingProperties in interface atg.repository.search.indexing.ProcessingPropertiesCallback

processDynamicOutputProperties

protected void processDynamicOutputProperties(Context pContext,
                                              RepositoryItem pItem,
                                              atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
                                              java.util.Collection<atg.repository.search.indexing.specifier.OutputProperty> pOutputProperties,
                                              boolean pIsMeta)

Process any dynamic output properties by adding them to ATTR_DYNAMIC_PROPERTIES as needed.

Parameters:

pContext - the current indexing context object

pItem - the current respository item (not directly used)

pSpecifier - the parent output item specific

pOutputProperties - the (presumably dynamic) output properties.

doStartService

public void doStartService()
                    throws ServiceException

Description copied from class: GenericService

This is called after a Service has been created, placed into the naming hierarchy, and initialized with its configured property values. The Service should override this method to start any processes it requires.

Overrides:

doStartService in class GenericService

Throws:

ServiceException - if the Service had a problem starting up