Modifier and Type | Field and Description |
---|---|
protected IOutputConnector |
IncrementalIngester.OutputAddEntryPoint.outputConnector |
IOutputConnector[] |
IncrementalIngester.PipelineObject.outputConnectors |
Constructor and Description |
---|
OutputAddEntryPoint(IOutputConnector outputConnector,
VersionContext outputDescriptionString,
IOutputActivity activity,
boolean isActive,
java.lang.String outputConnectionName,
java.lang.String transformationVersion,
long ingestTime,
java.lang.String documentVersion,
java.lang.String docKey,
java.lang.String componentHash,
java.lang.String authorityNameString) |
PipelineObject(IPipelineSpecification pipelineConnections,
ITransformationConnector[] transformationConnectors,
IOutputConnector[] outputConnectors) |
PipelineObjectWithVersions(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions,
ITransformationConnector[] transformationConnectors,
IOutputConnector[] outputConnectors) |
Modifier and Type | Method and Description |
---|---|
static IOutputConnector |
OutputConnectorFactory.getConnectorNoCheck(java.lang.String className)
Get an output connector instance, without checking for installed connector.
|
IOutputConnector |
IOutputConnectorPool.grab(IOutputConnection outputConnection)
Get an output connector.
|
IOutputConnector[] |
IOutputConnectorPool.grabMultiple(java.lang.String[] orderingKeys,
IOutputConnection[] outputConnections)
Get multiple output connectors, all at once.
|
Modifier and Type | Method and Description |
---|---|
void |
IOutputConnectorPool.release(IOutputConnection connection,
IOutputConnector connector)
Release an output connector.
|
void |
IOutputConnectorPool.releaseMultiple(IOutputConnection[] connections,
IOutputConnector[] connectors)
Release multiple output connectors.
|
Modifier and Type | Class and Description |
---|---|
class |
BaseOutputConnector
This base class describes an instance of a connection between an output pipeline and the Connector Framework.
|
Modifier and Type | Method and Description |
---|---|
IOutputConnector |
OutputConnectorPool.grab(IOutputConnection outputConnection)
Get an output connector.
|
IOutputConnector[] |
OutputConnectorPool.LocalPool.grabMultiple(IThreadContext tc,
java.lang.String[] orderingKeys,
java.lang.String[] connectionNames,
java.lang.String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
IOutputConnector[] |
OutputConnectorPool.grabMultiple(java.lang.String[] orderingKeys,
IOutputConnection[] outputConnections)
Get multiple output connectors, all at once.
|
Modifier and Type | Method and Description |
---|---|
void |
OutputConnectorPool.release(IOutputConnection connection,
IOutputConnector connector)
Release an output connector.
|
void |
OutputConnectorPool.releaseMultiple(IOutputConnection[] connections,
IOutputConnector[] connectors)
Release multiple output connectors.
|