Compare commits
No commits in common. "master" and "fix/initial-state" have entirely different histories.
master
...
fix/initia
4 changed files with 4 additions and 6 deletions
2
pom.xml
2
pom.xml
|
@ -14,7 +14,7 @@
|
||||||
<groupId>eu.ztsh</groupId>
|
<groupId>eu.ztsh</groupId>
|
||||||
<artifactId>large-file-reading-challenge</artifactId>
|
<artifactId>large-file-reading-challenge</artifactId>
|
||||||
<name>Large File Reading Challenge</name>
|
<name>Large File Reading Challenge</name>
|
||||||
<version>1.0.0</version>
|
<version>1.0.0-SNAPSHOT</version>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
<!-- encoding -->
|
<!-- encoding -->
|
||||||
|
|
|
@ -30,7 +30,7 @@ public class TemperaturesServiceImpl implements TemperaturesService {
|
||||||
Thread.currentThread().interrupt();
|
Thread.currentThread().interrupt();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return averages.get().getOrDefault(city.toLowerCase(), List.of());
|
return averages.get().get(city);
|
||||||
}
|
}
|
||||||
|
|
||||||
@EventListener(FileProcessedEvent.class)
|
@EventListener(FileProcessedEvent.class)
|
||||||
|
|
|
@ -79,9 +79,7 @@ public class FileLoadingService {
|
||||||
.map(line -> {
|
.map(line -> {
|
||||||
try {
|
try {
|
||||||
var parts = line.split(";");
|
var parts = line.split(";");
|
||||||
return new DataRow(parts[0].toLowerCase(),
|
return new DataRow(parts[0], Integer.parseInt(parts[1].split("-")[0]), Double.parseDouble(parts[2]));
|
||||||
Integer.parseInt(parts[1].split("-")[0]),
|
|
||||||
Double.parseDouble(parts[2]));
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
throw new FileProcessingException("Error in line %s".formatted(line), e);
|
throw new FileProcessingException("Error in line %s".formatted(line), e);
|
||||||
}
|
}
|
||||||
|
|
|
@ -29,7 +29,7 @@ class FileLoadingServiceTest {
|
||||||
.publishEvent(captor.capture());
|
.publishEvent(captor.capture());
|
||||||
var averages = captor.getValue().averages();
|
var averages = captor.getValue().averages();
|
||||||
assertThat(averages).hasSize(1);
|
assertThat(averages).hasSize(1);
|
||||||
var list = averages.get("warszawa");
|
var list = averages.get("Warszawa");
|
||||||
assertThat(list).hasSize(1);
|
assertThat(list).hasSize(1);
|
||||||
assertThat(list.getFirst()).satisfies(item -> {
|
assertThat(list.getFirst()).satisfies(item -> {
|
||||||
assertThat(item.getYear()).isEqualTo("2018");
|
assertThat(item.getYear()).isEqualTo("2018");
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue