cql

Type Members

1. trait AuthConf extends Serializable

   Stores credentials used to authenticate to a Cassandra cluster and uses them to configure a Cassandra connection.

2. trait AuthConfFactory extends AnyRef

   Obtains authentication configuration by reading SparkConf object.

3. trait CassandraConnectionFactory extends Serializable

   Creates both native and Thrift connections to Cassandra.

4. class CassandraConnector extends Serializable with Logging

   Provides and manages connections to Cassandra.

5. case class CassandraConnectorConf(hosts: Set[InetAddress], port: Int = ..., authConf: AuthConf = NoAuthConf, localDC: Option[String] = scala.None, keepAliveMillis: Int = ..., minReconnectionDelayMillis: Int = ..., maxReconnectionDelayMillis: Int = ..., compression: Compression = ..., queryRetryCount: Int = ..., connectTimeoutMillis: Int = ..., readTimeoutMillis: Int = ..., connectionFactory: CassandraConnectionFactory = DefaultConnectionFactory, cassandraSSLConf: CassandraSSLConf = ..., queryRetryDelay: RetryDelayConf = ...) extends Product with Serializable

   Stores configuration of a connection to Cassandra.

6. case class ClusteringColumn(index: Int) extends ColumnRole with Product with Serializable

7. case class ColumnDef(columnName: String, columnRole: ColumnRole, columnType: ColumnType[_], indexed: Boolean = false) extends FieldDef with Product with Serializable

   A Cassandra column metadata that can be serialized.

8. sealed trait ColumnRole extends AnyRef

9. trait FieldDef extends Serializable

   Abstract column / field definition.

10. case class KeyspaceDef(keyspaceName: String, tables: Set[TableDef]) extends Product with Serializable

    A Cassandra keyspace metadata that can be serialized.

11. class LocalNodeFirstLoadBalancingPolicy extends LoadBalancingPolicy with Logging

    Selects local node first and then nodes in local DC in random order.

12. class MultipleRetryPolicy extends RetryPolicy

    Always retries with the same CL, constant number of times, regardless of circumstances

13. case class PasswordAuthConf(user: String, password: String) extends AuthConf with Product with Serializable

    Performs plain-text password authentication.

14. class RefCountMap[T] extends AnyRef

    Atomically counts references to objects of any type

15. final class RefCountedCache[K, V] extends AnyRef

    A lockless cache that caches values for multiple users and destroys them once all users release them.

16. case class Schema(clusterName: String, keyspaces: Set[KeyspaceDef]) extends Product with Serializable

17. class SessionProxy extends InvocationHandler

    Wraps a Session and intercepts:

18. trait StructDef extends Serializable

    Cassandra structure that contains columnar information, e.

19. case class TableDef(keyspaceName: String, tableName: String, partitionKey: Seq[ColumnDef], clusteringColumns: Seq[ColumnDef], regularColumns: Seq[ColumnDef]) extends StructDef with Product with Serializable

    A Cassandra table metadata that can be serialized.