Packages

object TaskContext extends Serializable

Source
TaskContext.scala
Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TaskContext
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def get(): TaskContext

    Return the currently active TaskContext.

    Return the currently active TaskContext. This can be called inside of user functions to access contextual information about running tasks.

  2. def getPartitionId(): Int

    Returns the partition id of currently active TaskContext.

    Returns the partition id of currently active TaskContext. It will return 0 if there is no active TaskContext for cases like local execution.