org.apache.hadoop.chukwa.datatrigger

Class HttpTriggerAction

java.lang.Object

org.apache.hadoop.chukwa.datatrigger.HttpTriggerAction

All Implemented Interfaces:

TriggerAction

public class HttpTriggerAction
extends Object
implements TriggerAction

Trigger action that makes an HTTP request when executed.

To use this trigger, two types of configurations must be set. First, this class must be configured to be invoked for a given trigger event. Second, the the relevant settings for the HTTP request(s) to be made must be set as described below.

The general format of this classes configs is chukwa.trigger.[eventName].http.[N].[paramName] where eventName is the name of the event the request values are bound to (see TriggerEvent), N is a counter for each request configured (starting at 1) and paramName is the request parameter being set.

Using the post demux success trigger event as an example, the first request to be fired would use the following configurations

• chukwa.trigger.post.demux.success.http.1.url - The HTTP url to invoke.
• chukwa.trigger.post.demux.success.http.1.method - The HTTP method (optional, default=GET).
• chukwa.trigger.post.demux.success.http.1.headers - A comma-delimited set of HTTP headers (in [headerName]:[headerValue] form) to include (optional).
• chukwa.trigger.post.demux.success.http.1.body - The text HTTP body to include (optional).
• chukwa.trigger.post.demux.success.http.1.connect.timeout - The HTTP connection timeout setting in milliseconds (optional, default=5000ms).
• chukwa.trigger.post.demux.success.http.1.read.timeout - The HTTP read timeout setting in milliseconds (optional, default=5000ms).

See Also:

TriggerAction, TriggerEvent

Constructor Summary

Constructors

Constructor and Description
HttpTriggerAction()

Method Summary

Modifier and Type	Method and Description
void	execute(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.FileStatus[] src, TriggerEvent triggerEvent) Iterates over each URL found, fetched other settings and fires and HTTP request.

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpTriggerAction

public HttpTriggerAction()

Method Detail

execute

public void execute(org.apache.hadoop.conf.Configuration conf,
                    org.apache.hadoop.fs.FileSystem fs,
                    org.apache.hadoop.fs.FileStatus[] src,
                    TriggerEvent triggerEvent)
             throws IOException

Iterates over each URL found, fetched other settings and fires and HTTP request.

Specified by:

execute in interface TriggerAction

Parameters:

conf - is Chukwa configuration

fs - is HDFS File System

src - is list of sources to look for data

triggerEvent - is type of processing to happen

Throws:

IOException - if error in process triggers