org.wso2.carbon.analytics.spark.event

Class StreamRelation

java.lang.Object

org.apache.spark.sql.sources.BaseRelation

org.wso2.carbon.analytics.spark.event.StreamRelation

All Implemented Interfaces:

Serializable, org.apache.spark.sql.sources.InsertableRelation

public class StreamRelation
extends org.apache.spark.sql.sources.BaseRelation
implements org.apache.spark.sql.sources.InsertableRelation, Serializable

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamRelation(int tenantId, org.apache.spark.sql.SQLContext sqlContext, String streamId, String payloadString, boolean globalTenantAccess)

Method Summary

Methods

Modifier and Type	Method and Description
void	insert(org.apache.spark.sql.DataFrame data, boolean b)
org.apache.spark.sql.types.StructType	schema()
org.apache.spark.sql.SQLContext	sqlContext()

Methods inherited from class org.apache.spark.sql.sources.BaseRelation

needConversion, sizeInBytes

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamRelation

public StreamRelation(int tenantId,
              org.apache.spark.sql.SQLContext sqlContext,
              String streamId,
              String payloadString,
              boolean globalTenantAccess)

Method Detail

insert

public void insert(org.apache.spark.sql.DataFrame data,
          boolean b)

Specified by:

insert in interface org.apache.spark.sql.sources.InsertableRelation

sqlContext

public org.apache.spark.sql.SQLContext sqlContext()

Specified by:

sqlContext in class org.apache.spark.sql.sources.BaseRelation

schema

public org.apache.spark.sql.types.StructType schema()

Specified by:

schema in class org.apache.spark.sql.sources.BaseRelation