| Modifier and Type | Method and Description |
|---|---|
protected XMLContext |
XMLContext.beginTag(java.lang.String namespaceURI,
java.lang.String localName,
java.lang.String qName,
org.xml.sax.Attributes atts)
This method is meant to be extended by classes that extend this class.
|
protected XMLContext |
XMLWriterContext.beginTag(java.lang.String namespaceURI,
java.lang.String localName,
java.lang.String qName,
org.xml.sax.Attributes atts)
Start a child tag.
|
protected void |
XMLContext.endTag()
This method is meant to be extended by classes that extend this class
|
protected void |
XMLWriterContext.endTag()
End a child tag.
|
void |
XMLStream.parse(java.io.InputStream xmlInputStream) |
protected void |
XMLContext.tagContents(char[] ch,
int start,
int length)
This method is meant to be extended by classes that extend this class
|
| Modifier and Type | Method and Description |
|---|---|
int |
IncrementalIngester.PipelineAddEntryPoint.addOrReplaceDocumentWithException(java.lang.String documentURI,
RepositoryDocument document) |
int |
IncrementalIngester.OutputAddEntryPoint.addOrReplaceDocumentWithException(java.lang.String documentURI,
RepositoryDocument document) |
int |
IncrementalIngester.PipelineObjectWithVersions.addOrReplaceDocumentWithException(java.lang.String docKey,
java.lang.String componentHash,
java.lang.String documentURI,
RepositoryDocument document,
java.lang.String newDocumentVersion,
java.lang.String authorityNameString,
IOutputActivity finalActivity,
long ingestTime) |
boolean |
IncrementalIngester.OutputAddActivitiesWrapper.checkDateIndexable(java.util.Date date)
Detect if a date is acceptable downstream or not.
|
boolean |
IncrementalIngester.PipelineCheckFanout.checkDateIndexable(java.util.Date date) |
boolean |
IncrementalIngester.PipelineCheckEntryPoint.checkDateIndexable(java.util.Date date) |
boolean |
IncrementalIngester.PipelineAddFanout.checkDateIndexable(java.util.Date date) |
boolean |
IncrementalIngester.PipelineAddEntryPoint.checkDateIndexable(java.util.Date date) |
boolean |
IncrementalIngester.MonitoredAddActivityWrapper.checkDateIndexable(java.util.Date date)
Detect if a date is acceptable downstream or not.
|
boolean |
IncrementalIngester.PipelineObject.checkDateIndexable(java.util.Date date,
IOutputCheckActivity finalActivity) |
boolean |
IncrementalIngester.checkDateIndexable(IPipelineSpecification pipelineSpecification,
java.util.Date date,
IOutputCheckActivity activity)
Check if a date is indexable.
|
boolean |
IncrementalIngester.OutputAddActivitiesWrapper.checkDocumentIndexable(java.io.File localFile)
Pre-determine whether a document (passed here as a File object) is acceptable downstream.
|
boolean |
IncrementalIngester.PipelineCheckFanout.checkDocumentIndexable(java.io.File localFile) |
boolean |
IncrementalIngester.PipelineCheckEntryPoint.checkDocumentIndexable(java.io.File localFile) |
boolean |
IncrementalIngester.PipelineAddFanout.checkDocumentIndexable(java.io.File localFile) |
boolean |
IncrementalIngester.PipelineAddEntryPoint.checkDocumentIndexable(java.io.File localFile) |
boolean |
IncrementalIngester.MonitoredAddActivityWrapper.checkDocumentIndexable(java.io.File localFile)
Pre-determine whether a document (passed here as a File object) is acceptable downstream.
|
boolean |
IncrementalIngester.PipelineObject.checkDocumentIndexable(java.io.File localFile,
IOutputCheckActivity finalActivity) |
boolean |
IncrementalIngester.checkDocumentIndexable(IPipelineSpecification pipelineSpecification,
java.io.File localFile,
IOutputCheckActivity activity)
Check if a file is indexable.
|
boolean |
IncrementalIngester.checkLengthIndexable(IPipelineSpecification pipelineSpecification,
long length,
IOutputCheckActivity activity)
Pre-determine whether a document's length is indexable by this connector.
|
boolean |
IncrementalIngester.OutputAddActivitiesWrapper.checkLengthIndexable(long length)
Pre-determine whether a document's length is acceptable downstream.
|
boolean |
IncrementalIngester.PipelineCheckFanout.checkLengthIndexable(long length) |
boolean |
IncrementalIngester.PipelineCheckEntryPoint.checkLengthIndexable(long length) |
boolean |
IncrementalIngester.PipelineAddFanout.checkLengthIndexable(long length) |
boolean |
IncrementalIngester.PipelineAddEntryPoint.checkLengthIndexable(long length) |
boolean |
IncrementalIngester.MonitoredAddActivityWrapper.checkLengthIndexable(long length)
Pre-determine whether a document's length is acceptable downstream.
|
boolean |
IncrementalIngester.PipelineObject.checkLengthIndexable(long length,
IOutputCheckActivity finalActivity) |
boolean |
IncrementalIngester.checkMimeTypeIndexable(IPipelineSpecification pipelineSpecification,
java.lang.String mimeType,
IOutputCheckActivity activity)
Check if a mime type is indexable.
|
boolean |
IncrementalIngester.OutputAddActivitiesWrapper.checkMimeTypeIndexable(java.lang.String mimeType)
Detect if a mime type is acceptable downstream or not.
|
boolean |
IncrementalIngester.PipelineCheckFanout.checkMimeTypeIndexable(java.lang.String mimeType) |
boolean |
IncrementalIngester.PipelineCheckEntryPoint.checkMimeTypeIndexable(java.lang.String mimeType) |
boolean |
IncrementalIngester.PipelineAddFanout.checkMimeTypeIndexable(java.lang.String mimeType) |
boolean |
IncrementalIngester.PipelineAddEntryPoint.checkMimeTypeIndexable(java.lang.String mimeType) |
boolean |
IncrementalIngester.MonitoredAddActivityWrapper.checkMimeTypeIndexable(java.lang.String mimeType)
Detect if a mime type is acceptable downstream or not.
|
boolean |
IncrementalIngester.PipelineObject.checkMimeTypeIndexable(java.lang.String mimeType,
IOutputCheckActivity finalActivity) |
boolean |
IncrementalIngester.checkURLIndexable(IPipelineSpecification pipelineSpecification,
java.lang.String url,
IOutputCheckActivity activity)
Pre-determine whether a document's URL is indexable by this connector.
|
boolean |
IncrementalIngester.OutputAddActivitiesWrapper.checkURLIndexable(java.lang.String url)
Pre-determine whether a document's URL is acceptable downstream.
|
boolean |
IncrementalIngester.PipelineCheckFanout.checkURLIndexable(java.lang.String uri) |
boolean |
IncrementalIngester.PipelineCheckEntryPoint.checkURLIndexable(java.lang.String uri) |
boolean |
IncrementalIngester.PipelineAddFanout.checkURLIndexable(java.lang.String uri) |
boolean |
IncrementalIngester.PipelineAddEntryPoint.checkURLIndexable(java.lang.String uri) |
boolean |
IncrementalIngester.MonitoredAddActivityWrapper.checkURLIndexable(java.lang.String url)
Pre-determine whether a document's URL is acceptable downstream.
|
boolean |
IncrementalIngester.PipelineObject.checkURLIndexable(java.lang.String uri,
IOutputCheckActivity finalActivity) |
void |
IncrementalIngester.documentDelete(IPipelineConnections pipelineConnections,
java.lang.String identifierClass,
java.lang.String identifierHash,
IOutputRemoveActivity activities)
Delete a document from the search engine index.
|
void |
IncrementalIngester.documentDeleteMultiple(IPipelineConnections[] pipelineConnections,
java.lang.String[] identifierClasses,
java.lang.String[] identifierHashes,
IOutputRemoveActivity activities)
Delete multiple documents from the search engine index.
|
void |
IncrementalIngester.documentDeleteMultiple(IPipelineConnections pipelineConnections,
java.lang.String[] identifierClasses,
java.lang.String[] identifierHashes,
IOutputRemoveActivity originalActivities)
Delete multiple documents from the search engine index.
|
boolean |
IncrementalIngester.documentIngest(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions,
java.lang.String identifierClass,
java.lang.String identifierHash,
java.lang.String componentHash,
java.lang.String documentVersion,
java.lang.String authorityName,
RepositoryDocument data,
long ingestTime,
java.lang.String documentURI,
IOutputActivity activities)
Ingest a document.
|
void |
IncrementalIngester.documentNoData(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions,
java.lang.String identifierClass,
java.lang.String identifierHash,
java.lang.String componentHash,
java.lang.String documentVersion,
java.lang.String authorityName,
long recordTime,
IOutputActivity activities)
Remove a document from specified indexes, just as if an empty document
was indexed, and record the necessary version information.
|
void |
IncrementalIngester.documentRemove(IPipelineConnections pipelineConnections,
java.lang.String identifierClass,
java.lang.String identifierHash,
java.lang.String componentHash,
IOutputRemoveActivity activities)
Remove a document component from the search engine index.
|
void |
IncrementalIngester.documentRemoveMultiple(IPipelineConnections pipelineConnections,
java.lang.String[] identifierClasses,
java.lang.String[] identifierHashes,
java.lang.String componentHash,
IOutputRemoveActivity activities)
Remove multiple document components from the search engine index.
|
VersionContext |
IncrementalIngester.getOutputDescription(IOutputConnection outputConnection,
Specification spec)
Get an output version string for a document.
|
VersionContext |
IncrementalIngester.getTransformationDescription(ITransformationConnection transformationConnection,
Specification spec)
Get transformation version string for a document.
|
void |
IncrementalIngester.OutputAddActivitiesWrapper.noDocument()
Send NO document via the pipeline to the next output connection.
|
void |
IncrementalIngester.PipelineAddFanout.noDocument()
Send NO document via the pipeline to the next output connection.
|
void |
IncrementalIngester.PipelineAddEntryPoint.noDocument() |
void |
IncrementalIngester.OutputAddEntryPoint.noDocument() |
void |
IncrementalIngester.MonitoredAddActivityWrapper.noDocument()
Send NO document via the pipeline to the next output connection.
|
void |
IncrementalIngester.PipelineObjectWithVersions.noDocument(java.lang.String docKey,
java.lang.String componentHash,
java.lang.String newDocumentVersion,
java.lang.String authorityNameString,
IOutputActivity finalActivity,
long ingestTime) |
protected void |
IncrementalIngester.removeDocument(IOutputConnection connection,
java.lang.String documentURI,
java.lang.String outputDescription,
IOutputRemoveActivity activities)
Remove document, using the specified output connection, via the standard pool.
|
int |
IncrementalIngester.OutputAddActivitiesWrapper.sendDocument(java.lang.String documentURI,
RepositoryDocument document)
Send a document via the pipeline to the next output connection.
|
int |
IncrementalIngester.PipelineAddFanout.sendDocument(java.lang.String documentURI,
RepositoryDocument document)
Send a document via the pipeline to the next output connection.
|
int |
IncrementalIngester.MonitoredAddActivityWrapper.sendDocument(java.lang.String documentURI,
RepositoryDocument document)
Send a document via the pipeline to the next output connection.
|
| Modifier and Type | Method and Description |
|---|---|
int |
IPipelineConnector.addOrReplaceDocumentWithException(java.lang.String documentURI,
VersionContext pipelineDescription,
RepositoryDocument document,
java.lang.String authorityNameString,
IOutputAddActivity activities)
Add (or replace) a document in the output data store using the connector.
|
boolean |
IOutputCheckActivity.checkDateIndexable(java.util.Date date)
Detect if a document date is acceptable downstream or not.
|
boolean |
IIncrementalIngester.checkDateIndexable(IPipelineSpecification pipelineSpecification,
java.util.Date date,
IOutputCheckActivity activity)
Check if a document date is indexable.
|
boolean |
IPipelineConnector.checkDateIndexable(VersionContext pipelineDescription,
java.util.Date date,
IOutputCheckActivity checkActivity)
Detect if a document date is acceptable or not.
|
boolean |
IOutputCheckActivity.checkDocumentIndexable(java.io.File localFile)
Pre-determine whether a document (passed here as a File object) is acceptable downstream.
|
boolean |
ITransformationCheckActivity.checkDocumentIndexable(java.io.File localFile)
Pre-determine whether a document (passed here as a File object) is acceptable downstream.
|
boolean |
IIncrementalIngester.checkDocumentIndexable(IPipelineSpecification pipelineSpecification,
java.io.File localFile,
IOutputCheckActivity activity)
Check if a file is indexable.
|
boolean |
IPipelineConnector.checkDocumentIndexable(VersionContext pipelineDescription,
java.io.File localFile,
IOutputCheckActivity checkActivity)
Pre-determine whether a document (passed here as a File object) is acceptable or not.
|
boolean |
IIncrementalIngester.checkLengthIndexable(IPipelineSpecification pipelineSpecification,
long length,
IOutputCheckActivity activity)
Pre-determine whether a document's length is indexable by this connector.
|
boolean |
IOutputCheckActivity.checkLengthIndexable(long length)
Pre-determine whether a document's length is acceptable downstream.
|
boolean |
ITransformationCheckActivity.checkLengthIndexable(long length)
Pre-determine whether a document's length is acceptable downstream.
|
boolean |
IPipelineConnector.checkLengthIndexable(VersionContext pipelineDescription,
long length,
IOutputCheckActivity checkActivity)
Pre-determine whether a document's length is acceptable.
|
boolean |
IIncrementalIngester.checkMimeTypeIndexable(IPipelineSpecification pipelineSpecification,
java.lang.String mimeType,
IOutputCheckActivity activity)
Check if a mime type is indexable.
|
boolean |
IOutputCheckActivity.checkMimeTypeIndexable(java.lang.String mimeType)
Detect if a mime type is acceptable downstream or not.
|
boolean |
ITransformationCheckActivity.checkMimeTypeIndexable(java.lang.String mimeType)
Detect if a mime type is acceptable downstream or not.
|
boolean |
IPipelineConnector.checkMimeTypeIndexable(VersionContext pipelineDescription,
java.lang.String mimeType,
IOutputCheckActivity checkActivity)
Detect if a mime type is acceptable or not.
|
boolean |
IIncrementalIngester.checkURLIndexable(IPipelineSpecification pipelineSpecification,
java.lang.String url,
IOutputCheckActivity activity)
Pre-determine whether a document's URL is indexable by this connector.
|
boolean |
IOutputCheckActivity.checkURLIndexable(java.lang.String url)
Pre-determine whether a document's URL is acceptable downstream.
|
boolean |
ITransformationCheckActivity.checkURLIndexable(java.lang.String url)
Pre-determine whether a document's URL is acceptable downstream.
|
boolean |
IPipelineConnector.checkURLIndexable(VersionContext pipelineDescription,
java.lang.String url,
IOutputCheckActivity checkActivity)
Pre-determine whether a document's URL is acceptable.
|
void |
IIncrementalIngester.documentDelete(IPipelineConnections pipelineConnections,
java.lang.String identifierClass,
java.lang.String identifierHash,
IOutputRemoveActivity activities)
Delete a document, and all its components, from the search engine index.
|
void |
IIncrementalIngester.documentDeleteMultiple(IPipelineConnections[] pipelineConnections,
java.lang.String[] identifierClasses,
java.lang.String[] identifierHashes,
IOutputRemoveActivity activities)
Delete multiple documents, and their components, from the search engine index.
|
void |
IIncrementalIngester.documentDeleteMultiple(IPipelineConnections pipelineConnections,
java.lang.String[] identifierClasses,
java.lang.String[] identifierHashes,
IOutputRemoveActivity activities)
Delete multiple documents, and their components, from the search engine index.
|
boolean |
IIncrementalIngester.documentIngest(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions,
java.lang.String identifierClass,
java.lang.String identifierHash,
java.lang.String componentHash,
java.lang.String documentVersion,
java.lang.String authorityName,
RepositoryDocument data,
long ingestTime,
java.lang.String documentURI,
IOutputActivity activities)
Ingest a document.
|
void |
IIncrementalIngester.documentNoData(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions,
java.lang.String identifierClass,
java.lang.String identifierHash,
java.lang.String componentHash,
java.lang.String documentVersion,
java.lang.String authorityName,
long recordTime,
IOutputActivity activities)
Remove a document from specified indexes, just as if an empty document
was indexed, and record the necessary version information.
|
void |
IIncrementalIngester.documentRemove(IPipelineConnections pipelineConnections,
java.lang.String identifierClass,
java.lang.String identifierHash,
java.lang.String componentHash,
IOutputRemoveActivity activities)
Remove a document component from the search engine index.
|
void |
IIncrementalIngester.documentRemoveMultiple(IPipelineConnections pipelineConnections,
java.lang.String[] identifierClasses,
java.lang.String[] identifierHashes,
java.lang.String componentHash,
IOutputRemoveActivity activities)
Remove multiple document components from the search engine index.
|
VersionContext |
IIncrementalIngester.getOutputDescription(IOutputConnection outputConnection,
Specification spec)
Get an output version string for a document.
|
VersionContext |
IPipelineConnector.getPipelineDescription(Specification spec)
Get a pipeline version object, given a pipeline specification object.
|
VersionContext |
IIncrementalIngester.getTransformationDescription(ITransformationConnection transformationConnection,
Specification spec)
Get transformation version string for a document.
|
void |
IOutputAddActivity.noDocument()
Send NO document via the pipeline to the next output connection.
|
void |
IOutputConnector.noteJobComplete(IOutputNotifyActivity activities)
Notify the connector of a completed job.
|
void |
IOutputConnector.removeDocument(java.lang.String documentURI,
java.lang.String outputDescription,
IOutputRemoveActivity activities)
Remove a document using the connector.
|
int |
IOutputAddActivity.sendDocument(java.lang.String documentURI,
RepositoryDocument document)
Send a document via the pipeline to the next output connection.
|
| Modifier and Type | Method and Description |
|---|---|
int |
BaseOutputConnector.addOrReplaceDocumentWithException(java.lang.String documentURI,
VersionContext pipelineDescription,
RepositoryDocument document,
java.lang.String authorityNameString,
IOutputAddActivity activities)
Add (or replace) a document in the output data store using the connector.
|
boolean |
BaseOutputConnector.checkDateIndexable(VersionContext pipelineDescription,
java.util.Date date,
IOutputCheckActivity checkActivity)
Detect if a document date is acceptable or not.
|
boolean |
BaseOutputConnector.checkDocumentIndexable(VersionContext pipelineDescription,
java.io.File localFile,
IOutputCheckActivity checkActivity)
Pre-determine whether a document (passed here as a File object) is acceptable or not.
|
boolean |
BaseOutputConnector.checkLengthIndexable(VersionContext pipelineDescription,
long length,
IOutputCheckActivity checkActivity)
Pre-determine whether a document's length is acceptable.
|
boolean |
BaseOutputConnector.checkMimeTypeIndexable(VersionContext pipelineDescription,
java.lang.String mimeType,
IOutputCheckActivity checkActivity)
Detect if a mime type is acceptable or not.
|
boolean |
BaseOutputConnector.checkURLIndexable(VersionContext pipelineDescription,
java.lang.String url,
IOutputCheckActivity checkActivity)
Pre-determine whether a document's URL is acceptable.
|
VersionContext |
BaseOutputConnector.getPipelineDescription(Specification spec)
Get a pipeline version string, given a pipeline specification object.
|
void |
BaseOutputConnector.noteJobComplete(IOutputNotifyActivity activities)
Notify the connector of a completed job.
|
void |
BaseOutputConnector.removeDocument(java.lang.String documentURI,
java.lang.String outputDescription,
IOutputRemoveActivity activities)
Remove a document using the connector.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
ManifoldCF.createServiceInterruptionNode(Configuration output,
ServiceInterruption e)
Handle a service interruption, by converting it to a serviceinterruption node.
|
| Modifier and Type | Method and Description |
|---|---|
int |
BaseTransformationConnector.addOrReplaceDocumentWithException(java.lang.String documentURI,
VersionContext pipelineDescription,
RepositoryDocument document,
java.lang.String authorityNameString,
IOutputAddActivity activities)
Add (or replace) a document in the output data store using the connector.
|
boolean |
BaseTransformationConnector.checkDateIndexable(VersionContext pipelineDescription,
java.util.Date date,
IOutputCheckActivity checkActivity)
Detect if a document date is acceptable or not.
|
boolean |
BaseTransformationConnector.checkDocumentIndexable(VersionContext pipelineDescription,
java.io.File localFile,
IOutputCheckActivity checkActivity)
Pre-determine whether a document (passed here as a File object) is acceptable or not.
|
boolean |
BaseTransformationConnector.checkLengthIndexable(VersionContext pipelineDescription,
long length,
IOutputCheckActivity checkActivity)
Pre-determine whether a document's length is acceptable.
|
boolean |
BaseTransformationConnector.checkMimeTypeIndexable(VersionContext pipelineDescription,
java.lang.String mimeType,
IOutputCheckActivity checkActivity)
Detect if a mime type is acceptable or not.
|
boolean |
BaseTransformationConnector.checkURLIndexable(VersionContext pipelineDescription,
java.lang.String url,
IOutputCheckActivity checkActivity)
Pre-determine whether a document's URL is acceptable.
|
VersionContext |
BaseTransformationConnector.getPipelineDescription(Specification spec)
Get a pipeline version string, given a pipeline specification object.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
BaseRepositoryConnector.addSeedDocuments(ISeedingActivity activities,
Specification spec,
java.lang.String lastSeedVersion,
long seedTime,
int jobMode)
Queue "seed" documents.
|
void |
BaseRepositoryConnector.processDocuments(java.lang.String[] documentIdentifiers,
IExistingVersions statuses,
Specification spec,
IProcessActivity activities,
int jobMode,
boolean usesDefaultAuthority)
Process a set of documents.
|
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
IRepositoryConnector.addSeedDocuments(ISeedingActivity activities,
Specification spec,
java.lang.String lastSeedVersion,
long seedTime,
int jobMode)
Queue "seed" documents.
|
boolean |
IFingerprintActivity.checkDateIndexable(java.util.Date date)
Detect if a date is indexable or not.
|
boolean |
IFingerprintActivity.checkDocumentIndexable(java.io.File localFile)
Check whether a document is indexable by the currently specified output connector.
|
void |
IAbortActivity.checkJobStillActive()
Check whether current job is still active.
|
boolean |
IFingerprintActivity.checkLengthIndexable(long length)
Check whether a document of a specific length is indexable by the currently specified output connector.
|
boolean |
IFingerprintActivity.checkMimeTypeIndexable(java.lang.String mimeType)
Detect if a mime type is indexable or not.
|
boolean |
IFingerprintActivity.checkURLIndexable(java.lang.String url)
Pre-determine whether a document's URL is indexable by this connector.
|
void |
IProcessActivity.ingestDocumentWithException(java.lang.String documentIdentifier,
java.lang.String version,
java.lang.String documentURI,
RepositoryDocument data)
Ingest the current document.
|
void |
IProcessActivity.ingestDocumentWithException(java.lang.String documentIdentifier,
java.lang.String componentIdentifier,
java.lang.String version,
java.lang.String documentURI,
RepositoryDocument data)
Ingest the current document.
|
void |
IProcessActivity.noDocument(java.lang.String documentIdentifier,
java.lang.String version)
Remove the specified document from the search engine index, and update the
recorded version information for the document.
|
void |
IProcessActivity.noDocument(java.lang.String documentIdentifier,
java.lang.String componentIdentifier,
java.lang.String version)
Remove the specified document from the search engine index, and update the
recorded version information for the document.
|
void |
INotificationConnector.notifyOfJobEnd(Specification spec)
Notify of job end
|
void |
INotificationConnector.notifyOfJobStopErrorAbort(Specification spec)
Notify of job stop due to error abort.
|
void |
INotificationConnector.notifyOfJobStopManualAbort(Specification spec)
Notify of job stop due to manual abort.
|
void |
INotificationConnector.notifyOfJobStopManualPause(Specification spec)
Notify of job stop due to manual pause.
|
void |
INotificationConnector.notifyOfJobStopRestart(Specification spec)
Notify of job stop due to restart.
|
void |
INotificationConnector.notifyOfJobStopSchedulePause(Specification spec)
Notify of job stop due to schedule pause.
|
void |
IRepositoryConnector.processDocuments(java.lang.String[] documentIdentifiers,
IExistingVersions statuses,
Specification spec,
IProcessActivity activities,
int jobMode,
boolean usesDefaultAuthority)
Process a set of documents.
|
void |
IProcessActivity.removeDocument(java.lang.String documentIdentifier)
Remove the specified document primary component permanently from the search engine index,
and from the status table.
|
| Modifier and Type | Method and Description |
|---|---|
void |
BaseNotificationConnector.notifyOfJobEnd(Specification spec)
Notify of job end.
|
void |
BaseNotificationConnector.notifyOfJobStop(Specification spec)
Notify of job stop.
|
void |
BaseNotificationConnector.notifyOfJobStopErrorAbort(Specification spec)
Notify of job stop due to error abort.
|
void |
BaseNotificationConnector.notifyOfJobStopManualAbort(Specification spec)
Notify of job stop due to manual abort.
|
void |
BaseNotificationConnector.notifyOfJobStopManualPause(Specification spec)
Notify of job stop due to manual pause.
|
void |
BaseNotificationConnector.notifyOfJobStopRestart(Specification spec)
Notify of job stop due to restart.
|
void |
BaseNotificationConnector.notifyOfJobStopSchedulePause(Specification spec)
Notify of job stop due to schedule pause.
|
| Modifier and Type | Field and Description |
|---|---|
protected ServiceInterruption |
JobNotificationThread.Disposition.serviceInterruption |
| Modifier and Type | Method and Description |
|---|---|
ServiceInterruption |
JobNotificationThread.Disposition.getServiceInterruption() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
WorkerThread.ProcessActivity.checkDateIndexable(java.util.Date date)
Detect if a date is indexable or not.
|
boolean |
WorkerThread.CheckActivity.checkDateIndexable(java.util.Date date)
Detect if a date is acceptable downstream or not.
|
boolean |
WorkerThread.ProcessActivity.checkDocumentIndexable(java.io.File localFile)
Check whether a document is indexable by the currently specified output connector.
|
boolean |
WorkerThread.CheckActivity.checkDocumentIndexable(java.io.File localFile)
Pre-determine whether a document (passed here as a File object) is acceptable downstream.
|
void |
SeedingActivity.checkJobStillActive()
Check whether current job is still active.
|
void |
WorkerThread.ProcessActivity.checkJobStillActive()
Check whether current job is still active.
|
boolean |
WorkerThread.ProcessActivity.checkLengthIndexable(long length)
Check whether a document of a specified length is indexable by the currently specified output connector.
|
boolean |
WorkerThread.CheckActivity.checkLengthIndexable(long length)
Pre-determine whether a document's length is acceptable downstream.
|
boolean |
WorkerThread.ProcessActivity.checkMimeTypeIndexable(java.lang.String mimeType)
Check whether a mime type is indexable by the currently specified output connector.
|
boolean |
WorkerThread.CheckActivity.checkMimeTypeIndexable(java.lang.String mimeType)
Detect if a mime type is acceptable downstream or not.
|
boolean |
WorkerThread.ProcessActivity.checkURLIndexable(java.lang.String url)
Pre-determine whether a document's URL is indexable by this connector.
|
boolean |
WorkerThread.CheckActivity.checkURLIndexable(java.lang.String url)
Pre-determine whether a document's URL is acceptable downstream.
|
void |
WorkerThread.ProcessActivity.ingestDocumentWithException(java.lang.String documentIdentifier,
java.lang.String version,
java.lang.String documentURI,
RepositoryDocument data)
Ingest the current document.
|
void |
WorkerThread.ProcessActivity.ingestDocumentWithException(java.lang.String documentIdentifier,
java.lang.String componentIdentifier,
java.lang.String version,
java.lang.String documentURI,
RepositoryDocument data)
Ingest the current document.
|
void |
WorkerThread.OutputActivity.noDocument()
Send NO document via the pipeline to the next output connection.
|
void |
WorkerThread.ProcessActivity.noDocument(java.lang.String documentIdentifier,
java.lang.String version)
Remove the specified document from the search engine index, while keeping track of the version information
for it (to reduce churn).
|
void |
WorkerThread.ProcessActivity.noDocument(java.lang.String documentIdentifier,
java.lang.String componentIdentifier,
java.lang.String version)
Remove the specified document from the search engine index, and update the
recorded version information for the document.
|
void |
WorkerThread.ProcessActivity.removeDocument(java.lang.String documentIdentifier)
Remove the specified document primary component permanently from the search engine index,
and from the status table.
|
int |
WorkerThread.OutputActivity.sendDocument(java.lang.String documentURI,
RepositoryDocument document)
Send a document via the pipeline to the next output connection.
|
| Constructor and Description |
|---|
Disposition(ServiceInterruption serviceInterruption) |
| Constructor and Description |
|---|
PipelineSpecification(IPipelineConnections connections,
IJobDescription job,
IIncrementalIngester ingester) |