Package org.apache.spark.sql.pipelines.logging

Class PipelineEvent

Object

org.apache.spark.sql.pipelines.logging.PipelineEvent

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public class PipelineEvent
extends Object
implements scala.Product, Serializable

An internal event that is emitted during the run of a pipeline. param: id A globally unique id param: timestamp The time of the event param: origin Where the event originated from param: level Security level of the event param: message A user friendly description of the event param: details The details of the event param: error An error that occurred during the event

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
PipelineEvent(String id, Timestamp timestamp, PipelineEventOrigin origin, EventLevel level, String message, EventDetails details, scala.Option<Throwable> error)

Method Summary

Modifier and Type	Method	Description
abstract static R	apply(T1 v1, T2 v2, T3 v3, T4 v4, T5 v5, T6 v6, T7 v7)
EventDetails	details()
scala.Option<Throwable>	error()
String	id()
EventLevel	level()
String	message()
String	messageWithError()	Combines the message and error (if any) into a single string
PipelineEventOrigin	origin()
Timestamp	timestamp()
static String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

PipelineEvent

public PipelineEvent(String id,
 Timestamp timestamp,
 PipelineEventOrigin origin,
 EventLevel level,
 String message,
 EventDetails details,
 scala.Option<Throwable> error)

Method Details

apply

public abstract static R apply(T1 v1,
 T2 v2,
 T3 v3,
 T4 v4,
 T5 v5,
 T6 v6,
 T7 v7)

toString

public static String toString()

id

public String id()

timestamp

public Timestamp timestamp()

origin

public PipelineEventOrigin origin()

level

public EventLevel level()

message

public String message()

details

public EventDetails details()

error

public scala.Option<Throwable> error()

messageWithError

public String messageWithError()

Combines the message and error (if any) into a single string