object CassandraConnectorConf extends Logging with Serializable
A factory for CassandraConnectorConf objects. Allows for manually setting connection properties or reading them from SparkConf object. By embedding connection information in SparkConf, SparkContext can offer Cassandra specific methods which require establishing connections to a Cassandra cluster.
- Alphabetic
- By Inheritance
- CassandraConnectorConf
- Serializable
- Serializable
- Logging
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- case class CassandraSSLConf(enabled: Boolean = false, trustStorePath: Option[String] = None, trustStorePassword: Option[String] = None, trustStoreType: String = "JKS", protocol: String = "TLS", enabledAlgorithms: Set[String] = ..., clientAuthEnabled: Boolean = false, keyStorePath: Option[String] = None, keyStorePassword: Option[String] = None, keyStoreType: String = "JKS") extends Product with Serializable
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- val CloudBasedConfigurationParam: ConfigParameter[Option[String]]
- val CompressionParam: ConfigParameter[String]
- val ConnectionHostParam: ConfigParameter[String]
- val ConnectionPortParam: ConfigParameter[Int]
- val ConnectionTimeoutParam: ConfigParameter[Int]
- val DefaultCassandraSSLConf: CassandraSSLConf
- val DeprecatedConnectionTimeoutParam: DeprecatedConfigParameter[Int]
- val DeprecatedKeepAliveMillisParam: DeprecatedConfigParameter[Int]
- val DeprecatedLocalDCParam: DeprecatedConfigParameter[Option[String]]
- val DeprecatedMaxReconnectionDelayParam: DeprecatedConfigParameter[Int]
- val DeprecatedMinReconnectionDelayParam: DeprecatedConfigParameter[Int]
- val DeprecatedReadTimeoutParam: DeprecatedConfigParameter[Int]
- val KeepAliveMillisParam: ConfigParameter[Int]
- val LocalConnectionsPerExecutorParam: ConfigParameter[Option[Int]]
- val LocalDCParam: ConfigParameter[Option[String]]
- val MaxReconnectionDelayParam: ConfigParameter[Int]
- val MinReconnectionDelayParam: ConfigParameter[Int]
- val ProfileFileBasedConfigurationParam: ConfigParameter[Option[String]]
- val QueryRetryParam: ConfigParameter[Int]
- val QuietPeriodBeforeCloseParam: ConfigParameter[Int]
- val ReadTimeoutParam: ConfigParameter[Int]
- val ReferenceSection: String
- val ReferenceSectionAlternativeConnection: String
- val ReferenceSectionSSL: String
- val RemoteConnectionsPerExecutorParam: ConfigParameter[Option[Int]]
- val ResolveContactPoints: ConfigParameter[Boolean]
- val SSLClientAuthEnabledParam: ConfigParameter[Boolean]
- val SSLEnabledAlgorithmsParam: ConfigParameter[Set[String]]
- val SSLEnabledParam: ConfigParameter[Boolean]
- val SSLKeyStorePasswordParam: ConfigParameter[Option[String]]
- val SSLKeyStorePathParam: ConfigParameter[Option[String]]
- val SSLKeyStoreTypeParam: ConfigParameter[String]
- val SSLProtocolParam: ConfigParameter[String]
- val SSLTrustStorePasswordParam: ConfigParameter[Option[String]]
- val SSLTrustStorePathParam: ConfigParameter[Option[String]]
- val SSLTrustStoreTypeParam: ConfigParameter[String]
- val TimeoutBeforeCloseParam: ConfigParameter[Int]
- def apply(conf: SparkConf): CassandraConnectorConf
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def fromConnectionParams(params: Map[String, String]): CassandraConnectorConf
- def fromSparkConf(conf: SparkConf): CassandraConnectorConf
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
getContactInfoFromSparkConf(conf: SparkConf): ContactInfo
Determine how we should be connecting to Cassandra for this configuration
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
isTraceEnabled(): Boolean
- Attributes
- protected
- Definition Classes
- Logging
-
def
log: Logger
- Attributes
- protected
- Definition Classes
- Logging
-
def
logDebug(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logDebug(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logError(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logError(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logInfo(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logInfo(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logName: String
- Attributes
- protected
- Definition Classes
- Logging
-
def
logTrace(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logTrace(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logWarning(msg: ⇒ String, throwable: Throwable): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
def
logWarning(msg: ⇒ String): Unit
- Attributes
- protected
- Definition Classes
- Logging
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()