Skip to content

Commit

Permalink
Fix code style
Browse files Browse the repository at this point in the history
  • Loading branch information
kylase committed May 7, 2024
1 parent 7cb1772 commit 73fd5f7
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -726,7 +726,8 @@ public void processElement(ProcessContext context) throws IllegalArgumentExcepti
String dataType2 = field.schema().getTypes().get(1).getType().getName().toLowerCase();

// Check if Csv data is null.
if ((dataType1.equals("null") || dataType2.equals("null")) && csvRecord.get(index).isEmpty()) {
if ((dataType1.equals("null") || dataType2.equals("null"))
&& csvRecord.get(index).isEmpty()) {
genericRecord.put(field.name(), null);
} else {
// Add valid data type to generic record.
Expand Down

0 comments on commit 73fd5f7

Please sign in to comment.