org.apache.manifoldcf.agents.incrementalingest

Class IncrementalIngester.PipelineObject

java.lang.Object

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

Direct Known Subclasses:

IncrementalIngester.PipelineObjectWithVersions

Enclosing class:

IncrementalIngester

protected class IncrementalIngester.PipelineObject
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
IOutputConnector[]	outputConnectors
IPipelineSpecification	pipelineConnections
ITransformationConnector[]	transformationConnectors

Constructor Summary

Constructors

Constructor and Description
PipelineObject(IPipelineSpecification pipelineConnections, ITransformationConnector[] transformationConnectors, IOutputConnector[] outputConnectors)

Method Summary

Modifier and Type	Method and Description
protected IncrementalIngester.PipelineCheckFanout	buildCheckPipeline(IOutputCheckActivity finalActivity)
boolean	checkDateIndexable(java.util.Date date, IOutputCheckActivity finalActivity)
boolean	checkDocumentIndexable(java.io.File localFile, IOutputCheckActivity finalActivity)
boolean	checkLengthIndexable(long length, IOutputCheckActivity finalActivity)
boolean	checkMimeTypeIndexable(java.lang.String mimeType, IOutputCheckActivity finalActivity)
boolean	checkURLIndexable(java.lang.String uri, IOutputCheckActivity finalActivity)
void	release()

Methods inherited from class java.lang.Object

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

Field Detail

pipelineConnections

public final IPipelineSpecification pipelineConnections

outputConnectors

public final IOutputConnector[] outputConnectors

transformationConnectors

public final ITransformationConnector[] transformationConnectors

Constructor Detail

PipelineObject

public PipelineObject(IPipelineSpecification pipelineConnections,
                      ITransformationConnector[] transformationConnectors,
                      IOutputConnector[] outputConnectors)

Method Detail

checkDateIndexable

public boolean checkDateIndexable(java.util.Date date,
                                  IOutputCheckActivity finalActivity)
                           throws ManifoldCFException,
                                  ServiceInterruption

Throws:

ManifoldCFException

ServiceInterruption

checkMimeTypeIndexable

public boolean checkMimeTypeIndexable(java.lang.String mimeType,
                                      IOutputCheckActivity finalActivity)
                               throws ManifoldCFException,
                                      ServiceInterruption

Throws:

ManifoldCFException

ServiceInterruption

checkDocumentIndexable

public boolean checkDocumentIndexable(java.io.File localFile,
                                      IOutputCheckActivity finalActivity)
                               throws ManifoldCFException,
                                      ServiceInterruption

Throws:

ManifoldCFException

ServiceInterruption

checkLengthIndexable

public boolean checkLengthIndexable(long length,
                                    IOutputCheckActivity finalActivity)
                             throws ManifoldCFException,
                                    ServiceInterruption

Throws:

ManifoldCFException

ServiceInterruption

checkURLIndexable

public boolean checkURLIndexable(java.lang.String uri,
                                 IOutputCheckActivity finalActivity)
                          throws ManifoldCFException,
                                 ServiceInterruption

Throws:

ManifoldCFException

ServiceInterruption

release

public void release()
             throws ManifoldCFException

Throws:

ManifoldCFException

buildCheckPipeline

protected IncrementalIngester.PipelineCheckFanout buildCheckPipeline(IOutputCheckActivity finalActivity)