Class PipelineSpecificationWithVersions
- java.lang.Object
-
- org.apache.manifoldcf.crawler.system.PipelineSpecificationWithVersions
-
- All Implemented Interfaces:
IPipelineConnections
,IPipelineSpecification
,IPipelineSpecificationBasic
,IPipelineSpecificationWithVersions
public class PipelineSpecificationWithVersions extends java.lang.Object implements IPipelineSpecificationWithVersions
Class which handles pipeline specifications, including both new versions and old versions.
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.String
componentIDHash
protected IPipelineSpecification
pipelineSpecification
protected QueuedDocument
queuedDocument
-
Fields inherited from interface org.apache.manifoldcf.agents.interfaces.IPipelineSpecificationWithVersions
_rcsid
-
-
Constructor Summary
Constructors Constructor Description PipelineSpecificationWithVersions(IPipelineSpecification pipelineSpecification, QueuedDocument queuedDocument, java.lang.String componentIDHash)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
checkStageOutputConnection(int stage)
Check if a stage is an output stage.java.lang.String
getAuthorityNameString(int index)
For a given output index, return an authority name string.java.lang.Integer
getOutputConnectionIndex(int stage)
Get the index of the output connection corresponding to a specific pipeline stage.java.lang.String[]
getOutputConnectionNames()
Get the output connection names mentioned by the IPipelineSpecification object.IOutputConnection[]
getOutputConnections()
Get the output connection instances mentioned by the IPipelineSpecification object.int
getOutputCount()
Return the number of output connections.java.lang.String
getOutputDocumentVersionString(int index)
For a given output index, return a document version string.int
getOutputStage(int index)
Given an output index, return the stage number for that output.java.lang.String
getOutputTransformationVersionString(int index)
For a given output index, return a transformation version string.java.lang.String
getOutputVersionString(int index)
For a given output index, return an output version string.int[]
getStageChildren(int stage)
Find children of a given pipeline stage.java.lang.String
getStageConnectionName(int stage)
Get the connection name for a pipeline stage.int
getStageCount()
Get a count of all stages.VersionContext
getStageDescriptionString(int stage)
Get the description string for a pipeline stage.int
getStageParent(int stage)
Find parent of a given pipeline stage.protected DocumentIngestStatus
getStatus(int index)
java.lang.Integer
getTransformationConnectionIndex(int stage)
Get the index of the transformation connection corresponding to a specific pipeline stage.java.lang.String[]
getTransformationConnectionNames()
Get the transformation connection names mentioned by the IPipelineSpecification object.ITransformationConnection[]
getTransformationConnections()
Get the transformation connection instances mentioned by the IPipelineSpecification object.
-
-
-
Field Detail
-
pipelineSpecification
protected final IPipelineSpecification pipelineSpecification
-
queuedDocument
protected final QueuedDocument queuedDocument
-
componentIDHash
protected final java.lang.String componentIDHash
-
-
Constructor Detail
-
PipelineSpecificationWithVersions
public PipelineSpecificationWithVersions(IPipelineSpecification pipelineSpecification, QueuedDocument queuedDocument, java.lang.String componentIDHash)
-
-
Method Detail
-
getStatus
protected DocumentIngestStatus getStatus(int index)
-
getStageCount
public int getStageCount()
Get a count of all stages.- Specified by:
getStageCount
in interfaceIPipelineSpecificationBasic
- Returns:
- the total count of all stages.
-
getStageChildren
public int[] getStageChildren(int stage)
Find children of a given pipeline stage. Pass -1 to find the children of the root stage.- Specified by:
getStageChildren
in interfaceIPipelineSpecificationBasic
- Parameters:
stage
- is the stage index to get the children of.- Returns:
- the pipeline stages that represent those children.
-
getStageParent
public int getStageParent(int stage)
Find parent of a given pipeline stage. Returns -1 if there's no parent (it's the root).- Specified by:
getStageParent
in interfaceIPipelineSpecificationBasic
- Parameters:
stage
- is the stage index to get the parent of.- Returns:
- the pipeline stage that is the parent, or -1.
-
getStageConnectionName
public java.lang.String getStageConnectionName(int stage)
Get the connection name for a pipeline stage.- Specified by:
getStageConnectionName
in interfaceIPipelineSpecificationBasic
- Parameters:
stage
- is the stage to get the connection name for.- Returns:
- the connection name for that stage.
-
checkStageOutputConnection
public boolean checkStageOutputConnection(int stage)
Check if a stage is an output stage.- Specified by:
checkStageOutputConnection
in interfaceIPipelineSpecificationBasic
- Parameters:
stage
- is the stage to check.- Returns:
- true if the stage represents an output connection.
-
getOutputCount
public int getOutputCount()
Return the number of output connections.- Specified by:
getOutputCount
in interfaceIPipelineSpecificationBasic
- Returns:
- the total number of output connections in this specification.
-
getOutputStage
public int getOutputStage(int index)
Given an output index, return the stage number for that output.- Specified by:
getOutputStage
in interfaceIPipelineSpecificationBasic
- Parameters:
index
- is the output connection index.- Returns:
- the stage number.
-
getTransformationConnectionNames
public java.lang.String[] getTransformationConnectionNames()
Get the transformation connection names mentioned by the IPipelineSpecification object.- Specified by:
getTransformationConnectionNames
in interfaceIPipelineConnections
-
getTransformationConnections
public ITransformationConnection[] getTransformationConnections()
Get the transformation connection instances mentioned by the IPipelineSpecification object.- Specified by:
getTransformationConnections
in interfaceIPipelineConnections
-
getOutputConnectionNames
public java.lang.String[] getOutputConnectionNames()
Get the output connection names mentioned by the IPipelineSpecification object.- Specified by:
getOutputConnectionNames
in interfaceIPipelineConnections
-
getOutputConnections
public IOutputConnection[] getOutputConnections()
Get the output connection instances mentioned by the IPipelineSpecification object.- Specified by:
getOutputConnections
in interfaceIPipelineConnections
-
getTransformationConnectionIndex
public java.lang.Integer getTransformationConnectionIndex(int stage)
Get the index of the transformation connection corresponding to a specific pipeline stage.- Specified by:
getTransformationConnectionIndex
in interfaceIPipelineConnections
-
getOutputConnectionIndex
public java.lang.Integer getOutputConnectionIndex(int stage)
Get the index of the output connection corresponding to a specific pipeline stage.- Specified by:
getOutputConnectionIndex
in interfaceIPipelineConnections
-
getStageDescriptionString
public VersionContext getStageDescriptionString(int stage)
Get the description string for a pipeline stage.- Specified by:
getStageDescriptionString
in interfaceIPipelineSpecification
- Parameters:
stage
- is the stage to get the connection name for.- Returns:
- the description string that stage.
-
getOutputDocumentVersionString
public java.lang.String getOutputDocumentVersionString(int index)
For a given output index, return a document version string.- Specified by:
getOutputDocumentVersionString
in interfaceIPipelineSpecificationWithVersions
- Parameters:
index
- is the output index.- Returns:
- the document version string.
-
getOutputTransformationVersionString
public java.lang.String getOutputTransformationVersionString(int index)
For a given output index, return a transformation version string.- Specified by:
getOutputTransformationVersionString
in interfaceIPipelineSpecificationWithVersions
- Parameters:
index
- is the output index.- Returns:
- the transformation version string.
-
getOutputVersionString
public java.lang.String getOutputVersionString(int index)
For a given output index, return an output version string.- Specified by:
getOutputVersionString
in interfaceIPipelineSpecificationWithVersions
- Parameters:
index
- is the output index.- Returns:
- the output version string.
-
getAuthorityNameString
public java.lang.String getAuthorityNameString(int index)
For a given output index, return an authority name string.- Specified by:
getAuthorityNameString
in interfaceIPipelineSpecificationWithVersions
- Parameters:
index
- is the output index.- Returns:
- the authority name string.
-
-