Skip to content

Commit f4a042a

Browse files
committed
Removing column renaming.
1 parent 1486d79 commit f4a042a

File tree

6 files changed

+23
-25
lines changed

6 files changed

+23
-25
lines changed

src/main/java/edu/ie3/datamodel/io/factory/timeseries/TimeSeriesMappingFactory.java

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,13 +8,16 @@
88
import edu.ie3.datamodel.io.factory.EntityData;
99
import edu.ie3.datamodel.io.factory.EntityFactory;
1010
import edu.ie3.datamodel.io.source.TimeSeriesMappingSource;
11+
import java.util.Collections;
1112
import java.util.List;
1213
import java.util.Set;
1314
import java.util.UUID;
15+
import java.util.stream.Collectors;
16+
import java.util.stream.Stream;
1417

1518
public class TimeSeriesMappingFactory
1619
extends EntityFactory<TimeSeriesMappingSource.MappingEntry, EntityData> {
17-
private static final String ENTITY = "entity";
20+
private static final String PARTICIPANT = "participant";
1821
private static final String TIME_SERIES = "timeSeries";
1922

2023
public TimeSeriesMappingFactory() {
@@ -23,13 +26,14 @@ public TimeSeriesMappingFactory() {
2326

2427
@Override
2528
protected List<Set<String>> getFields(Class<?> entityClass) {
26-
return List.of(newSet(ENTITY, TIME_SERIES));
29+
return Collections.singletonList(
30+
Stream.of(PARTICIPANT, TIME_SERIES).collect(Collectors.toSet()));
2731
}
2832

2933
@Override
3034
protected TimeSeriesMappingSource.MappingEntry buildModel(EntityData data) {
31-
UUID entity = data.getUUID(ENTITY);
35+
UUID participant = data.getUUID(PARTICIPANT);
3236
UUID timeSeries = data.getUUID(TIME_SERIES);
33-
return new TimeSeriesMappingSource.MappingEntry(entity, timeSeries);
37+
return new TimeSeriesMappingSource.MappingEntry(participant, timeSeries);
3438
}
3539
}

src/main/java/edu/ie3/datamodel/io/source/TimeSeriesMappingSource.java

Lines changed: 10 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import edu.ie3.datamodel.io.factory.EntityData;
1212
import edu.ie3.datamodel.io.factory.timeseries.TimeSeriesMappingFactory;
1313
import edu.ie3.datamodel.models.input.InputEntity;
14+
import edu.ie3.datamodel.models.input.system.SystemParticipantInput;
1415
import edu.ie3.datamodel.models.timeseries.TimeSeries;
1516
import edu.ie3.datamodel.utils.Try;
1617
import edu.ie3.datamodel.utils.Try.*;
@@ -46,7 +47,7 @@ public Map<UUID, UUID> getMapping() throws SourceException {
4647
.filter(Try::isSuccess)
4748
.map(t -> (Success<MappingEntry, FactoryException>) t)
4849
.map(Success::get)
49-
.collect(Collectors.toMap(MappingEntry::getEntity, MappingEntry::getTimeSeries));
50+
.collect(Collectors.toMap(MappingEntry::participant, MappingEntry::timeSeries));
5051
}
5152

5253
/**
@@ -79,19 +80,12 @@ private Try<MappingEntry, FactoryException> createMappingEntry(
7980

8081
// -=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-
8182

82-
/** Class to represent one entry within the entity to time series mapping */
83-
public static class MappingEntry implements InputEntity {
84-
private final UUID entity;
85-
private final UUID timeSeries;
83+
/** Class to represent one entry within the participant to time series mapping */
84+
public record MappingEntry(UUID participant, UUID timeSeries) implements InputEntity {
8685

87-
public MappingEntry(UUID entity, UUID timeSeries) {
88-
this.entity = entity;
89-
this.timeSeries = timeSeries;
90-
}
91-
92-
/** Returns the {@link UUID} of the {@link edu.ie3.datamodel.models.UniqueEntity}. */
93-
public UUID getEntity() {
94-
return entity;
86+
/** Returns the {@link UUID} of the {@link SystemParticipantInput}. */
87+
public UUID getParticipant() {
88+
return participant;
9589
}
9690

9791
/** Returns the {@link UUID} of the {@link TimeSeries}. */
@@ -103,17 +97,17 @@ public UUID getTimeSeries() {
10397
public boolean equals(Object o) {
10498
if (this == o) return true;
10599
if (!(o instanceof MappingEntry that)) return false;
106-
return entity.equals(that.entity) && timeSeries.equals(that.timeSeries);
100+
return participant.equals(that.participant) && timeSeries.equals(that.timeSeries);
107101
}
108102

109103
@Override
110104
public int hashCode() {
111-
return Objects.hash(entity, timeSeries);
105+
return Objects.hash(participant, timeSeries);
112106
}
113107

114108
@Override
115109
public String toString() {
116-
return "MappingEntry{" + "entity=" + entity + ", timeSeries=" + timeSeries + '}';
110+
return "MappingEntry{" + "participant=" + participant + ", timeSeries=" + timeSeries + '}';
117111
}
118112
}
119113
}

src/main/java/edu/ie3/datamodel/utils/validation/UniquenessValidationUtils.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ public class UniquenessValidationUtils extends ValidationUtils {
3333
protected static final FieldSetSupplier<CongestionResult> congestionResultFieldSupplier =
3434
entity -> Set.of(entity.getTime(), entity.getSubgrid());
3535
protected static final FieldSetSupplier<MappingEntry> mappingFieldSupplier =
36-
entity -> Set.of(entity.getEntity());
36+
entity -> Set.of(entity.participant());
3737
protected static final FieldSetSupplier<IdCoordinateInput> idCoordinateSupplier =
3838
entity -> Set.of(entity.id(), entity.point());
3939
protected static final FieldSetSupplier<TimeBasedValue<WeatherValue>> weatherValueFieldSupplier =

src/test/groovy/edu/ie3/datamodel/io/processor/input/InputEntityProcessorTest.groovy

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -630,7 +630,7 @@ class InputEntityProcessorTest extends Specification {
630630
def validResult = new TimeSeriesMappingSource.MappingEntry(UUID.fromString("7eb7b296-f4c4-4020-acf3-e865453b5dbd"), UUID.fromString("bc581c6c-3044-48a1-aea1-5b2cb1370356"))
631631

632632
Map expectedResults = [
633-
"entity": "7eb7b296-f4c4-4020-acf3-e865453b5dbd",
633+
"participant": "7eb7b296-f4c4-4020-acf3-e865453b5dbd",
634634
"timeSeries": "bc581c6c-3044-48a1-aea1-5b2cb1370356"
635635
]
636636

src/test/resources/edu/ie3/datamodel/io/source/csv/_timeseries/time_series_mapping.csv

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
"entity";"time_series"
1+
"participant";"time_series"
22
"b86e95b0-e579-4a80-a534-37c7a470a409";"9185b8c1-86ba-4a16-8dea-5ac898e8caa5"
33
"c7ebcc6c-55fc-479b-aa6b-6fa82ccac6b8";"3fbfaa97-cff4-46d4-95ba-a95665e87c26"
44
"90a96daa-012b-4fea-82dc-24ba7a7ab81c";"3fbfaa97-cff4-46d4-95ba-a95665e87c26"

src/test/resources/edu/ie3/datamodel/io/source/sql/_timeseries/time_series_mapping.sql

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
CREATE TABLE public.time_series_mapping
22
(
3-
entity uuid PRIMARY KEY,
3+
participant uuid PRIMARY KEY,
44
time_series uuid
55
)
66
WITHOUT OIDS
77
TABLESPACE pg_default;
88

99
INSERT INTO
10-
public.time_series_mapping (entity, time_series)
10+
public.time_series_mapping (participant, time_series)
1111
VALUES
1212
('b86e95b0-e579-4a80-a534-37c7a470a409', '9185b8c1-86ba-4a16-8dea-5ac898e8caa5'),
1313
('c7ebcc6c-55fc-479b-aa6b-6fa82ccac6b8', '3fbfaa97-cff4-46d4-95ba-a95665e87c26'),

0 commit comments

Comments
 (0)