|
|
@ -91,10 +91,6 @@ public abstract class BaseTimeseriesServiceTest extends AbstractServiceTest { |
|
|
saveEntries(deviceId, TS); |
|
|
saveEntries(deviceId, TS); |
|
|
|
|
|
|
|
|
testLatestTsAndVerify(deviceId); |
|
|
testLatestTsAndVerify(deviceId); |
|
|
|
|
|
|
|
|
EntityView entityView = saveAndCreateEntityView(deviceId, Arrays.asList(STRING_KEY, DOUBLE_KEY, LONG_KEY, BOOLEAN_KEY)); |
|
|
|
|
|
|
|
|
|
|
|
testLatestTsAndVerify(entityView.getId()); |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
private void testLatestTsAndVerify(EntityId entityId) throws ExecutionException, InterruptedException { |
|
|
private void testLatestTsAndVerify(EntityId entityId) throws ExecutionException, InterruptedException { |
|
|
@ -141,12 +137,6 @@ public abstract class BaseTimeseriesServiceTest extends AbstractServiceTest { |
|
|
List<TsKvEntry> entries = tsService.findLatest(tenantId, deviceId, Collections.singleton(STRING_KEY)).get(); |
|
|
List<TsKvEntry> entries = tsService.findLatest(tenantId, deviceId, Collections.singleton(STRING_KEY)).get(); |
|
|
Assert.assertEquals(1, entries.size()); |
|
|
Assert.assertEquals(1, entries.size()); |
|
|
Assert.assertEquals(toTsEntry(TS, stringKvEntry), entries.get(0)); |
|
|
Assert.assertEquals(toTsEntry(TS, stringKvEntry), entries.get(0)); |
|
|
|
|
|
|
|
|
EntityView entityView = saveAndCreateEntityView(deviceId, Arrays.asList(STRING_KEY)); |
|
|
|
|
|
|
|
|
|
|
|
entries = tsService.findLatest(tenantId, entityView.getId(), Collections.singleton(STRING_KEY)).get(); |
|
|
|
|
|
Assert.assertEquals(1, entries.size()); |
|
|
|
|
|
Assert.assertEquals(toTsEntry(TS, stringKvEntry), entries.get(0)); |
|
|
|
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@Test |
|
|
@Test |
|
|
|