org.apache.spark.storage

Class ShuffleFetchCompletionListener

Object

org.apache.spark.storage.ShuffleFetchCompletionListener

All Implemented Interfaces:

java.util.EventListener, TaskCompletionListener

public class ShuffleFetchCompletionListener
extends Object
implements TaskCompletionListener

A listener to be called at the completion of the ShuffleBlockFetcherIterator param: data the ShuffleBlockFetcherIterator to process

Constructor Summary

Constructors

Constructor and Description
ShuffleFetchCompletionListener(org.apache.spark.storage.ShuffleBlockFetcherIterator data)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.storage.ShuffleBlockFetcherIterator	data()
void	onComplete(TaskContext context)
void	onTaskCompletion(TaskContext context)

Methods inherited from class Object

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

Constructor Detail

ShuffleFetchCompletionListener

public ShuffleFetchCompletionListener(org.apache.spark.storage.ShuffleBlockFetcherIterator data)

Method Detail

data

public org.apache.spark.storage.ShuffleBlockFetcherIterator data()

onComplete

public void onComplete(TaskContext context)

onTaskCompletion

public void onTaskCompletion(TaskContext context)

Specified by:

onTaskCompletion in interface TaskCompletionListener