implicit final class CassandraSQLContextFunctions extends AnyVal
- Alphabetic
- By Inheritance
- CassandraSQLContextFunctions
- AnyVal
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new CassandraSQLContextFunctions(sqlContext: SQLContext)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
##(): Int
- Definition Classes
- Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
getClass(): Class[_ <: AnyVal]
- Definition Classes
- AnyVal → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val sqlContext: SQLContext
-
def
toString(): String
- Definition Classes
- Any
Deprecated Value Members
-
def
getCluster: String
Get current used cluster name
Get current used cluster name
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) Use SparkSession instead of SQLContext
-
def
setCassandraConf(cluster: String, keyspace: String, options: Map[String, String]): SQLContext
Set the Spark Cassandra Connector configuration parameters which will be used when accessing a given keyspace in a given cluster
Set the Spark Cassandra Connector configuration parameters which will be used when accessing a given keyspace in a given cluster
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) Use SparkSession instead of SQLContext
-
def
setCassandraConf(cluster: String, options: Map[String, String]): SQLContext
Set the Spark Cassandra Connector configuration parameters which will be used when accessing a given cluster
Set the Spark Cassandra Connector configuration parameters which will be used when accessing a given cluster
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) Use SparkSession instead of SQLContext
-
def
setCassandraConf(options: Map[String, String]): SQLContext
Set the Spark Cassandra Connector configuration parameters
Set the Spark Cassandra Connector configuration parameters
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) Use SparkSession instead of SQLContext
-
def
setCluster(cluster: String): SQLContext
Set current used cluster name
Set current used cluster name
- Annotations
- @deprecated
- Deprecated
(Since version 2.0.0) Use SparkSession instead of SQLContext