Class

com.datastax.spark.connector.cql

ReplicaAwareStatement

Related Doc: package cql

Permalink

class ReplicaAwareStatement extends StatementWrapper

Associates given statement with a set of replica addresses. It is meant to be interpreted by LoadBalancingPolicy implementations, like LocalNodeFirstLoadBalancingPolicy.

Linear Supertypes
StatementWrapper, Statement, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReplicaAwareStatement
  2. StatementWrapper
  3. Statement
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ReplicaAwareStatement(wrapped: Statement, replicas: Set[InetAddress])

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  6. def disableTracing(): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  7. def enableTracing(): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  8. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  9. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  10. def executingAs(arg0: String): Statement

    Permalink
    Definition Classes
    Statement

  11. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  12. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  13. def getConsistencyLevel(): ConsistencyLevel

    Permalink
    Definition Classes
    StatementWrapper → Statement

  14. def getDefaultTimestamp(): Long

    Permalink
    Definition Classes
    StatementWrapper → Statement

  15. def getFetchSize(): Int

    Permalink
    Definition Classes
    StatementWrapper → Statement

  16. def getHost(): Host

    Permalink
    Definition Classes
    StatementWrapper → Statement

  17. def getKeyspace(): String

    Permalink
    Definition Classes
    StatementWrapper → Statement

  18. def getOutgoingPayload(): Map[String, ByteBuffer]

    Permalink
    Definition Classes
    StatementWrapper → Statement

  19. def getPagingState(): ByteBuffer

    Permalink
    Definition Classes
    StatementWrapper → Statement

  20. def getReadTimeoutMillis(): Int

    Permalink
    Definition Classes
    StatementWrapper → Statement

  21. def getRetryPolicy(): RetryPolicy

    Permalink
    Definition Classes
    StatementWrapper → Statement

  22. def getRoutingKey(arg0: ProtocolVersion, arg1: CodecRegistry): ByteBuffer

    Permalink
    Definition Classes
    StatementWrapper → Statement

  23. def getRoutingToken(): Token

    Permalink
    Definition Classes
    Statement

  24. def getSerialConsistencyLevel(): ConsistencyLevel

    Permalink
    Definition Classes
    StatementWrapper → Statement

  25. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  26. def isIdempotent(): Boolean

    Permalink
    Definition Classes
    StatementWrapper → Statement

  27. def isIdempotentWithDefault(arg0: QueryOptions): Boolean

    Permalink
    Definition Classes
    StatementWrapper → Statement

  28. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  29. def isTracing(): Boolean

    Permalink
    Definition Classes
    StatementWrapper → Statement

  30. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  31. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  32. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  33. val replicas: Set[InetAddress]

    Permalink

  34. def requestSizeInBytes(arg0: ProtocolVersion, arg1: CodecRegistry): Int

    Permalink
    Definition Classes
    StatementWrapper → Statement

  35. def setConsistencyLevel(arg0: ConsistencyLevel): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  36. def setDefaultTimestamp(arg0: Long): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  37. def setFetchSize(arg0: Int): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  38. def setHost(arg0: Host): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  39. def setIdempotent(arg0: Boolean): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  40. def setOutgoingPayload(arg0: Map[String, ByteBuffer]): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  41. def setPagingState(arg0: PagingState): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  42. def setPagingState(arg0: PagingState, arg1: CodecRegistry): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  43. def setPagingStateUnsafe(arg0: Array[Byte]): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  44. def setReadTimeoutMillis(arg0: Int): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  45. def setRetryPolicy(arg0: RetryPolicy): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  46. def setSerialConsistencyLevel(arg0: ConsistencyLevel): Statement

    Permalink
    Definition Classes
    StatementWrapper → Statement

  47. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  48. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  49. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  50. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  51. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  52. val wrapped: Statement

    Permalink

Inherited from StatementWrapper

Inherited from Statement

Inherited from AnyRef

Inherited from Any

Ungrouped