org.apache.lens.server.query

Class QueryEndNotifier

java.lang.Object

org.apache.lens.server.api.events.AsyncEventListener<QueryEnded>

org.apache.lens.server.query.QueryEndNotifier

All Implemented Interfaces:

LensEventListener<QueryEnded>

public class QueryEndNotifier
extends AsyncEventListener<QueryEnded>

The Class QueryEndNotifier.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	QueryEndNotifier.Email

Field Summary

Fields

Modifier and Type	Field and Description
static String	EMAIL_ERROR_COUNTER The Constant EMAIL_ERROR_COUNTER.

Fields inherited from interface org.apache.lens.server.api.events.LensEventListener

HANDLER_METHOD_NAME

Constructor Summary

Constructors

Constructor and Description
QueryEndNotifier(QueryExecutionServiceImpl queryService, org.apache.hadoop.hive.conf.HiveConf hiveConf, LogSegregationContext logSegregationContext) Instantiates a new query end notifier.

Method Summary

Methods

Modifier and Type	Method and Description
void	process(QueryEnded event) Should implement the actual event handling.
static void	sendMail(String host, String port, QueryEndNotifier.Email email, int mailSmtpTimeout, int mailSmtpConnectionTimeout) Send mail.

Methods inherited from class org.apache.lens.server.api.events.AsyncEventListener

getEventQueue, onEvent, stop

Methods inherited from class java.lang.Object

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

Field Detail

EMAIL_ERROR_COUNTER

public static final String EMAIL_ERROR_COUNTER

The Constant EMAIL_ERROR_COUNTER.

See Also:

Constant Field Values

Constructor Detail

QueryEndNotifier

public QueryEndNotifier(QueryExecutionServiceImpl queryService,
                org.apache.hadoop.hive.conf.HiveConf hiveConf,
                @NonNull
                LogSegregationContext logSegregationContext)

Instantiates a new query end notifier.

Parameters:

queryService - the query service

hiveConf - the hive conf

Method Detail

process

public void process(QueryEnded event)

Description copied from class: AsyncEventListener

Should implement the actual event handling.

Specified by:

process in class AsyncEventListener<QueryEnded>

Parameters:

event - the event

sendMail

public static void sendMail(String host,
            String port,
            QueryEndNotifier.Email email,
            int mailSmtpTimeout,
            int mailSmtpConnectionTimeout)
                     throws Exception

Send mail.

Parameters:

host - the host

port - the port

email - the email

mailSmtpTimeout - the mail smtp timeout

mailSmtpConnectionTimeout - the mail smtp connection timeout

Throws:

Exception