yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-09-26 09:35:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(usage-stats): Add usage stats factory to mae processor config (#2803)

Browse Source
This commit is contained in:
Dexter Lee 2021-06-29 23:03:31 -07:00 committed by GitHub
parent ef75bc6e5c
commit 8df8ff96bc
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
metadata-jobs/mae-consumer/src/main/java/com/linkedin/metadata/kafka/MetadataAuditEventsProcessor.java
View File

@ -5,6 +5,7 @@ import com.linkedin.common.urn.Urn;
import com.linkedin.data.template.RecordTemplate; import com.linkedin.data.template.RecordTemplate;
import com.linkedin.gms.factory.common.GraphServiceFactory; import com.linkedin.gms.factory.common.GraphServiceFactory;
import com.linkedin.gms.factory.search.SearchServiceFactory; import com.linkedin.gms.factory.search.SearchServiceFactory;
import com.linkedin.gms.factory.usage.UsageServiceFactory;
import com.linkedin.metadata.EventUtils; import com.linkedin.metadata.EventUtils;
import com.linkedin.metadata.PegasusUtils; import com.linkedin.metadata.PegasusUtils;
import com.linkedin.metadata.dao.utils.RecordUtils; import com.linkedin.metadata.dao.utils.RecordUtils;
@ -49,7 +50,7 @@ import static com.linkedin.metadata.dao.Neo4jUtil.createRelationshipFilter;
@Slf4j @Slf4j
@Component @Component
@Conditional(MetadataAuditEventsProcessorCondition.class) @Conditional(MetadataAuditEventsProcessorCondition.class)
@Import({GraphServiceFactory.class, SearchServiceFactory.class}) @Import({GraphServiceFactory.class, SearchServiceFactory.class, UsageServiceFactory.class})
@EnableKafka @EnableKafka
public class MetadataAuditEventsProcessor { public class MetadataAuditEventsProcessor {