Modifier and Type | Class and Description |
---|---|
protected static class |
IncrementalIngester.MonitoredAddActivityWrapper
This class passes everything through, and monitors what happens so that the
framework can compensate for any transformation connector coding errors.
|
protected static class |
IncrementalIngester.OutputActivitiesWrapper |
protected static class |
IncrementalIngester.OutputAddActivitiesWrapper |
static class |
IncrementalIngester.PipelineAddFanout
This class describes the entry stage of multiple siblings in an add pipeline.
|
Modifier and Type | Field and Description |
---|---|
protected IOutputAddActivity |
IncrementalIngester.MonitoredAddActivityWrapper.activities |
protected IOutputAddActivity |
IncrementalIngester.OutputAddActivitiesWrapper.addActivities |
protected IOutputAddActivity |
IncrementalIngester.PipelineAddEntryPoint.addActivity |
Constructor and Description |
---|
MonitoredAddActivityWrapper(IOutputAddActivity activities) |
OutputAddActivitiesWrapper(IOutputAddActivity addActivities,
java.lang.String outputConnectionName) |
PipelineAddEntryPoint(IPipelineConnector pipelineConnector,
VersionContext pipelineDescriptionString,
java.lang.String authorityNameString,
IOutputAddActivity addActivity,
boolean isActive) |
Modifier and Type | Interface and Description |
---|---|
interface |
IOutputActivity
This interface abstracts from the activities that an output connector can do
when adding or replacing documents, or deleting documents.
|
Modifier and Type | Method and Description |
---|---|
int |
IPipelineConnector.addOrReplaceDocumentWithException(java.lang.String documentURI,
VersionContext pipelineDescription,
RepositoryDocument document,
java.lang.String authorityNameString,
IOutputAddActivity activities)
Add (or replace) a document in the output data store using the connector.
|
Modifier and Type | Method and Description |
---|---|
int |
BaseOutputConnector.addOrReplaceDocumentWithException(java.lang.String documentURI,
VersionContext pipelineDescription,
RepositoryDocument document,
java.lang.String authorityNameString,
IOutputAddActivity activities)
Add (or replace) a document in the output data store using the connector.
|
Modifier and Type | Method and Description |
---|---|
int |
BaseTransformationConnector.addOrReplaceDocumentWithException(java.lang.String documentURI,
VersionContext pipelineDescription,
RepositoryDocument document,
java.lang.String authorityNameString,
IOutputAddActivity activities)
Add (or replace) a document in the output data store using the connector.
|
Modifier and Type | Class and Description |
---|---|
protected static class |
WorkerThread.OutputActivity
The ingest logger class
|