Skip to content

JsonProtocol

= JsonProtocol Utility :navtitle: JsonProtocol

JsonProtocol is an utility to convert SparkListenerEvents <> and <> JSON format.

JsonProtocol is used by spark-history-server:EventLoggingListener.md[] and spark-history-server:ReplayListenerBus.md[] (to spark-history-server:EventLoggingListener.md#logEvent[log] and spark-history-server:ReplayListenerBus.md#replay[replay] events for spark-history-server:index.md[], respectively).

== [[sparkEventFromJson]] sparkEventFromJson Utility

[source,scala]

sparkEventFromJson( json: JValue): SparkListenerEvent


sparkEventFromJson...FIXME

sparkEventFromJson is used when ReplayListenerBus is requested to spark-history-server:ReplayListenerBus.md#replay[replay].

== [[logStartToJson]] logStartToJson Utility

[source,scala]

logStartToJson( logStart: SparkListenerLogStart): JValue


logStartToJson...FIXME

logStartToJson is used when...FIXME

== [[taskEndFromJson]] taskEndFromJson Utility

[source,scala]

taskEndFromJson( json: JValue): SparkListenerTaskEnd


taskEndFromJson...FIXME

taskEndFromJson is used when JsonProtocol utility is used to <>.

== [[executorMetricsUpdateFromJson]] executorMetricsUpdateFromJson Utility

[source,scala]

executorMetricsUpdateFromJson( json: JValue): SparkListenerExecutorMetricsUpdate


executorMetricsUpdateFromJson...FIXME

executorMetricsUpdateFromJson is used when JsonProtocol utility is used to <>.

== [[taskEndReasonFromJson]] taskEndReasonFromJson Utility

[source,scala]

taskEndReasonFromJson( json: JValue): TaskEndReason


taskEndReasonFromJson...FIXME

taskEndReasonFromJson is used when JsonProtocol utility is used to <>.

== [[stageInfoFromJson]] stageInfoFromJson Utility

[source,scala]

stageInfoFromJson( json: JValue): StageInfo


stageInfoFromJson...FIXME

stageInfoFromJson is used when JsonProtocol utility is used to <>, <>, <>.

== [[taskInfoFromJson]] taskInfoFromJson Utility

[source,scala]

taskInfoFromJson( json: JValue): TaskInfo


taskInfoFromJson...FIXME

taskInfoFromJson is used when JsonProtocol utility is used to <>, <>, <>.

== [[accumulableInfoFromJson]] accumulableInfoFromJson Utility

[source,scala]

accumulableInfoFromJson( json: JValue): AccumulableInfo


accumulableInfoFromJson...FIXME

accumulableInfoFromJson is used when JsonProtocol utility is used to <>, <>, <>, <>.

== [[accumValueFromJson]] accumValueFromJson Utility

[source,scala]

accumValueFromJson( name: Option[String], value: JValue): Any


accumValueFromJson...FIXME

accumValueFromJson is used when JsonProtocol utility is used to <>.

== [[taskMetricsFromJson]] taskMetricsFromJson Utility

[source,scala]

taskMetricsFromJson( json: JValue): TaskMetrics


taskMetricsFromJson...FIXME

taskMetricsFromJson is used when JsonProtocol utility is used to <> and <>.

== [[taskEndToJson]] taskEndToJson Utility

[source,scala]

taskEndToJson( taskEnd: SparkListenerTaskEnd): JValue


taskEndToJson...FIXME

taskEndToJson is used when JsonProtocol utility is used to <> (serialize a SparkListenerEvent to JSON).

== [[taskMetricsToJson]] taskMetricsToJson Utility

[source,scala]

taskMetricsToJson( taskMetrics: TaskMetrics): JValue


taskMetricsToJson...FIXME

taskMetricsToJson is used when JsonProtocol utility is used to <>.

== [[blockUpdateFromJson]] blockUpdateFromJson Utility

[source,scala]

blockUpdateFromJson( json: JValue): SparkListenerBlockUpdated


blockUpdateFromJson...FIXME

blockUpdateFromJson is used when JsonProtocol utility is used to <>.

== [[blockUpdatedInfoFromJson]] blockUpdatedInfoFromJson Utility

[source,scala]

blockUpdatedInfoFromJson( json: JValue): BlockUpdatedInfo


blockUpdatedInfoFromJson...FIXME

blockUpdatedInfoFromJson is used when JsonProtocol utility is used to <>.


Last update: 2020-10-06