Package org.odpi.openmetadata.frameworks.opensurvey

Class SequentialSurveyPipeline

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.frameworks.opensurvey.SurveyActionServiceConnector

org.odpi.openmetadata.frameworks.opensurvey.SurveyActionPipelineConnector

org.odpi.openmetadata.frameworks.opensurvey.SequentialSurveyPipeline

All Implemented Interfaces:

AuditLoggingComponent, SecureConnectorExtension, VirtualConnectorExtension, SurveyActionService

public class SequentialSurveyPipeline
extends SurveyActionPipelineConnector

SequentialSurveyPipeline is a survey action pipeline that provides an inline sequential invocation of the supplied survey action services.

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.opensurvey.SurveyActionPipelineConnector

embeddedSurveyActionServices

Fields inherited from class org.odpi.openmetadata.frameworks.opensurvey.SurveyActionServiceConnector

auditLog, connector, embeddedConnectors, objectMapper, propertyHelper, surveyActionServiceName, surveyContext

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

connectionBean, connectorInstanceId, messageFormatter, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
SequentialSurveyPipeline()

Method Summary

Modifier and Type	Method	Description
protected void	runSurveyPipeline()	This implementation provides an inline sequential invocation of the supplied survey action services.

Methods inherited from class org.odpi.openmetadata.frameworks.opensurvey.SurveyActionPipelineConnector

disconnect, start

Methods inherited from class org.odpi.openmetadata.frameworks.opensurvey.SurveyActionServiceConnector

getConnectorComponentDescription, getEmbeddedSurveyActionServices, getJSONProperties, getRootSchemaType, getSurveyContext, handleUnexpectedException, performCheckAssetAnalysisStep, performCheckAssetAnalysisStep, setAuditLog, setSurveyActionServiceName, setSurveyContext, setUpAnnotation, throwMissingSchemaType, writeNameCountInventory, writeNameDescriptionInventory, writeNameListInventory, writePropertyListInventory

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

combineConfigurationProperties, disconnectConnectors, equals, fromCanonicalToKebabCase, fromCanonicalToSnakeCase, fromKebabToCanonicalCase, fromSnakeToCanonicalCase, getArrayConfigurationProperty, getArrayConfigurationProperty, getArrayConfigurationProperty, getBooleanConfigurationProperty, getConnection, getConnectorInstanceId, getDateConfigurationProperty, getIntConfigurationProperty, getLongConfigurationProperty, getStringConfigurationProperty, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, initializeEmbeddedConnectors, initializeSecretsStoreConnector, isActive, logExceptionRecord, logRecord, logRecord, throwMissingConfigurationProperty, throwMissingEndpointAddress, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, toString

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector

clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, refreshStatistics, setStatisticProperty, setStatisticTimestamp

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.odpi.openmetadata.frameworks.connectors.VirtualConnectorExtension

initializeEmbeddedConnectors

Constructor Details

SequentialSurveyPipeline

public SequentialSurveyPipeline()

Method Details

runSurveyPipeline

protected void runSurveyPipeline()
                          throws ConnectorCheckedException,
UserNotAuthorizedException

This implementation provides an inline sequential invocation of the supplied survey action services.

Specified by:

runSurveyPipeline in class SurveyActionPipelineConnector

Throws:

ConnectorCheckedException - there is a problem within the survey action service.

UserNotAuthorizedException - the connector was disconnected before/during start