atg.endeca.index

Class PerApplicationExporter

java.lang.Object

atg.nucleus.logging.VariableArgumentApplicationLoggingImpl

atg.nucleus.GenericService

atg.endeca.index.PerApplicationExporter

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, java.util.EventListener

Direct Known Subclasses:

RepositoryTypeHierarchyExporter, SchemaExporter

public abstract class PerApplicationExporter
extends GenericService

A base class that needs to export items by Endeca application (that is, exports records once per each Endeca Workbench/EAC application). Handles most of the setup/teardown of the submitter session. Appropriate for exporters that generate a relatively small number of records to be exported, since it assumes that a single Records object will hold all records comfortably in memory.

Created: November 16 2011

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PerApplicationExporter.MinimalBulkLoaderResults Extends BulkLoaderResults with a minimal implementation that accepts a boolean "successful" flag..
static class	PerApplicationExporter.MinimalIncrementalLoaderResults Extends IncrementalLoaderResults with a minimal implementation.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CLASS_VERSION Class version string
static java.lang.String	TEST_GENERATION_CONTEXT_ATTRIBUTE A context attribute that is set if we are generating test XML.

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
PerApplicationExporter()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel(IndexingTask pTask, boolean pBaseline)
protected javax.servlet.Servlet	createAdminServlet() Creates and returns a new Servlet that will administer this service.
protected EndecaContext	createContext() Create the context to use.
protected abstract Records	createExportRecords(EndecaContext pContext, java.util.Locale pLocale) Create the export records for the specified locale.
java.lang.String	createExportRecordsAsXML() Return the set of export records for the default Locale in XML form.
void	doStartService() This is called after a Service has been created, placed into the naming hierarchy, and initialized with its configured property values.
protected void	export(IndexingTask pTask) Generate and export records via our DocumentSubmitter.
void	exportRecords(Records pRecords, IndexingTask pTask, EndecaContext pContext) Export the schema using the specified DocumentSubmitterSession.
java.lang.String	getDefaultLanguageForRecordStores() Returns property mDefaultLanguageForRecordStores.
DocumentSubmitter	getDocumentSubmitter() Returns property documentSubmitter.
IndexingApplicationConfiguration	getIndexingApplicationConfiguration() Returns property indexingApplicationConfiguration.
EndecaIndexingOutputConfig	getIndexingOutputConfig() Returns property indexingOutputConfig.
java.util.Set<java.lang.String>	getIndexingOutputConfigPaths()
java.util.Locale[]	getLocales() Returns property locales.
protected java.lang.String	getXmlOutputTitle() Return the text string used as the title for the XML output in the HTML admin.
protected void	initContext(EndecaContext pContext, IndexingTask pTask, atg.repository.search.indexing.DocumentSubmitterSession pSession, java.util.Locale pLocale) Initialize the specified context object, using the passed in parameters.
boolean	isEchoRecordsToStdout() Returns property echoRecordsToStdout.
boolean	isForceToBaseline() The method is called before starting partial indexing job for all Indexable to allow forcing the job to baseline indexing.
boolean	isNeededForIncremental()
boolean	isSingleLanguageOverride() Whether or not we are saving things to a single language record store, regardless of locale.
boolean	isSupportsStatusCounts()
boolean	mayNeedCleanup()
atg.repository.search.indexing.BulkLoaderResults	performBaselineUpdate(IndexingTask pTask)
atg.repository.search.indexing.LoaderResults	performPartialUpdate(IndexingTask pTask)
void	postIndexingCleanup(IndexingTask pTask, boolean pSuccess, atg.repository.search.indexing.LoaderResults pResults)
protected void	restoreDynamoRequestLocale(java.lang.Object pRestoreValue) Restore the current dynamo request locale.
void	setDefaultLanguageForRecordStores(java.lang.String pDefaultLanguageForRecordStores) Sets property mDefaultLanguageForRecordStores.
void	setDocumentSubmitter(DocumentSubmitter pDocumentSubmitter) Sets property documentSubmitter.
protected java.lang.Object	setDynamoRequestLocale(java.util.Locale pLocale) Set the current dynamo request locale, possibly setting a fake current local request.
void	setEchoRecordsToStdout(boolean pEchoRecordsToStdout) Sets property echoRecordsToStdout.
void	setIndexables(Indexable[] pIndexables)
void	setIndexingApplicationConfiguration(IndexingApplicationConfiguration pIndexingApplicationConfiguration) Sets property indexingApplicationConfiguration.
void	setIndexingOutputConfig(EndecaIndexingOutputConfig pIndexingOutputConfig) Sets property indexingOutputConfig.

Methods inherited from class atg.nucleus.GenericService

addLogListener, 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

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, toString, wait, wait, wait

Field Detail

CLASS_VERSION

public static java.lang.String CLASS_VERSION

Class version string

TEST_GENERATION_CONTEXT_ATTRIBUTE

public static final java.lang.String TEST_GENERATION_CONTEXT_ATTRIBUTE

A context attribute that is set if we are generating test XML.

See Also:

Constant Field Values

Constructor Detail

PerApplicationExporter

public PerApplicationExporter()

Method Detail

setDefaultLanguageForRecordStores

public void setDefaultLanguageForRecordStores(java.lang.String pDefaultLanguageForRecordStores)

Sets property mDefaultLanguageForRecordStores. If set, everything is exported to a single record store for all locales

getDefaultLanguageForRecordStores

public java.lang.String getDefaultLanguageForRecordStores()

Returns property mDefaultLanguageForRecordStores. If set, everything is exported to a single record store for all locales

isSingleLanguageOverride

public boolean isSingleLanguageOverride()

Whether or not we are saving things to a single language record store, regardless of locale.

getLocales

public java.util.Locale[] getLocales()

