Packages

object CassandraSource

Scala API.

Source
CassandraSource.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CassandraSource
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def apply(stmt: Statement[_])(implicit session: CassandraSession): Source[Row, NotUsed]

    Create a Source from a given statement.

    Create a Source from a given statement.

    See Querying data.

  2. def apply(cqlStatement: String, bindValues: AnyRef*)(implicit session: CassandraSession): Source[Row, NotUsed]

    Prepare, bind and execute a select statement in one go.

    Prepare, bind and execute a select statement in one go.

    See Querying data.

  3. def fromFuture(stmt: Future[Statement[_]])(implicit session: CassandraSession): Source[Row, NotUsed]

    Create a Source from a given statement.

    Create a Source from a given statement.

    See Querying data.