org.apache.manifoldcf.agents.incrementalingest

Class IncrementalIngester.PipelineObjectWithVersions

java.lang.Object

org.apache.manifoldcf.agents.incrementalingest.IncrementalIngester.PipelineObject

org.apache.manifoldcf.agents.incrementalingest.IncrementalIngester.PipelineObjectWithVersions

Enclosing class:

IncrementalIngester

protected class IncrementalIngester.PipelineObjectWithVersions
extends IncrementalIngester.PipelineObject

Field Summary

Fields

Modifier and Type	Field and Description
protected IPipelineSpecificationWithVersions	pipelineSpecificationWithVersions

Fields inherited from class org.apache.manifoldcf.agents.incrementalingest.IncrementalIngester.PipelineObject

outputConnectors, pipelineConnections, transformationConnectors

Constructor Summary

Constructors

Constructor and Description
PipelineObjectWithVersions(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions, ITransformationConnector[] transformationConnectors, IOutputConnector[] outputConnectors)

Method Summary

Modifier and Type	Method and Description
int	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)
protected IncrementalIngester.PipelineAddFanout	buildAddPipeline(IOutputActivity finalActivity, java.lang.String newDocumentVersion, java.lang.String newAuthorityNameString, long ingestTime, java.lang.String docKey, java.lang.String componentHash)
void	noDocument(java.lang.String docKey, java.lang.String componentHash, java.lang.String newDocumentVersion, java.lang.String authorityNameString, IOutputActivity finalActivity, long ingestTime)

Methods inherited from class org.apache.manifoldcf.agents.incrementalingest.IncrementalIngester.PipelineObject

buildCheckPipeline, checkDateIndexable, checkDocumentIndexable, checkLengthIndexable, checkMimeTypeIndexable, checkURLIndexable, release

Methods inherited from class java.lang.Object

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

Field Detail

pipelineSpecificationWithVersions

protected final IPipelineSpecificationWithVersions pipelineSpecificationWithVersions

Constructor Detail

PipelineObjectWithVersions

public PipelineObjectWithVersions(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions,
                                  ITransformationConnector[] transformationConnectors,
                                  IOutputConnector[] outputConnectors)

Method Detail

addOrReplaceDocumentWithException

public int 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)
                                      throws ManifoldCFException,
                                             ServiceInterruption,
                                             java.io.IOException

Throws:

ManifoldCFException

ServiceInterruption

java.io.IOException

noDocument

public void noDocument(java.lang.String docKey,
                       java.lang.String componentHash,
                       java.lang.String newDocumentVersion,
                       java.lang.String authorityNameString,
                       IOutputActivity finalActivity,
                       long ingestTime)
                throws ManifoldCFException,
                       ServiceInterruption

Throws:

ManifoldCFException

ServiceInterruption

buildAddPipeline

protected IncrementalIngester.PipelineAddFanout buildAddPipeline(IOutputActivity finalActivity,
                                                                 java.lang.String newDocumentVersion,
                                                                 java.lang.String newAuthorityNameString,
                                                                 long ingestTime,
                                                                 java.lang.String docKey,
                                                                 java.lang.String componentHash)