org.apache.spark.sql.streaming

Class SafeJsonSerializer

Object

org.apache.spark.sql.streaming.SafeJsonSerializer

public class SafeJsonSerializer
extends Object

Constructor Summary

Constructors

Constructor and Description
SafeJsonSerializer()

Method Summary

Modifier and Type	Method and Description
static org.json4s.JsonAST.JValue	safeDoubleToJValue(double value)
static <T> org.json4s.JsonAST.JValue	safeMapToJValue(java.util.Map<String,T> map, scala.Function1<T,org.json4s.JsonAST.JValue> valueToJValue) Convert map to JValue while handling empty maps.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SafeJsonSerializer

public SafeJsonSerializer()

Method Detail

safeDoubleToJValue

public static org.json4s.JsonAST.JValue safeDoubleToJValue(double value)

safeMapToJValue

public static <T> org.json4s.JsonAST.JValue safeMapToJValue(java.util.Map<String,T> map,
                                                            scala.Function1<T,org.json4s.JsonAST.JValue> valueToJValue)

Convert map to JValue while handling empty maps. Also, this sorts the keys.