Package org.apache.spark.sql.streaming

Class SafeJsonSerializer

Object

org.apache.spark.sql.streaming.SafeJsonSerializer

public class SafeJsonSerializer
extends Object

Constructor Summary

Constructors

Constructor	Description
SafeJsonSerializer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

SafeJsonSerializer

public SafeJsonSerializer()

Method Details

safeDoubleToJValue

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

safeMapToJValue

public static <T> org.json4s.JsonAST.JValue safeMapToJValue(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.