|
|
|
@ -116,16 +116,16 @@ public class CassandraBaseTimeseriesDao extends AbstractCassandraBaseTimeseriesD |
|
|
|
super.startExecutor(); |
|
|
|
if (!isInstall()) { |
|
|
|
getFetchStmt(Aggregation.NONE, DESC_ORDER); |
|
|
|
Optional<NoSqlTsPartitionDate> partition = NoSqlTsPartitionDate.parse(partitioning); |
|
|
|
if (partition.isPresent()) { |
|
|
|
tsFormat = partition.get(); |
|
|
|
if (!isFixedPartitioning() && partitionsCacheSize > 0) { |
|
|
|
cassandraTsPartitionsCache = new CassandraTsPartitionsCache(partitionsCacheSize); |
|
|
|
} |
|
|
|
} else { |
|
|
|
log.warn("Incorrect configuration of partitioning {}", partitioning); |
|
|
|
throw new RuntimeException("Failed to parse partitioning property: " + partitioning + "!"); |
|
|
|
} |
|
|
|
Optional<NoSqlTsPartitionDate> partition = NoSqlTsPartitionDate.parse(partitioning); |
|
|
|
if (partition.isPresent()) { |
|
|
|
tsFormat = partition.get(); |
|
|
|
if (!isFixedPartitioning() && partitionsCacheSize > 0) { |
|
|
|
cassandraTsPartitionsCache = new CassandraTsPartitionsCache(partitionsCacheSize); |
|
|
|
} |
|
|
|
} else { |
|
|
|
log.warn("Incorrect configuration of partitioning {}", partitioning); |
|
|
|
throw new RuntimeException("Failed to parse partitioning property: " + partitioning + "!"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|