A C D E G I M O P S T U V

A

activate(ComponentContext) - Method in class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

addToStore(List<EventRecord>) - Static method in class org.wso2.carbon.analytics.spark.event.EventStreamDataStore

ANALYTICS_SPARK_EVENTING_TASK_NAME - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

ANALYTICS_SPARK_EVENTING_TASK_TYPE - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

apply(Iterator<Row>) - Method in class org.wso2.carbon.analytics.spark.event.EventIteratorFunction

C

CORRELATION_DATA - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

createRelation(SQLContext, Map<String, String>) - Method in class org.wso2.carbon.analytics.spark.event.EventStreamProvider

D

deactivate(ComponentContext) - Method in class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

DISABLE_EVENT_SINK_SYS_PROP - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

DISABLE_SPARK_EVENTING_TASK_SYS_PROP - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

E

EVENT_CORRELATION_DATA_PREFIX - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

EVENT_META_DATA_PREFIX - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

EventingComponent - Class in org.wso2.carbon.analytics.spark.event.internal

Declarative service component for spark evening.

EventingComponent() - Constructor for class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

EventingConstants - Class in org.wso2.carbon.analytics.spark.event

Event stream relation provider related constants.

EventingConstants() - Constructor for class org.wso2.carbon.analytics.spark.event.EventingConstants

EventingTask - Class in org.wso2.carbon.analytics.spark.event

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

EventingTask() - Constructor for class org.wso2.carbon.analytics.spark.event.EventingTask

EventIteratorFunction - Class in org.wso2.carbon.analytics.spark.event

Iterates over a resultset from the select query, builds events from them and publishes to the event stream.

EventIteratorFunction(int, String, StructType, boolean) - Constructor for class org.wso2.carbon.analytics.spark.event.EventIteratorFunction

EventRecord - Class in org.wso2.carbon.analytics.spark.event

EventRecord(int, String, List<Object>, List<Object>, List<Object>) - Constructor for class org.wso2.carbon.analytics.spark.event.EventRecord

EventStreamDataStore - Class in org.wso2.carbon.analytics.spark.event

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

EventStreamProvider - Class in org.wso2.carbon.analytics.spark.event

Implements org.apache.spark.sql.sources.RelationProvider This is called whenever a CREATE_TABLE or INSERT_OVERWRITE Spark query is executed.

EventStreamProvider() - Constructor for class org.wso2.carbon.analytics.spark.event.EventStreamProvider

execute() - Method in class org.wso2.carbon.analytics.spark.event.EventingTask

extractNextEventBatch() - Static method in class org.wso2.carbon.analytics.spark.event.EventStreamDataStore

G

getCorrelationEntries() - Method in class org.wso2.carbon.analytics.spark.event.EventRecord

getEventManagementService() - Static method in class org.wso2.carbon.analytics.spark.event.internal.ServiceHolder

getEventPublisherManagementService() - Static method in class org.wso2.carbon.analytics.spark.event.internal.ServiceHolder

getEventStreamService() - Static method in class org.wso2.carbon.analytics.spark.event.internal.ServiceHolder

getLocation(TaskServiceContext, TaskInfo) - Method in class org.wso2.carbon.analytics.spark.event.SparkEventingTaskLocationResolver

getMetaEntries() - Method in class org.wso2.carbon.analytics.spark.event.EventRecord

getPayloadEntries() - Method in class org.wso2.carbon.analytics.spark.event.EventRecord

getStreamId() - Method in class org.wso2.carbon.analytics.spark.event.EventRecord

getTaskService() - Static method in class org.wso2.carbon.analytics.spark.event.internal.ServiceHolder

getTenantId() - Method in class org.wso2.carbon.analytics.spark.event.EventRecord

I

init() - Method in class org.wso2.carbon.analytics.spark.event.EventingTask

init(Map<String, String>) - Method in class org.wso2.carbon.analytics.spark.event.SparkEventingTaskLocationResolver

initStore() - Static method in class org.wso2.carbon.analytics.spark.event.EventStreamDataStore

insert(DataFrame, boolean) - Method in class org.wso2.carbon.analytics.spark.event.StreamRelation

isDrop() - Method in class org.wso2.carbon.analytics.spark.event.internal.SparkEventingPublisherManagementService

M

META_DATA - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

O

org.wso2.carbon.analytics.spark.event - package org.wso2.carbon.analytics.spark.event

org.wso2.carbon.analytics.spark.event.internal - package org.wso2.carbon.analytics.spark.event.internal

P

PAYLOAD - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

S

schema() - Method in class org.wso2.carbon.analytics.spark.event.StreamRelation

ServiceHolder - Class in org.wso2.carbon.analytics.spark.event.internal

This class holds the OSGI services registered with declarative service component.

setDrop(boolean) - Method in class org.wso2.carbon.analytics.spark.event.internal.SparkEventingPublisherManagementService

setEventManagementService(EventManagementService) - Method in class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

setEventManagementService(EventManagementService) - Static method in class org.wso2.carbon.analytics.spark.event.internal.ServiceHolder

setEventPublisherManagementService(EventPublisherManagementService) - Static method in class org.wso2.carbon.analytics.spark.event.internal.ServiceHolder

setEventStreamService(EventStreamService) - Method in class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

setEventStreamService(EventStreamService) - Static method in class org.wso2.carbon.analytics.spark.event.internal.ServiceHolder

setProperties(Map<String, String>) - Method in class org.wso2.carbon.analytics.spark.event.EventingTask

setTaskService(TaskService) - Method in class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

setTaskService(TaskService) - Static method in class org.wso2.carbon.analytics.spark.event.internal.ServiceHolder

SPARK_EVENTING_TASK_RUN_INTERVAL_MS - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

SparkEventingPublisherManagementService - Class in org.wso2.carbon.analytics.spark.event.internal

EventPublisherManagementService implementation to check whether the current node is the active node or not.

SparkEventingPublisherManagementService() - Constructor for class org.wso2.carbon.analytics.spark.event.internal.SparkEventingPublisherManagementService

SparkEventingTaskLocationResolver - Class in org.wso2.carbon.analytics.spark.event

Task location resolver to always possibly schedule the task on the active receiver in an H/A scenario.

SparkEventingTaskLocationResolver() - Constructor for class org.wso2.carbon.analytics.spark.event.SparkEventingTaskLocationResolver

sqlContext() - Method in class org.wso2.carbon.analytics.spark.event.StreamRelation

STREAM_ID - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

STREAM_NAME - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

StreamRelation - Class in org.wso2.carbon.analytics.spark.event

Extends org.apache.spark.sql.sources.BaseRelation

StreamRelation(int, SQLContext, String, String, boolean) - Constructor for class org.wso2.carbon.analytics.spark.event.StreamRelation

T

TENANT_ID - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

U

unsetEventManagementService(EventManagementService) - Method in class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

unsetEventStreamService(EventStreamService) - Method in class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

unsetTaskService(TaskService) - Method in class org.wso2.carbon.analytics.spark.event.internal.EventingComponent

V

VERSION - Static variable in class org.wso2.carbon.analytics.spark.event.EventingConstants

A C D E G I M O P S T U V