Skip to content

Commit

Permalink
feat: handle Double, Float
Browse files Browse the repository at this point in the history
  • Loading branch information
tomasgarba committed Jan 31, 2024
1 parent e5aaa66 commit 60095b0
Showing 1 changed file with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -344,6 +344,10 @@ private void addSessionConfig(StreamingSession session) {
session.setOption(entry.getKey(), (boolean) entry.getValue());
} else if (entry.getValue() instanceof String) {
session.setOption(entry.getKey(), entry.getValue().toString());
} else if (entry.getValue() instanceof Float) {
session.setOption(entry.getKey(), ((Float) entry.getValue()).intValue());
} else if (entry.getValue() instanceof Double) {
session.setOption(entry.getKey(), ((Double) entry.getValue()).intValue());
}
}
}
Expand Down

0 comments on commit 60095b0

Please sign in to comment.