com.datastax.spark.connector.cql

CassandraConnectorConf

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.

Linear Supertypes
Serializable, Serializable, Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. CassandraConnectorConf
  2. Serializable
  3. Serializable
  4. Logging
  5. AnyRef
  6. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. case class CassandraSSLConf(enabled: Boolean = false, trustStorePath: Option[String] = scala.None, trustStorePassword: Option[String] = scala.None, trustStoreType: String = "JKS", protocol: String = "TLS", enabledAlgorithms: Set[String] = ...) extends Product with Serializable

  2. trait RetryDelayConf extends AnyRef

    Annotations
    @deprecated
    Deprecated

    (Since version 1.2.6, 1.3.2, 1.4.3, 1.5.1) delayed retrying has been disabled; see SPARKC-360

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. val CassandraConnectionSSLEnabledAlgorithmsDescription: String

  7. val CassandraConnectionSSLEnabledAlgorithmsProperty: String

  8. val CompressionParam: ConfigParameter[Compression]

  9. val ConnectionHostParam: ConfigParameter[String]

  10. val ConnectionPortParam: ConfigParameter[Int]

  11. val ConnectionTimeoutParam: ConfigParameter[Int]

  12. val DefaultCassandraSSLConf: CassandraSSLConf

  13. val DefaultSSLEnabledAlgorithms: Set[String]

  14. val KeepAliveMillisParam: ConfigParameter[Int]

  15. val LocalDCParam: ConfigParameter[Option[String]]

  16. val MaxReconnectionDelayParam: ConfigParameter[Int]

  17. val MinReconnectionDelayParam: ConfigParameter[Int]

  18. val Properties: Set[ConfigParameter[_]]

  19. val QueryRetryParam: ConfigParameter[Int]

  20. val ReadTimeoutParam: ConfigParameter[Int]

  21. val ReferenceSection: String

  22. val ReferenceSectionSSL: String

  23. val SSLEnabledAlgorithmsParam: ConfigParameter[Set[String]]

  24. val SSLEnabledParam: ConfigParameter[Boolean]

  25. val SSLProtocolParam: ConfigParameter[String]

  26. val SSLTrustStorePasswordParam: ConfigParameter[Option[String]]

  27. val SSLTrustStorePathParam: ConfigParameter[Option[String]]

  28. val SSLTrustStoreTypeParam: ConfigParameter[String]

  29. def apply(conf: SparkConf): CassandraConnectorConf

  30. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  31. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  33. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  34. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  35. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  36. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  37. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  38. def isTraceEnabled(): Boolean

    Attributes
    protected
    Definition Classes
    Logging
  39. def log: Logger

    Attributes
    protected
    Definition Classes
    Logging
  40. def logDebug(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  41. def logDebug(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  42. def logError(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  43. def logError(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  44. def logInfo(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  45. def logInfo(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  46. def logName: String

    Attributes
    protected
    Definition Classes
    Logging
  47. def logTrace(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  48. def logTrace(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  49. def logWarning(msg: ⇒ String, throwable: Throwable): Unit

    Attributes
    protected
    Definition Classes
    Logging
  50. def logWarning(msg: ⇒ String): Unit

    Attributes
    protected
    Definition Classes
    Logging
  51. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  52. final def notify(): Unit

    Definition Classes
    AnyRef
  53. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  54. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  55. def toString(): String

    Definition Classes
    AnyRef → Any
  56. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  57. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  58. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. val QueryRetryDelayParam: ConfigParameter[RetryDelayConf]

    Annotations
    @deprecated
    Deprecated

    (Since version 1.2.6, 1.3.2, 1.4.3, 1.5.1) delayed retrying has been disabled; see SPARKC-360

  2. object RetryDelayConf extends Serializable

    Annotations
    @deprecated
    Deprecated

    (Since version 1.2.6, 1.3.2, 1.4.3, 1.5.1) delayed retrying has been disabled; see SPARKC-360

Inherited from Serializable

Inherited from Serializable

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped