From 7de38a33e04fd0c5e9e325131cca90744b838679 Mon Sep 17 00:00:00 2001 From: jgreenstevens Date: Wed, 6 Nov 2024 17:08:19 +0000 Subject: [PATCH] Remove logs --- .../generator/ExpiredHousekeepingMetadataGenerator.java | 7 ------- .../apiary/generator/utils/CleanupDelayExtractor.java | 4 ---- .../scheduler/apiary/handler/MessageEventHandler.java | 5 ----- 3 files changed, 16 deletions(-) diff --git a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java index 9ed1fc46..159dc0d8 100644 --- a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java +++ b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java @@ -73,10 +73,6 @@ public ExpiredHousekeepingMetadataGenerator(String cleanupDelay) { public List generate(ListenerEvent listenerEvent, String clientId) { List housekeepingEntities = new ArrayList<>(); - System.out.println("Inside generator. Table parameters: "); - listenerEvent.getTableParameters() - .forEach((key, value1) -> System.out.println("Key: " + key + ", value: " + value1)); - switch (listenerEvent.getEventType()) { case CREATE_TABLE: CreateTableEvent createTableEvent = (CreateTableEvent) listenerEvent; @@ -86,9 +82,6 @@ public List generate(ListenerEvent listenerEvent, String cli break; case ALTER_TABLE: AlterTableEvent alterTableEvent = (AlterTableEvent) listenerEvent; - System.out.println("Inside generator. AlterTableEvent parameters: "); - alterTableEvent.getTableParameters() - .forEach((key, value1) -> System.out.println("Key: " + key + ", value: " + value1)); if (validTablePath(alterTableEvent.getTableLocation())) { housekeepingEntities.add(generateHousekeepingEntity((AlterTableEvent) listenerEvent, clientId)); } diff --git a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/utils/CleanupDelayExtractor.java b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/utils/CleanupDelayExtractor.java index d69fd5c6..f284a57a 100644 --- a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/utils/CleanupDelayExtractor.java +++ b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/utils/CleanupDelayExtractor.java @@ -45,10 +45,6 @@ public CleanupDelayExtractor(String propertyKey, String defaultValue) { public PeriodDuration extractCleanupDelay(ListenerEvent listenerEvent) { String tableCleanupDelay = listenerEvent.getTableParameters().get(propertyKey); - System.out.println("Inside cleanup delay extractor. Table parameters: "); - listenerEvent.getTableParameters() - .forEach((key, value1) -> System.out.println("Key: " + key + ", value: " + value1)); - try { PeriodDuration value = tableCleanupDelay == null ? defaultValue : PeriodDuration.parse(tableCleanupDelay); log diff --git a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java index 50cb9e91..d07912b2 100644 --- a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java +++ b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java @@ -45,11 +45,6 @@ public MessageEventHandler(HousekeepingEntityGenerator generator, List handleMessage(MessageEvent event) { ListenerEvent listenerEvent = event.getEvent(); - - System.out.println("Inside MessageEventHandler"); - event.getEvent().getTableParameters() - .forEach((key, value1) -> System.out.println("Key: " + key + ", value: " + value1)); - if (shouldFilterMessage(listenerEvent)) { return Collections.emptyList(); }