Modifier and Type | Field and Description |
---|---|
protected IOutputConnector |
IncrementalIngester.OutputAddEntryPoint.outputConnector |
IOutputConnector[] |
IncrementalIngester.PipelineObject.outputConnectors |
Constructor and Description |
---|
IncrementalIngester.OutputAddEntryPoint(IOutputConnector outputConnector,
VersionContext outputDescriptionString,
IOutputActivity activity,
boolean isActive,
String outputConnectionName,
String transformationVersion,
long ingestTime,
String documentVersion,
String parameterVersion,
String docKey,
String componentHash,
String authorityNameString) |
IncrementalIngester.PipelineObject(IPipelineSpecification pipelineConnections,
ITransformationConnector[] transformationConnectors,
IOutputConnector[] outputConnectors) |
IncrementalIngester.PipelineObjectWithVersions(IPipelineSpecificationWithVersions pipelineSpecificationWithVersions,
ITransformationConnector[] transformationConnectors,
IOutputConnector[] outputConnectors) |
Modifier and Type | Method and Description |
---|---|
static IOutputConnector |
OutputConnectorFactory.getConnectorNoCheck(String className)
Get an output connector instance, without checking for installed connector.
|
IOutputConnector |
IOutputConnectorPool.grab(IOutputConnection outputConnection)
Get an output connector.
|
IOutputConnector[] |
IOutputConnectorPool.grabMultiple(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,
String[] orderingKeys,
String[] connectionNames,
String[] classNames,
ConfigParams[] configInfos,
int[] maxPoolSizes) |
IOutputConnector[] |
OutputConnectorPool.grabMultiple(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.
|