protected class IncrementalIngester.PipelineObjectWithVersions extends IncrementalIngester.PipelineObject
| Modifier and Type | Field and Description |
|---|---|
protected IPipelineSpecificationWithVersions |
pipelineSpecificationWithVersions |
outputConnectors, pipelineConnections, transformationConnectors| Constructor and Description |
|---|
IncrementalIngester.PipelineObjectWithVersions(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions,
ITransformationConnector[] transformationConnectors,
IOutputConnector[] outputConnectors) |
| Modifier and Type | Method and Description |
|---|---|
int |
addOrReplaceDocumentWithException(String docKey,
String componentHash,
String documentURI,
RepositoryDocument document,
String newDocumentVersion,
String newParameterVersion,
String authorityNameString,
IOutputActivity finalActivity,
long ingestTime) |
protected IncrementalIngester.PipelineAddFanout |
buildAddPipeline(IOutputActivity finalActivity,
String newDocumentVersion,
String newParameterVersion,
String newAuthorityNameString,
long ingestTime,
String docKey,
String componentHash) |
void |
noDocument(String docKey,
String componentHash,
String newDocumentVersion,
String newParameterVersion,
String authorityNameString,
IOutputActivity finalActivity,
long ingestTime) |
buildCheckPipeline, checkDateIndexable, checkDocumentIndexable, checkLengthIndexable, checkMimeTypeIndexable, checkURLIndexable, releaseprotected final IPipelineSpecificationWithVersions pipelineSpecificationWithVersions
public IncrementalIngester.PipelineObjectWithVersions(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions, ITransformationConnector[] transformationConnectors, IOutputConnector[] outputConnectors)
public int addOrReplaceDocumentWithException(String docKey, String componentHash, String documentURI, RepositoryDocument document, String newDocumentVersion, String newParameterVersion, String authorityNameString, IOutputActivity finalActivity, long ingestTime) throws ManifoldCFException, ServiceInterruption, IOException
public void noDocument(String docKey, String componentHash, String newDocumentVersion, String newParameterVersion, String authorityNameString, IOutputActivity finalActivity, long ingestTime) throws ManifoldCFException, ServiceInterruption
protected IncrementalIngester.PipelineAddFanout buildAddPipeline(IOutputActivity finalActivity, String newDocumentVersion, String newParameterVersion, String newAuthorityNameString, long ingestTime, String docKey, String componentHash)