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, release
protected 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)