Skip to content

Commit 48fef7b

Browse files
committed
fmt
1 parent 46fd758 commit 48fef7b

File tree

1 file changed

+13
-13
lines changed

1 file changed

+13
-13
lines changed

src/main/java/edu/ie3/datamodel/io/sink/CsvFileSink.java

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -324,19 +324,19 @@ private <C extends UniqueEntity> void write(C entity) {
324324
LinkedHashMap<String, String> entityFieldData;
325325
try {
326326
entityFieldData =
327-
processorProvider
328-
.handleEntity(entity)
329-
.map(this::csvEntityFieldData)
330-
.orElseThrow(
331-
() ->
332-
new SinkException(
333-
"Cannot persist entity of type '"
334-
+ entity.getClass().getSimpleName()
335-
+ "'. This sink can only process the following entities: ["
336-
+ processorProvider.getRegisteredClasses().stream()
337-
.map(Class::getSimpleName)
338-
.collect(Collectors.joining(","))
339-
+ "]"));
327+
processorProvider
328+
.handleEntity(entity)
329+
.map(this::csvEntityFieldData)
330+
.orElseThrow(
331+
() ->
332+
new SinkException(
333+
"Cannot persist entity of type '"
334+
+ entity.getClass().getSimpleName()
335+
+ "'. This sink can only process the following entities: ["
336+
+ processorProvider.getRegisteredClasses().stream()
337+
.map(Class::getSimpleName)
338+
.collect(Collectors.joining(","))
339+
+ "]"));
340340

341341
String[] headerElements = processorProvider.getHeaderElements(entity.getClass());
342342
BufferedCsvWriter writer =

0 commit comments

Comments
 (0)