org.mule.modules.sparksql.data

Class CassandraDataProperties

java.lang.Object

org.mule.modules.sparksql.data.CassandraDataProperties

public class CassandraDataProperties
extends Object

Cassandra data source configuration properties. Used to indicate which tables (and keyspaces) must be available to query from the Apache Spark SQL Context.

Constructor Summary

Constructors

Constructor and Description
CassandraDataProperties() Default constructor
CassandraDataProperties(String keyspace, String tableName) Create a new instance with next data:

Method Summary

Modifier and Type	Method and Description
String	getKeyspace() Retrieve Cassandra keyspace
String	getTableName() Retrieve Cassandra table name (leave this value empty to import all tables at the keyspace)
void	setKeyspace(String keyspace) Set Cassandra keyspace for this instance
void	setTableName(String tableName) Set Cassandra table name for this instance (leave this value empty to import all tables at the keyspace)

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraDataProperties

public CassandraDataProperties()

Default constructor

CassandraDataProperties

public CassandraDataProperties(String keyspace,
                               String tableName)

Create a new instance with next data:

Parameters:

keyspace - Cassandra keyspace

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

Method Detail

getKeyspace

public String getKeyspace()

Retrieve Cassandra keyspace

Returns:

Cassandra keyspace

setKeyspace

public void setKeyspace(String keyspace)

Set Cassandra keyspace for this instance

Parameters:

keyspace - Cassandra keyspace

getTableName

public String getTableName()

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

Returns:

Cassandra table name

setTableName

public void setTableName(String tableName)

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

Parameters:

tableName - Cassandra table name