@Test public void cdpDatalakeClusterStatusChanged() { UsageProto.CDPDatalakeClusterStatusChanged proto = UsageProto.CDPDatalakeClusterStatusChanged.newBuilder() .setDatalakeId(dummy) .setOldStatus(UsageProto.CDPCloudbreakClusterStatus.Value.REQUESTED) .setNewStatus(UsageProto.CDPCloudbreakClusterStatus.Value.CREATE_IN_PROGRESS) .build(); usageReporter.cdpDatalakeClusterStatusChanged(proto); ArgumentCaptor<UsageProto.Event> captor = ArgumentCaptor.forClass(UsageProto.Event.class); verify(usageReporter).log(captor.capture()); assertEquals(dummy, captor.getValue().getCdpDatalakeClusterStatusChanged().getDatalakeId()); }
@Override public void cdpDatalakeClusterStatusChanged(UsageProto.CDPDatalakeClusterStatusChanged details) { checkNotNull(details); log(eventBuilder() .setCdpDatalakeClusterStatusChanged(details) .build()); }
LoggingUsageReporter implements UsageReporter { @Override public void cdpDatalakeClusterStatusChanged(UsageProto.CDPDatalakeClusterStatusChanged details) { checkNotNull(details); log(eventBuilder() .setCdpDatalakeClusterStatusChanged(details) .build()); } }
LoggingUsageReporter implements UsageReporter { @Override public void cdpDatalakeClusterStatusChanged(UsageProto.CDPDatalakeClusterStatusChanged details) { checkNotNull(details); log(eventBuilder() .setCdpDatalakeClusterStatusChanged(details) .build()); }  }
LoggingUsageReporter implements UsageReporter { @Override public void cdpDatalakeClusterStatusChanged(UsageProto.CDPDatalakeClusterStatusChanged details) { checkNotNull(details); log(eventBuilder() .setCdpDatalakeClusterStatusChanged(details) .build()); }  @Override void cdpDatahubClusterRequested(long timestamp, UsageProto.CDPDatahubClusterRequested details); @Override void cdpDatahubClusterStatusChanged(UsageProto.CDPDatahubClusterStatusChanged details); @Override void cdpDatalakeClusterRequested(long timestamp, UsageProto.CDPDatalakeClusterRequested details); @Override void cdpDatalakeClusterStatusChanged(UsageProto.CDPDatalakeClusterStatusChanged details); }
LoggingUsageReporter implements UsageReporter { @Override public void cdpDatalakeClusterStatusChanged(UsageProto.CDPDatalakeClusterStatusChanged details) { checkNotNull(details); log(eventBuilder() .setCdpDatalakeClusterStatusChanged(details) .build()); }  @Override void cdpDatahubClusterRequested(long timestamp, UsageProto.CDPDatahubClusterRequested details); @Override void cdpDatahubClusterStatusChanged(UsageProto.CDPDatahubClusterStatusChanged details); @Override void cdpDatalakeClusterRequested(long timestamp, UsageProto.CDPDatalakeClusterRequested details); @Override void cdpDatalakeClusterStatusChanged(UsageProto.CDPDatalakeClusterStatusChanged details);  }