types

Type Members

trait CanBuildFrom[-Elem, To] extends Serializable

Serves the same purpose as standard Scala CanBuildFrom, however this one is Serializable.
sealed trait CassandraOption[+A] extends Product with Serializable

An Optional value with Cassandra in mind.
An Optional value with Cassandra in mind. There are three options Value(value): Representing a value to be inserted from C* Unset: Representing a value which should be skipped when writing to C* Null: Representing a java null, treated as a delete in C* (or empty collection)
class ChainedTypeConverter[T] extends NullableTypeConverter[T]

Chains together several converters converting to the same type.
Chains together several converters converting to the same type. This way you can extend functionality of any converter to support new input types.
trait CollectionColumnType[T] extends ColumnType[T]
trait ColumnType[T] extends Serializable

Serializable representation of column data type.
trait CustomDriverConverter extends AnyRef
case class ListType[T](elemType: ColumnType[T]) extends CollectionColumnType[Vector[T]] with Product with Serializable
case class MapType[K, V](keyType: ColumnType[K], valueType: ColumnType[V]) extends CollectionColumnType[Map[K, V]] with Product with Serializable
trait NullableTypeConverter[T] extends TypeConverter[T]

Handles nullable types and converts any null to null.
trait PrimitiveColumnType[T] extends ColumnType[T]
case class SetType[T](elemType: ColumnType[T]) extends CollectionColumnType[Set[T]] with Product with Serializable
case class TupleFieldDef(index: Int, columnType: ColumnType[_]) extends FieldDef with Product with Serializable
case class TupleType(componentTypes: TupleFieldDef*) extends StructDef with ColumnType[TupleValue] with Product with Serializable

A type representing typed tuples.
A type representing typed tuples. A tuple consists of a sequence of values. Every value is identified by its 0-based position. Every value can be of a different type.
class TypeConversionException extends Exception
trait TypeConverter[T] extends Serializable

Machinery for converting objects of any type received from Cassandra into objects of Scala types.
Machinery for converting objects of any type received from Cassandra into objects of Scala types. Every converter knows how to convert object to one type. See TypeConverter companion object for a list of available converters.
case class UDTFieldDef(columnName: String, columnType: ColumnType[_]) extends FieldDef with Product with Serializable

A Cassandra user defined type field metadata.
A Cassandra user defined type field metadata. It consists of a name and an associated column type. The word column instead of field is used in member names because we want to treat UDT field entries in the same way as table columns, so that they are mappable to case classes. This is also the reason why this class extends FieldDef
case class UserDefinedType(name: String, columns: IndexedSeq[UDTFieldDef]) extends StructDef with ColumnType[UDTValue] with Product with Serializable

A Cassandra user defined type metadata.
A Cassandra user defined type metadata. A UDT consists of a sequence of ordered fields, called columns.

Value Members

object AsciiType extends PrimitiveColumnType[String] with Product with Serializable
object BigIntType extends PrimitiveColumnType[Long] with Product with Serializable
object BlobType extends PrimitiveColumnType[ByteBuffer] with Product with Serializable
object BooleanType extends PrimitiveColumnType[Boolean] with Product with Serializable
object CanBuildFrom extends Serializable
object CassandraOption extends Serializable
object ColumnType extends Serializable
object ColumnTypeConf
object CounterType extends PrimitiveColumnType[Long] with Product with Serializable
object DateType extends PrimitiveColumnType[Int] with Product with Serializable
object DecimalType extends PrimitiveColumnType[BigDecimal] with Product with Serializable
object DoubleType extends PrimitiveColumnType[Double] with Product with Serializable
object FloatType extends PrimitiveColumnType[Float] with Product with Serializable
object InetType extends PrimitiveColumnType[InetAddress] with Product with Serializable
object IntType extends PrimitiveColumnType[Int] with Product with Serializable
object SmallIntType extends PrimitiveColumnType[Short] with Product with Serializable
object TextType extends PrimitiveColumnType[String] with Product with Serializable
object TimeType extends PrimitiveColumnType[Long] with Product with Serializable
object TimeUUIDType extends PrimitiveColumnType[UUID] with Product with Serializable
object TimestampFormatter

Formats timestamps and dates using CQL timestamp format yyyy-MM-dd HH:mm:ssZ
object TimestampParser

