Type Members

1.  case class ClusteringColumn(index: Int, sortDirection: SortingOrder = ClusteringColumn.Ascending) extends ColumnRole with Product with Serializable
2.  case class ColumnDef(columnName: String, columnRole: ColumnRole, columnType: ColumnType[_]) extends FieldDef with Product with Serializable

   A Cassandra column metadata that can be serialized.

3.  sealed trait ColumnRole extends AnyRef
4.  trait FieldDef extends Serializable

   Abstract column / field definition.

   Abstract column / field definition. Common to tables and user-defined types

5.  case class IndexDef(className: Option[String], target: String, indexName: String, options: Map[String, String]) extends Serializable with Product

   Cassandra Index Metadata that can be serialized

   Cassandra Index Metadata that can be serialized

   className

   If this index is custom, the name of the server-side implementation. Otherwise, empty.

6.  case class KeyspaceDef(keyspaceName: String, tables: Set[TableDef], userTypes: Set[UserDefinedType], isSystem: Boolean) extends Product with Serializable

   A Cassandra keyspace metadata that can be serialized.

7.  class LocalNodeFirstLoadBalancingPolicy extends LoadBalancingPolicy

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

   Selects local node first and then nodes in local DC in random order. Never selects nodes from other DCs. For writes, if a statement has a routing key set, this LBP is token aware - it prefers the nodes which are replicas of the computed token to the other nodes.

8.  class MultipleRetryPolicy extends RetryPolicy

   Always retries with the same CL (null forces the original statement CL see SPARKC-494), constant number of times, regardless of circumstances

   Always retries with the same CL (null forces the original statement CL see SPARKC-494), constant number of times, regardless of circumstances

   Retries indefinitely if maxRetryCount is -1

9.  class MultiplexingSchemaListener extends SchemaChangeListener

   Uses an internal TrieMap to collect incoming listeners based on their hashCodes.

   Uses an internal TrieMap to collect incoming listeners based on their hashCodes. This means that identical objects cannot be added, if you need to add the same SchemaListener more than once be sure that it is not the identical object.

10.  case class Schema(keyspaces: Set[KeyspaceDef]) extends Product with Serializable
11.  trait StructDef extends Serializable

    Cassandra structure that contains columnar information, e.g.

    Cassandra structure that contains columnar information, e.g. a table or a user defined type. This trait allows ColumnMapper to work on tables and user defined types. Cassandra tables and user defined types are similar in a way data are extracted from them, therefore a common interface to describe their metadata is handy.

12.  case class TableDef(keyspaceName: String, tableName: String, partitionKey: Seq[ColumnDef], clusteringColumns: Seq[ColumnDef], regularColumns: Seq[ColumnDef], indexes: Seq[IndexDef] = Seq.empty, isView: Boolean = false, ifNotExists: Boolean = false, tableOptions: Map[String, String] = Map()) extends StructDef with Product with Serializable

    A Cassandra table metadata that can be serialized.