migratePayloads(TimeseriesContainer, String, InfluxTimeseries, InfluxTimeseriesDataType) |  | 0% |  | 0% | 8 | 8 | 48 | 48 | 1 | 1 |
lambda$createMigrationTasksForContainers$4(Long) |  | 0% |  | 0% | 4 | 4 | 21 | 21 | 1 | 1 |
runMigrations() |  | 0% |  | 0% | 3 | 3 | 25 | 25 | 1 | 1 |
TimeseriesMigrationService(TimeseriesContainerService, MigrationTaskRepository, InfluxDBConnector, InfluxTimeseriesService, TimeseriesDataPointRepository, PayloadReader, PayloadWriter, CompressionRunner, int, int, int) |  | 0% | | n/a | 1 | 1 | 18 | 18 | 1 | 1 |
migrateTask(MigrationTaskEntity) |  | 0% |  | 0% | 3 | 3 | 19 | 19 | 1 | 1 |
getMigrationState() |  | 0% |  | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
getContainerIdsThatDoNotHaveMigrationTaskYet(List) |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
getTimestampOfPayload(String, InfluxTimeseries, InfluxSingleValuedUnaryFunction) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
addCompressionTask() |  | 0% |  | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
addWriterPoisonPills() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
setStateToFinishedAndRemoveErrors(MigrationTaskEntity) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
addCompressionPoisonPills() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
persistError(MigrationTaskEntity, String) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getExistingContainerIds() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
getMigrationTasks(boolean) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
createMigrationTaskForEachContainer() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
setStateToRunning(MigrationTaskEntity) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
compressAllDataPoints() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
doesDatabaseExist(String) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
getPayloadReadQueueSize() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
storeTasksInDatabase(List) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getTimeseries(MigrationTaskEntity) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getUnfinishedMigrationTasks() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getContainerIdsThatDoNotHaveMigrationTaskYet$6(List, Long) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getMigrationState$1(MigrationTaskEntity) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$getMigrationTasks$0(MigrationTaskEntity) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
createMigrationTasksForContainers(List) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getFirstTimestampOfPayload(String, InfluxTimeseries) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLastTimestampOfPayload(String, InfluxTimeseries) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getContainerIdsThatDoNotHaveMigrationTaskYet$5(MigrationTaskEntity) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getExistingContainerIds$2(TimeseriesContainer) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPayloadReadQueue() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCompressionTasksQueue() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getReadWriteLock() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPayloadWriteQueue() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getExistingContainerIds$3(TimeseriesContainer) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |