Packages

object CassandraSource

Java 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 create(session: CassandraSession, stmt: Statement[_]): Source[Row, NotUsed]

    Create a Source from a given statement.

    Create a Source from a given statement.

    See Querying data.

  2. def create(session: CassandraSession, cqlStatement: String, bindValues: AnyRef*): 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.

    Annotations
    @varargs()
  3. def fromCompletionStage(session: CassandraSession, stmt: CompletionStage[Statement[_]]): Source[Row, NotUsed]

    Create a Source from a given statement.

    Create a Source from a given statement.

    See Querying data.