Returns property locales. List of locales to generate the records in.

setIndexingApplicationConfiguration

public void setIndexingApplicationConfiguration(IndexingApplicationConfiguration pIndexingApplicationConfiguration)

Sets property indexingApplicationConfiguration. The indexing application configuration used to determine Endeca applications and their associated locales.

getIndexingApplicationConfiguration

@NotNull
public IndexingApplicationConfiguration getIndexingApplicationConfiguration()

Returns property indexingApplicationConfiguration. The indexing application configuration used to determine Endeca applications and their associated locales.

setEchoRecordsToStdout

public void setEchoRecordsToStdout(boolean pEchoRecordsToStdout)

Sets property echoRecordsToStdout. Whether to echo records to standard out.

isEchoRecordsToStdout

public boolean isEchoRecordsToStdout()

Returns property echoRecordsToStdout. Whether to echo records to standard out.

setDocumentSubmitter

public void setDocumentSubmitter(DocumentSubmitter pDocumentSubmitter)

Sets property documentSubmitter. The document submitter to use for exporting our records..

getDocumentSubmitter

@NotNull
public DocumentSubmitter getDocumentSubmitter()

Returns property documentSubmitter. The document submitter to use for exporting our records.

setIndexingOutputConfig

public void setIndexingOutputConfig(EndecaIndexingOutputConfig pIndexingOutputConfig)

Sets property indexingOutputConfig. The indexing output config whose data should be used to generate records.

getIndexingOutputConfig

public EndecaIndexingOutputConfig getIndexingOutputConfig()

Returns property indexingOutputConfig. The indexing output config whose data should be used to generate records..

export

protected void export(IndexingTask pTask)
               throws IndexingException

Generate and export records via our DocumentSubmitter.

Parameters:

pTask - the current indexing task. May be null if there is no current IndexingTask.

Throws:

IndexingException

createContext

protected EndecaContext createContext()

Create the context to use. Provided for sub-classing.

Returns:

a new EndecaContext instance.

initContext

protected void initContext(EndecaContext pContext,
               IndexingTask pTask,
               atg.repository.search.indexing.DocumentSubmitterSession pSession,
               java.util.Locale pLocale)

Initialize the specified context object, using the passed in parameters.

Parameters:

pContext - the context to initialize

pTask - our indexing task

pSession - our document submitter session

pLocale - the locale to use for the current document locale.

exportRecords

public void exportRecords(Records pRecords,
                 IndexingTask pTask,
                 EndecaContext pContext)
                   throws IndexingException

Export the schema using the specified DocumentSubmitterSession.

Parameters:

pRecords - the records to export. If null, will generate records using createExportRecords().

pTask - the current indexing task. May be null if called outside of an IndexingPhase.

pContext - the EndecaContext to use. Must have a session on it.

Throws:

IndexingException - if there's a problem

createExportRecords

protected abstract Records createExportRecords(EndecaContext pContext,
                          java.util.Locale pLocale)
                                        throws IndexingException

Create the export records for the specified locale.

Parameters:

pContext - the current indexing context.

pLocale - to locale for which to generate records.

Returns:

the generated set of records.

Throws:

IndexingException - if there is a problem

performPartialUpdate

public atg.repository.search.indexing.LoaderResults performPartialUpdate(IndexingTask pTask)
                                                                  throws IndexingException

Throws:

IndexingException

performBaselineUpdate

public atg.repository.search.indexing.BulkLoaderResults performBaselineUpdate(IndexingTask pTask)
                                                                       throws IndexingException

Throws:

IndexingException

isNeededForIncremental

public boolean isNeededForIncremental()

postIndexingCleanup

public void postIndexingCleanup(IndexingTask pTask,
                       boolean pSuccess,
                       atg.repository.search.indexing.LoaderResults pResults)

mayNeedCleanup

public boolean mayNeedCleanup()

cancel

public boolean cancel(IndexingTask pTask,
             boolean pBaseline)
               throws IndexingException

Throws:

IndexingException

isSupportsStatusCounts

public boolean isSupportsStatusCounts()

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

setDynamoRequestLocale

protected java.lang.Object setDynamoRequestLocale(java.util.Locale pLocale)

Set the current dynamo request locale, possibly setting a fake current local request. Invokers should always call restoreDynamoRequestLocale in a finally block after invoking this method.

Parameters:

pLocale - the locale to set.

Returns:

the previous locale

restoreDynamoRequestLocale

protected void restoreDynamoRequestLocale(java.lang.Object pRestoreValue)

Restore the current dynamo request locale. This method should be called in a finally block by any code that called setDynamoRequestLocale.

Parameters:

pRestoreValue - the restore value returned by setDynamoRequestLocale.

createExportRecordsAsXML

public java.lang.String createExportRecordsAsXML()
                                          throws IndexingException

Return the set of export records for the default Locale in XML form.

Returns:

a XML representations of created records.

Throws:

IndexingException - if a problem occurred

getIndexingOutputConfigPaths

public java.util.Set<java.lang.String> getIndexingOutputConfigPaths()

isForceToBaseline

public boolean isForceToBaseline()

The method is called before starting partial indexing job for all Indexable to allow forcing the job to baseline indexing.

Returns:

true if the job should be forced to baseline.

createAdminServlet

protected javax.servlet.Servlet createAdminServlet()

Description copied from class: GenericService

Creates and returns a new Servlet that will administer this service. By default, this creates a ServiceAdminServlet, but subclasses may create their own servlets.

Overrides:

createAdminServlet in class GenericService

setIndexables

public void setIndexables(Indexable[] pIndexables)

getXmlOutputTitle

protected java.lang.String getXmlOutputTitle()

Return the text string used as the title for the XML output in the HTML admin.

Returns:

the XML output title.