Parses CQL timestamps.
Parses CQL timestamps.
Supported formats:
- yyyy-MM-dd HH:mm
- yyyy-MM-dd HH:mmZ
- yyyy-MM-dd HH:mm:ss
- yyyy-MM-dd HH:mm:ssZ
- yyyy-MM-dd HH:mm:ss.SSS
- yyyy-MM-dd HH:mm:ss.SSSZ
- yyyy-MM-dd'T'HH:mm
- yyyy-MM-dd'T'HH:mmZ
- yyyy-MM-dd'T'HH:mm:ss
- yyyy-MM-dd'T'HH:mm:ssZ
- yyyy-MM-dd'T'HH:mm:ss.SSS
- yyyy-MM-dd'T'HH:mm:ss.SSSZ
- yyyy-MM-dd
- yyyy-MM-ddZ
object TimestampType extends PrimitiveColumnType[Date] with Product with Serializable
object TinyIntType extends PrimitiveColumnType[Byte] with Product with Serializable
object TupleType extends Serializable
object TypeConverter extends Serializable

Defines a set of converters and implicit functions used to look up an appropriate converter for a desired type.
Defines a set of converters and implicit functions used to look up an appropriate converter for a desired type. Thanks to implicit method lookup, it is possible to implement a generic method CassandraRow#get, which picks up the right converter basing solely on its type argument.
object UUIDType extends PrimitiveColumnType[UUID] with Product with Serializable
object Unset extends Serializable

An object representing a column which will be skipped on insert.
An object representing a column which will be skipped on insert.

Attributes
protected[com.datastax.spark.connector]
object UserDefinedType extends Serializable
object VarCharType extends PrimitiveColumnType[String] with Product with Serializable
object VarIntType extends PrimitiveColumnType[BigInt] with Product with Serializable

package types

Type Members

trait CanBuildFrom[-Elem, To] extends Serializable

sealed trait CassandraOption[+A] extends Product with Serializable

class ChainedTypeConverter[T] extends NullableTypeConverter[T]

trait CollectionColumnType[T] extends ColumnType[T]

trait ColumnType[T] extends Serializable

trait CustomDriverConverter extends AnyRef

case class ListType[T](elemType: ColumnType[T]) extends CollectionColumnType[Vector[T]] with Product with Serializable

case class MapType[K, V](keyType: ColumnType[K], valueType: ColumnType[V]) extends CollectionColumnType[Map[K, V]] with Product with Serializable

trait NullableTypeConverter[T] extends TypeConverter[T]

trait PrimitiveColumnType[T] extends ColumnType[T]

case class SetType[T](elemType: ColumnType[T]) extends CollectionColumnType[Set[T]] with Product with Serializable

case class TupleFieldDef(index: Int, columnType: ColumnType[_]) extends FieldDef with Product with Serializable

case class TupleType(componentTypes: TupleFieldDef*) extends StructDef with ColumnType[TupleValue] with Product with Serializable

class TypeConversionException extends Exception

trait TypeConverter[T] extends Serializable

case class UDTFieldDef(columnName: String, columnType: ColumnType[_]) extends FieldDef with Product with Serializable

case class UserDefinedType(name: String, columns: IndexedSeq[UDTFieldDef]) extends StructDef with ColumnType[UDTValue] with Product with Serializable

Value Members

object AsciiType extends PrimitiveColumnType[String] with Product with Serializable

object BigIntType extends PrimitiveColumnType[Long] with Product with Serializable

object BlobType extends PrimitiveColumnType[ByteBuffer] with Product with Serializable

object BooleanType extends PrimitiveColumnType[Boolean] with Product with Serializable

object CanBuildFrom extends Serializable

object CassandraOption extends Serializable

object ColumnType extends Serializable

object ColumnTypeConf

object CounterType extends PrimitiveColumnType[Long] with Product with Serializable

object DateType extends PrimitiveColumnType[Int] with Product with Serializable

object DecimalType extends PrimitiveColumnType[BigDecimal] with Product with Serializable

object DoubleType extends PrimitiveColumnType[Double] with Product with Serializable

object FloatType extends PrimitiveColumnType[Float] with Product with Serializable

object InetType extends PrimitiveColumnType[InetAddress] with Product with Serializable

object IntType extends PrimitiveColumnType[Int] with Product with Serializable

object SmallIntType extends PrimitiveColumnType[Short] with Product with Serializable

object TextType extends PrimitiveColumnType[String] with Product with Serializable

object TimeType extends PrimitiveColumnType[Long] with Product with Serializable

object TimeUUIDType extends PrimitiveColumnType[UUID] with Product with Serializable

object TimestampFormatter

object TimestampParser

object TimestampType extends PrimitiveColumnType[Date] with Product with Serializable

object TinyIntType extends PrimitiveColumnType[Byte] with Product with Serializable

object TupleType extends Serializable

object TypeConverter extends Serializable

object UUIDType extends PrimitiveColumnType[UUID] with Product with Serializable

object Unset extends Serializable

object UserDefinedType extends Serializable

object VarCharType extends PrimitiveColumnType[String] with Product with Serializable

object VarIntType extends PrimitiveColumnType[BigInt] with Product with Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped