mirror of
https://github.com/open-metadata/OpenMetadata.git
synced 2025-11-11 08:23:40 +00:00
Update AbstractEventPublisher.java (#8828)
Co-authored-by: Rounak-28 <95576871+Rounak-28@users.noreply.github.com>
This commit is contained in:
parent
081aad5f5d
commit
2baf6873b6
@ -35,11 +35,11 @@ public abstract class AbstractEventPublisher implements EventPublisher {
|
|||||||
|
|
||||||
protected void updateFilter(List<EventFilter> filterList) {
|
protected void updateFilter(List<EventFilter> filterList) {
|
||||||
filterList.forEach(
|
filterList.forEach(
|
||||||
(entityFilter) -> {
|
entityFilter -> {
|
||||||
String entityType = entityFilter.getEntityType();
|
String entityType = entityFilter.getEntityType();
|
||||||
Map<EventType, Filters> entityBasicFilterMap = new HashMap<>();
|
Map<EventType, Filters> entityBasicFilterMap = new HashMap<>();
|
||||||
if (entityFilter.getFilters() != null) {
|
if (entityFilter.getFilters() != null) {
|
||||||
entityFilter.getFilters().forEach((f) -> entityBasicFilterMap.put(f.getEventType(), f));
|
entityFilter.getFilters().forEach(f -> entityBasicFilterMap.put(f.getEventType(), f));
|
||||||
}
|
}
|
||||||
filter.put(entityType, entityBasicFilterMap);
|
filter.put(entityType, entityBasicFilterMap);
|
||||||
});
|
});
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user