Package org.apache.spark.storage

Class ShuffleFetchCompletionListener

Object

org.apache.spark.storage.ShuffleFetchCompletionListener

All Implemented Interfaces:

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	Description
ShuffleFetchCompletionListener(org.apache.spark.storage.ShuffleBlockFetcherIterator data)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

ShuffleFetchCompletionListener

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

Method Details

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