Skip to content

Commit

Permalink
Remove logs
Browse files Browse the repository at this point in the history
  • Loading branch information
JayGreeeen authored and Harold Jimenez committed Dec 2, 2024
1 parent eb62d0b commit 7de38a3
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 16 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -73,10 +73,6 @@ public ExpiredHousekeepingMetadataGenerator(String cleanupDelay) {
public List<HousekeepingEntity> generate(ListenerEvent listenerEvent, String clientId) {
List<HousekeepingEntity> 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;
Expand All @@ -86,9 +82,6 @@ public List<HousekeepingEntity> 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));
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -45,11 +45,6 @@ public MessageEventHandler(HousekeepingEntityGenerator generator, List<ListenerE

public List<HousekeepingEntity> 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();
}
Expand Down

0 comments on commit 7de38a3

Please sign in to comment.