|
|
@ -86,6 +86,18 @@ public class CassandraBaseTimeseriesDao extends AbstractCassandraBaseTimeseriesD |
|
|
public static final String ASC_ORDER = "ASC"; |
|
|
public static final String ASC_ORDER = "ASC"; |
|
|
public static final long SECONDS_IN_DAY = TimeUnit.DAYS.toSeconds(1); |
|
|
public static final long SECONDS_IN_DAY = TimeUnit.DAYS.toSeconds(1); |
|
|
protected static final List<Long> FIXED_PARTITION = List.of(0L); |
|
|
protected static final List<Long> FIXED_PARTITION = List.of(0L); |
|
|
|
|
|
private static String INSERT_WITH_NULL = INSERT_INTO + ModelConstants.TS_KV_CF + |
|
|
|
|
|
"(" + ModelConstants.ENTITY_TYPE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.ENTITY_ID_COLUMN + |
|
|
|
|
|
"," + ModelConstants.KEY_COLUMN + |
|
|
|
|
|
"," + ModelConstants.PARTITION_COLUMN + |
|
|
|
|
|
"," + ModelConstants.TS_COLUMN + |
|
|
|
|
|
"," + ModelConstants.BOOLEAN_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.STRING_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.LONG_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.DOUBLE_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.JSON_VALUE_COLUMN + ")" + |
|
|
|
|
|
" VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"; |
|
|
|
|
|
|
|
|
private CassandraTsPartitionsCache cassandraTsPartitionsCache; |
|
|
private CassandraTsPartitionsCache cassandraTsPartitionsCache; |
|
|
|
|
|
|
|
|
@ -566,18 +578,7 @@ public class CassandraBaseTimeseriesDao extends AbstractCassandraBaseTimeseriesD |
|
|
stmtCreationLock.lock(); |
|
|
stmtCreationLock.lock(); |
|
|
try { |
|
|
try { |
|
|
if (saveWithNullStmt == null) { |
|
|
if (saveWithNullStmt == null) { |
|
|
saveWithNullStmt = prepare(INSERT_INTO + ModelConstants.TS_KV_CF + |
|
|
saveWithNullStmt = prepare(INSERT_WITH_NULL); |
|
|
"(" + ModelConstants.ENTITY_TYPE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.ENTITY_ID_COLUMN + |
|
|
|
|
|
"," + ModelConstants.KEY_COLUMN + |
|
|
|
|
|
"," + ModelConstants.PARTITION_COLUMN + |
|
|
|
|
|
"," + ModelConstants.TS_COLUMN + |
|
|
|
|
|
"," + ModelConstants.BOOLEAN_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.STRING_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.LONG_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.DOUBLE_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.JSON_VALUE_COLUMN + ")" + |
|
|
|
|
|
" VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"); |
|
|
|
|
|
} |
|
|
} |
|
|
} finally { |
|
|
} finally { |
|
|
stmtCreationLock.unlock(); |
|
|
stmtCreationLock.unlock(); |
|
|
@ -591,18 +592,7 @@ public class CassandraBaseTimeseriesDao extends AbstractCassandraBaseTimeseriesD |
|
|
stmtCreationLock.lock(); |
|
|
stmtCreationLock.lock(); |
|
|
try { |
|
|
try { |
|
|
if (saveWithNullWithTtlStmt == null) { |
|
|
if (saveWithNullWithTtlStmt == null) { |
|
|
saveWithNullWithTtlStmt = prepare(INSERT_INTO + ModelConstants.TS_KV_CF + |
|
|
saveWithNullWithTtlStmt = prepare(INSERT_WITH_NULL + " USING TTL ?"); |
|
|
"(" + ModelConstants.ENTITY_TYPE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.ENTITY_ID_COLUMN + |
|
|
|
|
|
"," + ModelConstants.KEY_COLUMN + |
|
|
|
|
|
"," + ModelConstants.PARTITION_COLUMN + |
|
|
|
|
|
"," + ModelConstants.TS_COLUMN + |
|
|
|
|
|
"," + ModelConstants.BOOLEAN_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.STRING_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.LONG_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.DOUBLE_VALUE_COLUMN + |
|
|
|
|
|
"," + ModelConstants.JSON_VALUE_COLUMN + ")" + |
|
|
|
|
|
" VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?) USING TTL ?"); |
|
|
|
|
|
} |
|
|
} |
|
|
} finally { |
|
|
} finally { |
|
|
stmtCreationLock.unlock(); |
|
|
stmtCreationLock.unlock(); |
|
|
|