org.apache.spark

Class Heartbeat

Object

org.apache.spark.Heartbeat

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

public class Heartbeat
extends Object
implements scala.Product, scala.Serializable

A heartbeat from executors to the driver. This is a shared message used by several internal components to convey liveness or execution information for in-progress tasks.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Heartbeat(String executorId, scala.Tuple2<Object,org.apache.spark.executor.TaskMetrics>[] taskMetrics, BlockManagerId blockManagerId)

Method Summary

Methods

Modifier and Type	Method and Description
BlockManagerId	blockManagerId()
String	executorId()
scala.Tuple2<Object,org.apache.spark.executor.TaskMetrics>[]	taskMetrics()

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

Heartbeat

public Heartbeat(String executorId,
         scala.Tuple2<Object,org.apache.spark.executor.TaskMetrics>[] taskMetrics,
         BlockManagerId blockManagerId)

Method Detail

executorId

public String executorId()

taskMetrics

public scala.Tuple2<Object,org.apache.spark.executor.TaskMetrics>[] taskMetrics()

blockManagerId

public BlockManagerId blockManagerId()