File tree Expand file tree Collapse file tree 1 file changed +12
-12
lines changed 
src/main/java/edu/ie3/datamodel/io/sink Expand file tree Collapse file tree 1 file changed +12
-12
lines changed Original file line number Diff line number Diff line change @@ -324,19 +324,19 @@ private <C extends UniqueEntity> void write(C entity) {
324324    LinkedHashMap <String , String > entityFieldData ;
325325    try  {
326326      entityFieldData  =
327-           csvEntityFieldData (
328327              processorProvider 
329-                   .handleEntity (entity )
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-                                   + "]" )));
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  =
 
 
   
 
     
   
   
          
    
    
     
    
      
     
     
    You can’t perform that action at this time.
  
 
    
  
    
      
        
     
       
      
     
   
 
    
    
  
 
  
 
     
    
0 commit comments