Serialized Form

Package org.wso2.carbon.analytics.spark.event

Class org.wso2.carbon.analytics.spark.event.EventIteratorFunction extends scala.runtime.AbstractFunction1<scala.collection.Iterator<org.apache.spark.sql.Row>,scala.runtime.BoxedUnit> implements Serializable

serialVersionUID:

4048303072566432397L

Serialized Fields

tenantId

int tenantId

streamId

String streamId

sch

org.apache.spark.sql.types.StructType sch

globalTenantAccess

boolean globalTenantAccess

Class org.wso2.carbon.analytics.spark.event.StreamRelation extends org.apache.spark.sql.sources.BaseRelation implements Serializable

serialVersionUID:

1628290158392312871L

Serialized Fields

sqlContext

org.apache.spark.sql.SQLContext sqlContext

schema

org.apache.spark.sql.types.StructType schema

streamId

String streamId

tenantId

int tenantId

globalTenantAccess

boolean globalTenantAccess