Showing
1 changed file
with
10 additions
and
1 deletions
@@ -255,7 +255,7 @@ public class CassandraBaseTimeseriesDao extends CassandraAbstractAsyncDao implem | @@ -255,7 +255,7 @@ public class CassandraBaseTimeseriesDao extends CassandraAbstractAsyncDao implem | ||
255 | stmt.setUUID(1, entityId.getId()); | 255 | stmt.setUUID(1, entityId.getId()); |
256 | stmt.setString(2, key); | 256 | stmt.setString(2, key); |
257 | log.debug("Generated query [{}] for entityType {} and entityId {}", stmt, entityId.getEntityType(), entityId.getId()); | 257 | log.debug("Generated query [{}] for entityType {} and entityId {}", stmt, entityId.getEntityType(), entityId.getId()); |
258 | - return getFuture(executeAsyncRead(stmt), rs -> convertResultToTsKvEntry(rs.one())); | 258 | + return getFuture(executeAsyncRead(stmt), rs -> convertResultToTsKvEntry(key, rs.one())); |
259 | } | 259 | } |
260 | 260 | ||
261 | @Override | 261 | @Override |
@@ -319,6 +319,15 @@ public class CassandraBaseTimeseriesDao extends CassandraAbstractAsyncDao implem | @@ -319,6 +319,15 @@ public class CassandraBaseTimeseriesDao extends CassandraAbstractAsyncDao implem | ||
319 | return entries; | 319 | return entries; |
320 | } | 320 | } |
321 | 321 | ||
322 | + private TsKvEntry convertResultToTsKvEntry(String key, Row row) { | ||
323 | + if (row != null) { | ||
324 | + long ts = row.getLong(ModelConstants.TS_COLUMN); | ||
325 | + return new BasicTsKvEntry(ts, toKvEntry(row, key)); | ||
326 | + } else { | ||
327 | + return new BasicTsKvEntry(System.currentTimeMillis(), new StringDataEntry(key, null)); | ||
328 | + } | ||
329 | + } | ||
330 | + | ||
322 | private TsKvEntry convertResultToTsKvEntry(Row row) { | 331 | private TsKvEntry convertResultToTsKvEntry(Row row) { |
323 | String key = row.getString(ModelConstants.KEY_COLUMN); | 332 | String key = row.getString(ModelConstants.KEY_COLUMN); |
324 | long ts = row.getLong(ModelConstants.TS_COLUMN); | 333 | long ts = row.getLong(ModelConstants.TS_COLUMN); |