Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/19902#discussion_r155389433
--- Diff:
sql/core/src/main/java/org/apache/spark/sql/sources/v2/DataSourceV2Options.java
---
@@ -49,4 +49,23 @@ public DataSourceV2Options(Map<String, String>
originalMap) {
public Optional<String> get(String key) {
return Optional.ofNullable(keyLowerCasedMap.get(toLowerCase(key)));
}
+
+ public boolean getBoolean(String key, boolean defaultValue) {
+ String lcaseKey = toLowerCase(key);
+ return keyLowerCasedMap.containsKey(lcaseKey) ?
+ Boolean.parseBoolean(keyLowerCasedMap.get(lcaseKey)) : defaultValue;
+ }
+
+ public int getInt(String key, int defaultValue) {
+ String lcaseKey = toLowerCase(key);
+ return keyLowerCasedMap.containsKey(lcaseKey) ?
+ Integer.parseInt(keyLowerCasedMap.get(lcaseKey)) : defaultValue;
+ }
+
+ public long getLong(String key, long defaultValue) {
--- End diff --
/** Get a parameter as a long, falling back to a default if not set */
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
