org.wso2.carbon.analytics.spark.event

Class EventingTask

java.lang.Object

org.wso2.carbon.analytics.spark.event.EventingTask

All Implemented Interfaces:

org.wso2.carbon.ntask.core.Task

public class EventingTask
extends Object
implements org.wso2.carbon.ntask.core.Task

Spark eventing scheduled task to read from the eventing data store and to dispatch the events to its respective streams.

Constructor Summary

Constructors

Constructor and Description
EventingTask()

Method Summary

Modifier and Type	Method and Description
void	execute()
void	init()
void	setProperties(Map<String,String> props)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventingTask

public EventingTask()

Method Detail

init

public void init()

Specified by:

init in interface org.wso2.carbon.ntask.core.Task

setProperties

public void setProperties(Map<String,String> props)

Specified by:

setProperties in interface org.wso2.carbon.ntask.core.Task

execute

public void execute()

Specified by:

execute in interface org.wso2.carbon.ntask.core.Task