View Source GoogleApi.Dataproc.V1.Model.SparkWrapperObject (google_api_dataproc v0.58.0)

Outer message that contains the data obtained from spark listener, packaged with information that is required to process it.

Attributes

appSummary (type: GoogleApi.Dataproc.V1.Model.AppSummary.t, default: nil) -
applicationEnvironmentInfo (type: GoogleApi.Dataproc.V1.Model.ApplicationEnvironmentInfo.t, default: nil) -
applicationId (type: String.t, default: nil) - Application Id created by Spark.
applicationInfo (type: GoogleApi.Dataproc.V1.Model.ApplicationInfo.t, default: nil) -
eventTimestamp (type: DateTime.t, default: nil) - VM Timestamp associated with the data object.
executorStageSummary (type: GoogleApi.Dataproc.V1.Model.ExecutorStageSummary.t, default: nil) -
executorSummary (type: GoogleApi.Dataproc.V1.Model.ExecutorSummary.t, default: nil) -
jobData (type: GoogleApi.Dataproc.V1.Model.JobData.t, default: nil) -
poolData (type: GoogleApi.Dataproc.V1.Model.PoolData.t, default: nil) -
processSummary (type: GoogleApi.Dataproc.V1.Model.ProcessSummary.t, default: nil) -
rddOperationGraph (type: GoogleApi.Dataproc.V1.Model.RddOperationGraph.t, default: nil) -
rddStorageInfo (type: GoogleApi.Dataproc.V1.Model.RddStorageInfo.t, default: nil) -
resourceProfileInfo (type: GoogleApi.Dataproc.V1.Model.ResourceProfileInfo.t, default: nil) -
sparkPlanGraph (type: GoogleApi.Dataproc.V1.Model.SparkPlanGraph.t, default: nil) -
speculationStageSummary (type: GoogleApi.Dataproc.V1.Model.SpeculationStageSummary.t, default: nil) -
sqlExecutionUiData (type: GoogleApi.Dataproc.V1.Model.SqlExecutionUiData.t, default: nil) -
stageData (type: GoogleApi.Dataproc.V1.Model.StageData.t, default: nil) -
streamBlockData (type: GoogleApi.Dataproc.V1.Model.StreamBlockData.t, default: nil) -
streamingQueryData (type: GoogleApi.Dataproc.V1.Model.StreamingQueryData.t, default: nil) -
streamingQueryProgress (type: GoogleApi.Dataproc.V1.Model.StreamingQueryProgress.t, default: nil) -
taskData (type: GoogleApi.Dataproc.V1.Model.TaskData.t, default: nil) -

Summary

Types

t()

Functions

decode(value, options)

Unwrap a decoded JSON object into its complex fields.

Types

t()

@type t() :: %GoogleApi.Dataproc.V1.Model.SparkWrapperObject{
  appSummary: GoogleApi.Dataproc.V1.Model.AppSummary.t() | nil,
  applicationEnvironmentInfo:
    GoogleApi.Dataproc.V1.Model.ApplicationEnvironmentInfo.t() | nil,
  applicationId: String.t() | nil,
  applicationInfo: GoogleApi.Dataproc.V1.Model.ApplicationInfo.t() | nil,
  eventTimestamp: DateTime.t() | nil,
  executorStageSummary:
    GoogleApi.Dataproc.V1.Model.ExecutorStageSummary.t() | nil,
  executorSummary: GoogleApi.Dataproc.V1.Model.ExecutorSummary.t() | nil,
  jobData: GoogleApi.Dataproc.V1.Model.JobData.t() | nil,
  poolData: GoogleApi.Dataproc.V1.Model.PoolData.t() | nil,
  processSummary: GoogleApi.Dataproc.V1.Model.ProcessSummary.t() | nil,
  rddOperationGraph: GoogleApi.Dataproc.V1.Model.RddOperationGraph.t() | nil,
  rddStorageInfo: GoogleApi.Dataproc.V1.Model.RddStorageInfo.t() | nil,
  resourceProfileInfo:
    GoogleApi.Dataproc.V1.Model.ResourceProfileInfo.t() | nil,
  sparkPlanGraph: GoogleApi.Dataproc.V1.Model.SparkPlanGraph.t() | nil,
  speculationStageSummary:
    GoogleApi.Dataproc.V1.Model.SpeculationStageSummary.t() | nil,
  sqlExecutionUiData: GoogleApi.Dataproc.V1.Model.SqlExecutionUiData.t() | nil,
  stageData: GoogleApi.Dataproc.V1.Model.StageData.t() | nil,
  streamBlockData: GoogleApi.Dataproc.V1.Model.StreamBlockData.t() | nil,
  streamingQueryData: GoogleApi.Dataproc.V1.Model.StreamingQueryData.t() | nil,
  streamingQueryProgress:
    GoogleApi.Dataproc.V1.Model.StreamingQueryProgress.t() | nil,
  taskData: GoogleApi.Dataproc.V1.Model.TaskData.t() | nil
}

Functions

decode(value, options)

@spec decode(struct(), keyword()) :: struct()

Unwrap a decoded JSON object into its complex fields.