org.apache.drill.exec.rpc.control

Class WorkEventBus

java.lang.Object

org.apache.drill.exec.rpc.control.WorkEventBus

public class WorkEventBus
extends Object

Constructor Summary

Constructors

Constructor and Description
WorkEventBus()

Method Summary

Modifier and Type	Method and Description
void	addFragmentManager(FragmentManager fragmentManager)
void	addFragmentStatusListener(UserBitShared.QueryId queryId, FragmentStatusListener listener)
FragmentManager	getFragmentManager(ExecProtos.FragmentHandle handle)
boolean	removeFragmentManager(ExecProtos.FragmentHandle handle, boolean cancel) Optionally cancels and removes fragment manager (for the corresponding the handle) from the work event bus.
void	removeFragmentStatusListener(UserBitShared.QueryId queryId)
void	statusUpdate(BitControl.FragmentStatus status)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkEventBus

public WorkEventBus()

Method Detail

removeFragmentStatusListener

public void removeFragmentStatusListener(UserBitShared.QueryId queryId)

addFragmentStatusListener

public void addFragmentStatusListener(UserBitShared.QueryId queryId,
                                      FragmentStatusListener listener)
                               throws ForemanSetupException

Throws:

ForemanSetupException

statusUpdate

public void statusUpdate(BitControl.FragmentStatus status)

addFragmentManager

public void addFragmentManager(FragmentManager fragmentManager)

getFragmentManager

public FragmentManager getFragmentManager(ExecProtos.FragmentHandle handle)

removeFragmentManager

public boolean removeFragmentManager(ExecProtos.FragmentHandle handle,
                                     boolean cancel)

Optionally cancels and removes fragment manager (for the corresponding the handle) from the work event bus. Currently, used for fragments waiting on data (root and intermediate). This method can be called multiple times. The manager will be removed only once (the first call).

Parameters:

handle - the handle to the fragment

cancel -

Returns:

if the fragment was found and removed from the event bus