@Test public void testPurge() { store.store(createMetricRecord()); Assert.assertEquals(1,store.getBatch().size()); store.purge(DataCategory.EXTERNAL,0L); Mockito.verify(session,Mockito.atLeast(1)).execute(Mockito.anyString()); }
public void purge(DataCategory category, long retentionTime) { purgeMetrics(category,retentionTime); purgeLogs(category,retentionTime); purgeBinary(category,retentionTime); }
CassandraStore implements AutoCloseable { public void purge(DataCategory category, long retentionTime) { purgeMetrics(category,retentionTime); purgeLogs(category,retentionTime); purgeBinary(category,retentionTime); } }
CassandraStore implements AutoCloseable { public void purge(DataCategory category, long retentionTime) { purgeMetrics(category,retentionTime); purgeLogs(category,retentionTime); purgeBinary(category,retentionTime); } @Inject  CassandraStore();  CassandraStore(Session session, Cluster cluster); }
CassandraStore implements AutoCloseable { public void purge(DataCategory category, long retentionTime) { purgeMetrics(category,retentionTime); purgeLogs(category,retentionTime); purgeBinary(category,retentionTime); } @Inject  CassandraStore();  CassandraStore(Session session, Cluster cluster); BatchStatement getBatch(); void startBatch(); @SuppressWarnings("checkstyle:IllegalCatch") void executeBatch(); void store(TSDRMetricRecord mr); void store(TSDRLogRecord lr); void store(TSDRBinaryRecord lr); List<TSDRMetricRecord> getTSDRMetricRecords(String tsdrMetricKey, long startDateTime, long endDateTime,
            int recordLimit); List<TSDRLogRecord> getTSDRLogRecords(String tsdrLogKey, long startDateTime, long endDateTime,
            int recordLimit); List<TSDRBinaryRecord> getTSDRBinaryRecords(String tsdrBinaryKey, long startDateTime, long endDateTime,
            int recordLimit); @Override @PreDestroy @SuppressWarnings("checkstyle:IllegalCatch") void close(); void purge(DataCategory category, long retentionTime); }
CassandraStore implements AutoCloseable { public void purge(DataCategory category, long retentionTime) { purgeMetrics(category,retentionTime); purgeLogs(category,retentionTime); purgeBinary(category,retentionTime); } @Inject  CassandraStore();  CassandraStore(Session session, Cluster cluster); BatchStatement getBatch(); void startBatch(); @SuppressWarnings("checkstyle:IllegalCatch") void executeBatch(); void store(TSDRMetricRecord mr); void store(TSDRLogRecord lr); void store(TSDRBinaryRecord lr); List<TSDRMetricRecord> getTSDRMetricRecords(String tsdrMetricKey, long startDateTime, long endDateTime,
            int recordLimit); List<TSDRLogRecord> getTSDRLogRecords(String tsdrLogKey, long startDateTime, long endDateTime,
            int recordLimit); List<TSDRBinaryRecord> getTSDRBinaryRecords(String tsdrBinaryKey, long startDateTime, long endDateTime,
            int recordLimit); @Override @PreDestroy @SuppressWarnings("checkstyle:IllegalCatch") void close(); void purge(DataCategory category, long retentionTime);  }