org.apache.hadoop.hive.llap.daemon.impl

Interface Scheduler<T>

All Known Implementing Classes:

TaskExecutorService

public interface Scheduler<T>

Task scheduler interface

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	Scheduler.SubmissionState

Method Summary

Modifier and Type	Method and Description
QueryIdentifier	findQueryByFragment(String fragmentId)
Set<String>	getExecutorsStatusForReporting()
int	getNumActiveForReporting()
void	killFragment(String fragmentId) Attempt to kill the fragment with the specified fragmentId
Scheduler.SubmissionState	schedule(T t) Schedule the task or throw RejectedExecutionException if queues are full
boolean	updateFragment(String fragmentId, boolean isGuaranteed)

Method Detail

schedule

Scheduler.SubmissionState schedule(T t)

Schedule the task or throw RejectedExecutionException if queues are full

Parameters:

t - - task to schedule

Returns:

SubmissionState

killFragment

void killFragment(String fragmentId)

Attempt to kill the fragment with the specified fragmentId

Parameters:

fragmentId -

getExecutorsStatusForReporting

Set<String> getExecutorsStatusForReporting()

getNumActiveForReporting

int getNumActiveForReporting()

findQueryByFragment

QueryIdentifier findQueryByFragment(String fragmentId)

updateFragment

boolean updateFragment(String fragmentId,
                       boolean isGuaranteed)