org.wso2.carbon.analytics.spark.event

Class EventStreamProvider

java.lang.Object

org.wso2.carbon.analytics.spark.event.EventStreamProvider

All Implemented Interfaces:

org.apache.spark.sql.sources.RelationProvider

public class EventStreamProvider
extends Object
implements org.apache.spark.sql.sources.RelationProvider

Implements org.apache.spark.sql.sources.RelationProvider This is called whenever a CREATE_TABLE or INSERT_OVERWRITE Spark query is executed. At the event of Spark's CREATE_TABLE query, this provider defines an event stream according to the parameters provided in the options sections of the query. At the event of Spark's INSERT_OVERWRITE query, this provider creates events from input table and publishes them into the stream that has been created previously.

Constructor Summary

Constructors

Constructor and Description
EventStreamProvider()

Method Summary

Methods

Modifier and Type	Method and Description
StreamRelation	createRelation(org.apache.spark.sql.SQLContext sqlContext, scala.collection.immutable.Map<String,String> parameters)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamProvider

public EventStreamProvider()

Method Detail

createRelation

public StreamRelation createRelation(org.apache.spark.sql.SQLContext sqlContext,
                            scala.collection.immutable.Map<String,String> parameters)

Specified by:

createRelation in interface org.apache.spark.sql.sources.RelationProvider