org.apache.tez.serviceplugins.api

Interface ServicePluginContextBase

All Known Subinterfaces:

ContainerLauncherContext, TaskSchedulerContext

public interface ServicePluginContextBase

Base interface for ServicePluginContexts

Method Summary

Methods

Modifier and Type	Method and Description
DagInfo	getCurrentDagInfo() Get information on the currently executing dag
UserPayload	getInitialUserPayload() Get the UserPayload that was configured while setting up the launcher
void	reportError(ServicePluginError servicePluginError, String message, DagInfo dagInfo) Report an error from the service.

Method Detail

getInitialUserPayload

UserPayload getInitialUserPayload()

Get the UserPayload that was configured while setting up the launcher

Returns:

the initially configured user payload

getCurrentDagInfo

@Nullable
DagInfo getCurrentDagInfo()

Get information on the currently executing dag

Returns:

info on the currently running dag, or null if no dag is executing

reportError

void reportError(@Nonnull
               ServicePluginError servicePluginError,
               String message,
               DagInfo dagInfo)

Report an error from the service. This results in the specific DAG being killed.

Parameters:

servicePluginError - the error category

message - A diagnostic message associated with this error

dagInfo - the affected dag