Package org.apache.spark.sql.streaming
Class SafeJsonSerializer
Object
org.apache.spark.sql.streaming.SafeJsonSerializer
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic org.json4s.JValuesafeDecimalToJValue(double value) Convert BigDecimal to JValue while handling empty or infinite valuesstatic org.json4s.JValuesafeDoubleToJValue(double value) Convert Double to JValue while handling empty or infinite valuesstatic <T> org.json4s.JValuesafeMapToJValue(Map<String, T> map, scala.Function1<T, org.json4s.JValue> valueToJValue) Convert map to JValue while handling empty maps.
-
Constructor Details
-
SafeJsonSerializer
public SafeJsonSerializer()
-
-
Method Details
-
safeDoubleToJValue
public static org.json4s.JValue safeDoubleToJValue(double value) Convert Double to JValue while handling empty or infinite values -
safeMapToJValue
public static <T> org.json4s.JValue safeMapToJValue(Map<String, T> map, scala.Function1<T, org.json4s.JValue> valueToJValue) Convert map to JValue while handling empty maps. Also, this sorts the keys. -
safeDecimalToJValue
public static org.json4s.JValue safeDecimalToJValue(double value) Convert BigDecimal to JValue while handling empty or infinite values
-