@@ -42,12 +42,12 @@ public class CsvFileConnector implements DataConnector {
4242  private  final  Map <UUID , BufferedCsvWriter > timeSeriesWriters  = new  HashMap <>();
4343
4444  private  final  FileNamingStrategy  fileNamingStrategy ;
45-   private  final  Path  baseDirectoryName ;
45+   private  final  Path  baseDirectory ;
4646
4747  private  static  final  String  FILE_ENDING  = ".csv" ;
4848
49-   public  CsvFileConnector (Path  baseDirectoryName , FileNamingStrategy  fileNamingStrategy ) {
50-     this .baseDirectoryName  = baseDirectoryName ;
49+   public  CsvFileConnector (Path  baseDirectory , FileNamingStrategy  fileNamingStrategy ) {
50+     this .baseDirectory  = baseDirectory ;
5151    this .fileNamingStrategy  = fileNamingStrategy ;
5252  }
5353
@@ -61,7 +61,7 @@ public synchronized BufferedCsvWriter getOrInitWriter(
6161    /* If it is not available, build and register one */ 
6262    try  {
6363      CsvFileDefinition  fileDefinition  = buildFileDefinition (clz , headerElements , csvSep );
64-       BufferedCsvWriter  newWriter  = initWriter (baseDirectoryName , fileDefinition );
64+       BufferedCsvWriter  newWriter  = initWriter (baseDirectory , fileDefinition );
6565
6666      entityWriters .put (clz , newWriter );
6767      return  newWriter ;
@@ -81,7 +81,7 @@ BufferedCsvWriter getOrInitWriter(T timeSeries, String[] headerElements, String
8181    /* If it is not available, build and register one */ 
8282    try  {
8383      CsvFileDefinition  fileDefinition  = buildFileDefinition (timeSeries , headerElements , csvSep );
84-       BufferedCsvWriter  newWriter  = initWriter (baseDirectoryName , fileDefinition );
84+       BufferedCsvWriter  newWriter  = initWriter (baseDirectory , fileDefinition );
8585
8686      timeSeriesWriters .put (timeSeries .getUuid (), newWriter );
8787      return  newWriter ;
@@ -188,7 +188,7 @@ public BufferedReader initReader(Class<? extends UniqueEntity> clz)
188188   * @throws FileNotFoundException if no file with the provided file name can be found 
189189   */ 
190190  public  BufferedReader  initReader (Path  filePath ) throws  FileNotFoundException  {
191-     File  fullPath  = baseDirectoryName .resolve (filePath .toString () + FILE_ENDING ).toFile ();
191+     File  fullPath  = baseDirectory .resolve (filePath .toString () + FILE_ENDING ).toFile ();
192192    return  new  BufferedReader (
193193        new  InputStreamReader (new  FileInputStream (fullPath ), StandardCharsets .UTF_8 ), 16384 );
194194  }
@@ -228,10 +228,9 @@ public BufferedReader initReader(Path filePath) throws FileNotFoundException {
228228   * @return A set of relative paths to time series files, with respect to the base folder path 
229229   */ 
230230  private  Set <Path > getIndividualTimeSeriesFilePaths () {
231-     Path  baseDirectoryPath  = baseDirectoryName .resolve (baseDirectoryName );
232-     try  (Stream <Path > pathStream  = Files .walk (baseDirectoryPath )) {
231+     try  (Stream <Path > pathStream  = Files .walk (baseDirectory )) {
233232      return  pathStream 
234-           .map (baseDirectoryPath ::relativize )
233+           .map (baseDirectory ::relativize )
235234          .filter (
236235              path  -> {
237236                Path  withoutEnding  =
0 commit comments