Class DataEngineProxyService
java.lang.Object
org.odpi.openmetadata.governanceservers.dataengineproxy.processor.DataEngineProxyService
- All Implemented Interfaces:
Runnable
Class to handle periodically polling a Data Engine for changes, for those data engines that do not
provide any event-based mechanism to notify on changes.
-
Constructor Summary
ConstructorsConstructorDescriptionDataEngineProxyService
(DataEngineConnectorBase connector, String userId, DataEngineProxyConfig dataEngineProxyConfig, DataEngineClient dataEngineOMASClient, OMRSAuditLog auditLog) Default constructor -
Method Summary
Modifier and TypeMethodDescriptionvoid
void
load()
void
pollProcessChanges
(String processId) void
run()
Poll for Process changes.void
stop()
-
Constructor Details
-
DataEngineProxyService
public DataEngineProxyService(DataEngineConnectorBase connector, String userId, DataEngineProxyConfig dataEngineProxyConfig, DataEngineClient dataEngineOMASClient, OMRSAuditLog auditLog) Default constructor- Parameters:
connector
- Data Engine Connector through which to connect to the data engine to polluserId
- the user ID used to poll for changes against the connectordataEngineProxyConfig
- configuration of the Data Engine (Proxy)dataEngineOMASClient
- Data Engine OMAS client through which to push any changes into EgeriaauditLog
- audit log through which to record activities
-
-
Method Details
-
initialize
public void initialize() throws ConnectorCheckedException, UserNotAuthorizedException, InvalidParameterException, PropertyServerException -
stop
public void stop() -
run
public void run()Poll for Process changes. -
load
public void load() -
pollProcessChanges
-