DistinctRowsTest.java

@Test
public void findAllMetricIdentifiersShouldReturnDistinctResult() throws Exception {
    String tenant = "DISTINCT";
    String metric = "METRIC";
    long timestamp = now().getMillis();
    String tempTable1 = dataAccess.getTempTableName(timestamp);
    String tempTable2 = dataAccess.getTempTableName(now().minusHours(3).getMillis());

    session.execute("insert into " + tempTable1 + " (tenant_id, type, metric, time) values ('" + tenant +
            "', 0, '" + metric + "', " + timestamp + ")");
    session.execute("insert into " + tempTable2 + " (tenant_id, type, metric, time) values ('" + tenant +
            "', 0, '" + metric + "', " + timestamp + ")");

    Observable<Row> rows = dataAccess.findAllMetricIdentifiersInData();
    // This assertion fails
    assertEquals(rows.toList().toBlocking().first().size(), 1);
}