org.apache.hadoop.hive.ql.exec.tez

Class InterruptibleProcessing

java.lang.Object

org.apache.hadoop.hive.ql.exec.tez.InterruptibleProcessing

Direct Known Subclasses:

RecordProcessor

public class InterruptibleProcessing
extends Object

Constructor Summary

Constructors

Constructor and Description
InterruptibleProcessing()

Method Summary

Modifier and Type	Method and Description
void	abort()
void	addRowAndMaybeCheckAbort()
void	checkAbortCondition()
boolean	isAborted()
void	setAborted(boolean b)
void	startAbortChecks()

Methods inherited from class java.lang.Object

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

Constructor Detail

InterruptibleProcessing

public InterruptibleProcessing()

Method Detail

startAbortChecks

public final void startAbortChecks()

addRowAndMaybeCheckAbort

public final void addRowAndMaybeCheckAbort()
                                    throws InterruptedException

Throws:

InterruptedException

checkAbortCondition

public final void checkAbortCondition()
                               throws InterruptedException

Throws:

InterruptedException

setAborted

public final void setAborted(boolean b)

abort

public void abort()

isAborted

public final boolean isAborted()