org.wso2.carbon.analytics.spark.event

Class EventStreamDataStore

java.lang.Object

org.wso2.carbon.analytics.spark.event.EventStreamDataStore

public class EventStreamDataStore
extends Object

This class represents the data store used to store the events destined to specific streams.

Method Summary

Methods

Modifier and Type	Method and Description
static void	addToStore(List<EventRecord> eventRecordList)
static Map<Integer,List<org.wso2.carbon.databridge.commons.Event>>	extractNextEventBatch()
static void	initStore()

Methods inherited from class java.lang.Object

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

Method Detail

initStore

public static void initStore()
                      throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

addToStore

public static void addToStore(List<EventRecord> eventRecordList)
                       throws org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

Throws:

org.wso2.carbon.analytics.datasource.commons.exception.AnalyticsException

extractNextEventBatch

public static Map<Integer,List<org.wso2.carbon.databridge.commons.Event>> extractNextEventBatch()