org.apache.flink.runtime.operators.sort

Class UnilateralSortMerger.SortingThread<E>

java.lang.Object

java.lang.Thread

org.apache.flink.runtime.operators.sort.UnilateralSortMerger.ThreadBase<E>

org.apache.flink.runtime.operators.sort.UnilateralSortMerger.SortingThread<E>

All Implemented Interfaces:

Runnable, Thread.UncaughtExceptionHandler

Enclosing class:

UnilateralSortMerger<E>

protected static class UnilateralSortMerger.SortingThread<E>
extends UnilateralSortMerger.ThreadBase<E>

The thread that sorts filled buffers.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class org.apache.flink.runtime.operators.sort.UnilateralSortMerger.ThreadBase

queues

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SortingThread(ExceptionHandler<IOException> exceptionHandler, UnilateralSortMerger.CircularQueues<E> queues, AbstractInvokable parentTask) Creates a new sorting thread.

Method Summary

Modifier and Type	Method and Description
void	go() Entry point of the thread.

Methods inherited from class org.apache.flink.runtime.operators.sort.UnilateralSortMerger.ThreadBase

internalHandleException, isRunning, run, shutdown, uncaughtException

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

SortingThread

public SortingThread(ExceptionHandler<IOException> exceptionHandler,
                     UnilateralSortMerger.CircularQueues<E> queues,
                     AbstractInvokable parentTask)

Creates a new sorting thread.

Parameters:

exceptionHandler - The exception handler to call for all exceptions.

queues - The queues used to pass buffers between the threads.

parentTask - The task that started this thread. If non-null, it is used to register this thread.

Method Detail

go

public void go()
        throws IOException

Entry point of the thread.

Specified by:

go in class UnilateralSortMerger.ThreadBase<E>

Throws:

IOException - Exceptions that prohibit correct completion of the work may be thrown by the thread.