Skip to content

Commit

Permalink
fix date -> instant
Browse files Browse the repository at this point in the history
  • Loading branch information
cesarecaccuri committed Sep 15, 2023
1 parent 8c4c97a commit b18e6b3
Showing 1 changed file with 1 addition and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,6 @@
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.logging.Logger;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
Expand Down Expand Up @@ -115,7 +114,7 @@ public void processNodoReEvent (
logger.info("processing "+(index+1)+" of "+properties.length);
// final Map<String,Object> reEvent = ObjectMapperUtils.readValue(reEvents.get(index), Map.class);
final Map<String,Object> reEvent = reEvents.get(index);
String partitionKey = ((String)reEvent.get(columnCreated)).substring(0,10);
String partitionKey = reEvent.get(columnCreated).toString().substring(0,10);
reEvent.put(partitionKeyColumnCreated,partitionKey);
properties[index].forEach((p,v)->{
String s = replaceDashWithUppercase(p);
Expand Down

0 comments on commit b18e6b3

Please sign in to comment.