A C D E F G H I J M N O P R S T U V

A

addCassandraDataProperties(List<CassandraDataProperties>) - Method in class org.mule.modules.sparksql.SparkSqlConnector

Dynamically add new datasources from Cassandra database keyspaces and tables

addCsvAndAvroJars(SparkContext, FileDataProperties) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

addDrivers() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

addFileDataProperties(List<FileDataProperties>) - Method in class org.mule.modules.sparksql.SparkSqlConnector

Dynamically add new datasources from Hadoop HDFS files

addJarDrivers(SparkContext, JdbcDataProperties) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

addJdbcDataProperties(List<JdbcDataProperties>) - Method in class org.mule.modules.sparksql.SparkSqlConnector

Dynamically add new datasources from JDBC accesible databases

C

CassandraDataProperties - Class in org.mule.modules.sparksql.data

Cassandra data source configuration properties.

CassandraDataProperties() - Constructor for class org.mule.modules.sparksql.data.CassandraDataProperties

Default constructor

CassandraDataProperties(String, String) - Constructor for class org.mule.modules.sparksql.data.CassandraDataProperties

Create a new instance with next data:

colNames - Variable in class org.mule.modules.sparksql.util.RowAsMapIterator

connect(String, String, String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

Connect to Apache Spark Cluster

connectDataSources() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

Connect all defined data sources to the sql context

connectDataSources(FileDataProperties) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

Connect all defined data sources to the sql context

connectDataSources(JdbcDataProperties) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

Connect all defined data sources to the sql context

connectDataSources(CassandraDataProperties) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

Connect all defined data sources to the sql context

connectionId() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

login ID

ConnectorConfig - Class in org.mule.modules.sparksql.config

Spark SQL Configuration contains the required information to connect to a Apache Spark Cluster.

ConnectorConfig() - Constructor for class org.mule.modules.sparksql.config.ConnectorConfig

create(Class<?>[], ClassLoader) - Static method in class org.mule.modules.sparksql.cl.UrlDelegatingCl

Create a new instance of the runner that contains a classloader with the sources for the classes at "classOnJar".

customSql(String) - Method in class org.mule.modules.sparksql.SparkSqlConnector

Run an arbitraty SQL query through Spark SQL Context.

D

DataSenseResolver - Class in org.mule.modules.sparksql.datasense

Category which can differentiate between input or output MetaDataRetriever

DataSenseResolver() - Constructor for class org.mule.modules.sparksql.datasense.DataSenseResolver

dataSourceAvro(FileDataProperties) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

dataSourceCsv(FileDataProperties) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

describeEntity(MetaDataKey) - Method in class org.mule.modules.sparksql.datasense.DataSenseResolver

destroyRunner() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

disconnect() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

Disconnect

disconnect() - Method in class org.mule.modules.sparksql.SparkSqlConnector

Force global configuration disconnection.

dropTemporaryTable(String) - Method in class org.mule.modules.sparksql.SparkSqlConnector

Drop a temporary table present at the Spark SQL Context.

E

empty(String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

EmptyDataPropertyException - Exception in org.mule.modules.sparksql.exception

EmptyDataPropertyException(StatusCode, String) - Constructor for exception org.mule.modules.sparksql.exception.EmptyDataPropertyException

EmptyTableNameException - Exception in org.mule.modules.sparksql.exception

EmptyTableNameException(StatusCode, String) - Constructor for exception org.mule.modules.sparksql.exception.EmptyTableNameException

ensureRunner() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

executeSql(String) - Method in class org.mule.modules.sparksql.SparkSqlConnector

Execute sql in sql context

F

FileDataProperties - Class in org.mule.modules.sparksql.data

A single file at Hadoop HDFS to include and make available as a 'table' to the Apache Spark SQL Context.

FileDataProperties() - Constructor for class org.mule.modules.sparksql.data.FileDataProperties

Default constructor

FileDataProperties(String, String, String, Boolean) - Constructor for class org.mule.modules.sparksql.data.FileDataProperties

Create the configuration for a single file at Hadoop HDFS to include and make available as a 'table' to the Apache Spark SQL Context.

FileDataPropertiesException - Exception in org.mule.modules.sparksql.exception

FileDataPropertiesException(StatusCode, String) - Constructor for exception org.mule.modules.sparksql.exception.FileDataPropertiesException

FileDataTypeNotValidException - Exception in org.mule.modules.sparksql.exception

FileDataTypeNotValidException(StatusCode, String) - Constructor for exception org.mule.modules.sparksql.exception.FileDataTypeNotValidException

G

getAddCassandraJar() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getAdvancedSparkConf() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getAlias() - Method in class org.mule.modules.sparksql.data.FileDataProperties

see FileDataProperties.FileDataProperties(String, String, String, Boolean)

getCassandraIp() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getCassandraPort() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getColumnName() - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

getConfig() - Method in class org.mule.modules.sparksql.SparkSqlConnector

getDbTable() - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

getDriver() - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

getEntities() - Method in class org.mule.modules.sparksql.datasense.DataSenseResolver

getHeartbeatInterval() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getKeyspace() - Method in class org.mule.modules.sparksql.data.CassandraDataProperties

Retrieve Cassandra keyspace

getListCassandraDataProps() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getListFileDataProps() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getListJdbcDataProps() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getLocalIp() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getLocalPort() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getLowerBound() - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

getNumPartitions() - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

getSparkContext() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getSparkSqlContext() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getSqlContextType() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

getStatusCode() - Method in exception org.mule.modules.sparksql.exception.SparkSqlConnectorException

getTableName() - Method in class org.mule.modules.sparksql.data.CassandraDataProperties

Retrieve Cassandra table name (leave this value empty to import all tables at the keyspace)

getType() - Method in class org.mule.modules.sparksql.data.FileDataProperties

see FileDataProperties.FileDataProperties(String, String, String, Boolean)

getUpperBound() - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

getUri() - Method in class org.mule.modules.sparksql.data.FileDataProperties

see FileDataProperties.FileDataProperties(String, String, String, Boolean)

getUrl() - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

H

hasNext() - Method in class org.mule.modules.sparksql.util.RowAsMapIterator

I

innerConnect(String, String, String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

isAddJar() - Method in class org.mule.modules.sparksql.data.FileDataProperties

see FileDataProperties.FileDataProperties(String, String, String, Boolean)

isAddJar() - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

isConnected() - Method in class org.mule.modules.sparksql.config.ConnectorConfig

Test if Spark Context (driver) exists and is valid (connected if non local)

isSqlSelectValid(String) - Method in class org.mule.modules.sparksql.SparkSqlConnector

Validate sql select

J

JdbcDataProperties - Class in org.mule.modules.sparksql.data

A schema or table at a JDBC accesible database to include and make available as a 'table(s)' to the Apache Spark SQL Context.

JdbcDataProperties() - Constructor for class org.mule.modules.sparksql.data.JdbcDataProperties

Default constructor

JdbcDataProperties(String, String, String, Boolean) - Constructor for class org.mule.modules.sparksql.data.JdbcDataProperties

Create the configuration for a schema or table at a JDBC accesible database to include and make available as a 'table(s)' to the Apache Spark SQL Context.

JdbcDataPropertiesException - Exception in org.mule.modules.sparksql.exception

JdbcDataPropertiesException(StatusCode, String) - Constructor for exception org.mule.modules.sparksql.exception.JdbcDataPropertiesException

JdbcDataPropertiesException(StatusCode, String, Throwable) - Constructor for exception org.mule.modules.sparksql.exception.JdbcDataPropertiesException

M

mapFieldType(String) - Method in class org.mule.modules.sparksql.datasense.DataSenseResolver

N

next() - Method in class org.mule.modules.sparksql.util.RowAsMapIterator

notEqualsOperator() - Method in class org.mule.modules.sparksql.datasense.SparkSqlOperatorVisitor

O

org.mule.modules.sparksql - package org.mule.modules.sparksql

org.mule.modules.sparksql.cl - package org.mule.modules.sparksql.cl

org.mule.modules.sparksql.config - package org.mule.modules.sparksql.config

org.mule.modules.sparksql.data - package org.mule.modules.sparksql.data

org.mule.modules.sparksql.datasense - package org.mule.modules.sparksql.datasense

org.mule.modules.sparksql.exception - package org.mule.modules.sparksql.exception

org.mule.modules.sparksql.util - package org.mule.modules.sparksql.util

P

parent - Variable in class org.mule.modules.sparksql.cl.UrlDelegatingCl

R

remove() - Method in class org.mule.modules.sparksql.util.RowAsMapIterator

RowAsMapIterator - Class in org.mule.modules.sparksql.util

RowAsMapIterator(DataFrame) - Constructor for class org.mule.modules.sparksql.util.RowAsMapIterator

rowIterator - Variable in class org.mule.modules.sparksql.util.RowAsMapIterator

RowToListMap - Class in org.mule.modules.sparksql.util

run() - Method in interface org.mule.modules.sparksql.cl.Runnable

run(Runnable) - Method in class org.mule.modules.sparksql.cl.UrlDelegatingCl

Run "r" on a classloader that contains the sources for the classes passed on the "create" method and delegated to current ContextClassLoader.

Runnable - Interface in org.mule.modules.sparksql.cl

S

SEPARATOR - Static variable in class org.mule.modules.sparksql.config.ConnectorConfig

setAddCassandraJar(Boolean) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setAddJar(Boolean) - Method in class org.mule.modules.sparksql.data.FileDataProperties

see FileDataProperties.FileDataProperties(String, String, String, Boolean)

setAddJar(Boolean) - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

setAdvancedSparkConf(Map<String, String>) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setAlias(String) - Method in class org.mule.modules.sparksql.data.FileDataProperties

see FileDataProperties.FileDataProperties(String, String, String, Boolean)

setCassandraIp(String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setCassandraPort(String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setColumnName(String) - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

setConfig(ConnectorConfig) - Method in class org.mule.modules.sparksql.SparkSqlConnector

setConnector(SparkSqlConnector) - Method in class org.mule.modules.sparksql.datasense.DataSenseResolver

setDbTable(String) - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

setDriver(String) - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

setHeartbeatInterval(String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setKeyspace(String) - Method in class org.mule.modules.sparksql.data.CassandraDataProperties

Set Cassandra keyspace for this instance

setListCassandraDataProps(List<CassandraDataProperties>) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setListFileDataProps(List<FileDataProperties>) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setListJdbcDataProps(List<JdbcDataProperties>) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setLocalIp(String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setLocalPort(String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setLowerBound(Long) - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

setNumPartitions(Integer) - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

setSqlContextType(SparkSqlEnum.SqlContextType) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

setTableName(String) - Method in class org.mule.modules.sparksql.data.CassandraDataProperties

Set Cassandra table name for this instance (leave this value empty to import all tables at the keyspace)

setType(String) - Method in class org.mule.modules.sparksql.data.FileDataProperties

see FileDataProperties.FileDataProperties(String, String, String, Boolean)

setUpperBound(Long) - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

setUri(String) - Method in class org.mule.modules.sparksql.data.FileDataProperties

see FileDataProperties.FileDataProperties(String, String, String, Boolean)

setUrl(String) - Method in class org.mule.modules.sparksql.data.JdbcDataProperties

see JdbcDataProperties

SimpleSyntaxVisitor - Class in org.mule.modules.sparksql.datasense

Visitor used for translate DSQL to an simple query sintax

SimpleSyntaxVisitor() - Constructor for class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

SparkSqlConnector - Class in org.mule.modules.sparksql

Annypoint connector SparkSql enables Apache Spark SQL to be used in Mule by providing integration inside Mule flows.

SparkSqlConnector() - Constructor for class org.mule.modules.sparksql.SparkSqlConnector

SparkSqlConnectorException - Exception in org.mule.modules.sparksql.exception

SparkSqlConnectorException(StatusCode, String) - Constructor for exception org.mule.modules.sparksql.exception.SparkSqlConnectorException

SparkSqlConnectorException(StatusCode, String, Throwable) - Constructor for exception org.mule.modules.sparksql.exception.SparkSqlConnectorException

SparkSqlEnum - Class in org.mule.modules.sparksql.data

SparkSqlEnum() - Constructor for class org.mule.modules.sparksql.data.SparkSqlEnum

SparkSqlEnum.SqlContextType - Enum in org.mule.modules.sparksql.data

SparkSqlOperatorVisitor - Class in org.mule.modules.sparksql.datasense

SparkSqlOperatorVisitor() - Constructor for class org.mule.modules.sparksql.datasense.SparkSqlOperatorVisitor

sqlSelect(String, String, Boolean) - Method in class org.mule.modules.sparksql.SparkSqlConnector

SQL Select

SqlSelectNotValidException - Exception in org.mule.modules.sparksql.exception

SqlSelectNotValidException(StatusCode, String) - Constructor for exception org.mule.modules.sparksql.exception.SqlSelectNotValidException

StatusCode - Enum in org.mule.modules.sparksql.exception

T

testConnect(String, String, String) - Method in class org.mule.modules.sparksql.config.ConnectorConfig

Test Connect

toListMap(DataFrame) - Static method in class org.mule.modules.sparksql.util.RowToListMap

toMap(Row) - Method in class org.mule.modules.sparksql.util.RowAsMapIterator

toNativeQuery(DsqlQuery) - Method in class org.mule.modules.sparksql.SparkSqlConnector

toSimpleQuery() - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

toString() - Method in class org.mule.modules.sparksql.cl.UrlDelegatingCl

U

UrlDelegatingCl - Class in org.mule.modules.sparksql.cl

An utility class to execute under a diferent classloader.

UrlDelegatingCl(URL[], ClassLoader) - Constructor for class org.mule.modules.sparksql.cl.UrlDelegatingCl

urls - Variable in class org.mule.modules.sparksql.cl.UrlDelegatingCl

V

validateAlias(String) - Static method in class org.mule.modules.sparksql.util.Validation

validateCassandraDataProperties(CassandraDataProperties) - Static method in class org.mule.modules.sparksql.util.Validation

validateDriver(String) - Static method in class org.mule.modules.sparksql.util.Validation

validateFileDataProperties(FileDataProperties) - Static method in class org.mule.modules.sparksql.util.Validation

validateFileDataSeparators(FileDataProperties) - Static method in class org.mule.modules.sparksql.util.Validation

validateJdbcDataProperties(JdbcDataProperties) - Static method in class org.mule.modules.sparksql.util.Validation

validateNoEmptyField(String) - Static method in class org.mule.modules.sparksql.util.Validation

validatePartition(String, Integer, String, Long, Long) - Static method in class org.mule.modules.sparksql.util.Validation

validateType(String) - Static method in class org.mule.modules.sparksql.util.Validation

validateUri(String) - Static method in class org.mule.modules.sparksql.util.Validation

Validation - Class in org.mule.modules.sparksql.util

valueOf(String) - Static method in enum org.mule.modules.sparksql.data.SparkSqlEnum.SqlContextType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.mule.modules.sparksql.exception.StatusCode

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.mule.modules.sparksql.data.SparkSqlEnum.SqlContextType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.mule.modules.sparksql.exception.StatusCode

Returns an array containing the constants of this enum type, in the order they are declared.

visitAnd() - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

visitBeginExpression() - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

visitComparison(String, Field, Value<?>) - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

This method translate an Dsql comparison

visitEndPrecedence() - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

Precedence delimiter. end.

visitFields(List<Field>) - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

visitInitPrecedence() - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

Precedence delimiter. init.

visitOR() - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

visitTypes(List<Type>) - Method in class org.mule.modules.sparksql.datasense.SimpleSyntaxVisitor

A C D E F G H I J M N O P R S T U V