atg.endeca.index

Class RecordStoreBulkLoaderImpl

java.lang.Object

atg.nucleus.logging.VariableArgumentApplicationLoggingImpl

atg.nucleus.GenericService

atg.repository.search.indexing.LoaderImpl

atg.repository.search.indexing.BulkLoaderImpl

atg.endeca.index.RecordStoreBulkLoaderImpl

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

public class RecordStoreBulkLoaderImpl
extends BulkLoaderImpl

A BulkLoader subclass that adds support for creating a RecordStoreOutputDocumentContent, as well as adding support for ProcessingPropertiesCallback and PerDocumentIndexingSynchronization.

Created: November 04 2011

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CLASS_VERSION Class version string

Fields inherited from class atg.repository.search.indexing.BulkLoaderImpl

EMPTY_REPOSITORY_ARRAY

Fields inherited from class atg.repository.search.indexing.LoaderImpl

DELETE_DOCUMENT, GET_GENERATOR_PROPERTY, GET_META_PROPERTY, GET_TEXT_PROPERTY, MY_RESOURCE_NAME, PROCESS_PROPERTIES, REGENERATE_FOR_CHANGE, REPOSITORY_ID_PROPERTY_NAME, sResourceBundle, START_QUERY

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

Method Summary

Modifier and Type	Method and Description
protected Context	createContext() Create a new context.
protected atg.repository.search.indexing.OutputDocumentContent	createEmptyOutputDocumentContent() Create a new, empty, OutputDocumentContent object.
protected void	outputAndSubmitDocument(Context pContext) Create the XHTML file for the Context's OutputDocumentContent and submit it using the DocumentSubmitterSession.
protected void	releaseContext(Context pContext) Release any resources claimed by the specified context.

Methods inherited from class atg.repository.search.indexing.BulkLoaderImpl

anyItemOfType, assetVersionsToRepositoryItems, bulkLoad, bulkLoad, bulkLoad, bulkLoad, bulkLoadWithRetry, createTestContext, deleteGenerationChanges, fetchItemsUsingThreadedQueue, generateTestDocument, getCurrentDate, getDevelopmentLines, getGcCallingRangeSize, getJaxbUnmarshaller, getPagedQuery, getPagedQuery, getPagedQueryOptions, getPagedQuerySize, getRepositoryIdPropertyDescriptor, isItemOfTypeInSet, loadIteration, loadPagedIteration, postIndexingCleanup, setCurrentDate, setGcCallingRangeSize, setJaxbUnmarshaller, setPagedQuerySize, uriMapFromAssetVersions

Methods inherited from class atg.repository.search.indexing.LoaderImpl

addActiveContext, adjustIncrementalQueue, afterSessionStart, beforeSessionEnd, cancelActiveContext, claimGeneration, createAdminServlet, createMembershipContextSet, deleteDocumentItem, deleteOrExcludeItem, doStartService, doStopService, getActiveContextStatuses, getArrayFromMultiRepoItems, getConfigStatePersister, getDocumentsPerTransaction, getIncrementalItemQueue, getLoggingInfoStatusCount, getTransactionManager, getUpdateActivityTimeMillis, getUpdateLastActivityTimeInSeparateThread, initContext, isConnectionRelated, isEchoDocumentsToStdout, isItemLoggingDebug, isPrettyPrint, isPropertyLoggingDebug, isSubTypeOfItemDesc, isTransactionPerDocument, nextQueuedUpdateActivity, popMembershipContexts, popMembershipContexts, processItem, processMetaProperty, processParentProperties, processProperties, processProperties, processTextProperty, pushMembershipContexts, pushMembershipContexts, pushMembershipContextsIfUsedByRepository, queueUpdateActivity, releaseGeneration, removeActiveContext, repositoryUsesMembershipContext, resetContextAfterDocument, setConfigStatePersister, setDocumentsPerTransaction, setEchoDocumentsToStdout, setIncrementalItemQueue, setItemLoggingDebug, setLoggingInfoStatusCount, setNextIncrementalGeneration, setPrettyPrint, setPropertyLoggingDebug, setTransactionPerDocument, setUpdateActivityTimeMillis, setUpdateLastActivityTimeInSeparateThread, splitPropertyValue, updateActivity

Methods inherited from class atg.nucleus.GenericService

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

Field Detail

CLASS_VERSION

public static java.lang.String CLASS_VERSION

Class version string

Constructor Detail

RecordStoreBulkLoaderImpl

public RecordStoreBulkLoaderImpl()

Method Detail

createEmptyOutputDocumentContent

protected atg.repository.search.indexing.OutputDocumentContent createEmptyOutputDocumentContent()

Description copied from class: LoaderImpl

Create a new, empty, OutputDocumentContent object.

Overrides:

createEmptyOutputDocumentContent in class LoaderImpl

createContext

protected Context createContext()

Create a new context. One context is created for each update (incremental or bulk).

Overrides:

createContext in class LoaderImpl

releaseContext

protected void releaseContext(Context pContext)

Description copied from class: LoaderImpl

Release any resources claimed by the specified context. Does not release any associated document submitter.

Overrides:

releaseContext in class LoaderImpl

Parameters:

pContext - The context to release.

outputAndSubmitDocument

protected void outputAndSubmitDocument(Context pContext)
                                throws IndexingException

Create the XHTML file for the Context's OutputDocumentContent and submit it using the DocumentSubmitterSession.

Overrides:

outputAndSubmitDocument in class LoaderImpl

Throws:

IndexingException