Skip to content

Commit 61908d2

Browse files
final fixes
1 parent 8b929f6 commit 61908d2

File tree

4 files changed

+11
-13
lines changed

4 files changed

+11
-13
lines changed

src/main/java/edu/ie3/datamodel/io/connectors/CsvFileConnector.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,8 @@ public CsvFileConnector(Path baseDirectory) {
4040
super(baseDirectory);
4141
}
4242

43-
public CsvFileConnector(Path baseDirectory, Function<String, InputStream> inputStreamBuilder) {
44-
super(baseDirectory, inputStreamBuilder);
43+
public CsvFileConnector(Path baseDirectory, Function<String, InputStream> customInputStream) {
44+
super(baseDirectory, customInputStream);
4545
}
4646

4747
public synchronized BufferedCsvWriter getOrInitWriter(

src/main/java/edu/ie3/datamodel/io/connectors/FileConnector.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,9 @@ public abstract class FileConnector implements DataConnector {
1616

1717
protected final Path baseDirectory;
1818

19-
/** Optional factory for custom input streams; may be {@code null} to use the default handling. */
19+
/**
20+
* Optional factory for custom input streams; may be {@code null} when using the default handling.
21+
*/
2022
private final Function<String, InputStream> customInputStream;
2123

2224
protected FileConnector(Path baseDirectory) {

src/main/java/edu/ie3/datamodel/io/source/file/FileDataSource.java

Lines changed: 6 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -70,19 +70,18 @@ protected Set<Path> getTimeSeriesFilePaths(Pattern pattern) {
7070

7171
public Stream<FileIndividualTimeSeriesMetaInformation> getIndividualTimeSeriesMetaInformation(
7272
final ColumnScheme... columnSchemes) {
73-
FileNamingStrategy namingStrategy = getNamingStrategy();
74-
return getTimeSeriesFilePaths(namingStrategy.getIndividualTimeSeriesPattern()).parallelStream()
73+
return getTimeSeriesFilePaths(fileNamingStrategy.getIndividualTimeSeriesPattern())
74+
.parallelStream()
7575
.map(filePath -> resolveFileInformation(filePath, "individual time series"))
7676
.flatMap(Optional::stream)
7777
.map(
7878
fileMeta -> {
7979
IndividualTimeSeriesMetaInformation metaInformation =
80-
namingStrategy.individualTimeSeriesMetaInformation(
80+
fileNamingStrategy.individualTimeSeriesMetaInformation(
8181
fileMeta.filePath().toString());
8282
return new FileIndividualTimeSeriesMetaInformation(
8383
metaInformation, fileMeta.pathWithoutEnding(), fileMeta.fileType());
8484
})
85-
.filter(meta -> meta.getFileType() != null)
8685
.filter(
8786
metaInformation ->
8887
columnSchemes == null
@@ -99,20 +98,18 @@ public Stream<FileIndividualTimeSeriesMetaInformation> getIndividualTimeSeriesMe
9998
*/
10099
public Stream<FileLoadProfileMetaInformation> getLoadProfileMetaInformation(
101100
LoadProfile... profiles) {
102-
FileNamingStrategy namingStrategy = getNamingStrategy();
103-
104-
return getTimeSeriesFilePaths(namingStrategy.getLoadProfileTimeSeriesPattern()).parallelStream()
101+
return getTimeSeriesFilePaths(fileNamingStrategy.getLoadProfileTimeSeriesPattern())
102+
.parallelStream()
105103
.map(filePath -> resolveFileInformation(filePath, "load profile"))
106104
.flatMap(Optional::stream)
107105
.map(
108106
fileMeta -> {
109107
LoadProfileMetaInformation metaInformation =
110-
namingStrategy.loadProfileTimeSeriesMetaInformation(
108+
fileNamingStrategy.loadProfileTimeSeriesMetaInformation(
111109
fileMeta.filePath().toString());
112110
return new FileLoadProfileMetaInformation(
113111
metaInformation.getProfile(), fileMeta.pathWithoutEnding(), fileMeta.fileType());
114112
})
115-
.filter(meta -> meta.getFileType() != null)
116113
.filter(
117114
metaInformation ->
118115
profiles == null
Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@ import edu.ie3.datamodel.io.naming.FileNamingStrategy
1010
import edu.ie3.datamodel.io.naming.timeseries.ColumnScheme
1111
import edu.ie3.datamodel.io.naming.timeseries.FileIndividualTimeSeriesMetaInformation
1212
import edu.ie3.datamodel.io.source.csv.CsvTestDataMeta
13-
import edu.ie3.datamodel.io.source.file.FileTimeSeriesMetaInformationSource
1413
import spock.lang.Shared
1514
import spock.lang.Specification
1615

0 commit comments

Comments
 (0)