Package org.odpi.openmetadata.governanceservers.lineagewarehouse.listeners

Class AsseLineageOutTopicListener

java.lang.Object

org.odpi.openmetadata.accessservices.assetlineage.event.AssetLineageEventListener

org.odpi.openmetadata.governanceservers.lineagewarehouse.listeners.AsseLineageOutTopicListener

public class AsseLineageOutTopicListener
extends AssetLineageEventListener

Constructor Summary

Constructors

Constructor	Description
AsseLineageOutTopicListener(StoringServices storingServices, LineageWarehouseAssetContextHandler assetContextHandler, OMRSAuditLog auditLog)

Method Summary

Modifier and Type	Method	Description
void	processEvent(String assetLineageEvent)	Receives kafka events that are publish out from Asset Lineage OMAS

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AsseLineageOutTopicListener

public AsseLineageOutTopicListener(StoringServices storingServices,
 LineageWarehouseAssetContextHandler assetContextHandler,
 OMRSAuditLog auditLog)

Method Details

processEvent

public void processEvent(String assetLineageEvent)

Receives kafka events that are publish out from Asset Lineage OMAS

Specified by:

processEvent in class AssetLineageEventListener

Parameters:

assetLineageEvent - contains all the information needed to build asset lineage like connection details, database name, schema name, table name, derived columns details