ColumnPath

Cassandra Column Path

A ColumnPath represents the full path to a given column. Any ColumnPath (or substructure) can use get to optionally fetch the column (although recent changes mean that to get a Composite Column you need to use RowPath to do so). Additionally execute and executeAsync expose the Astyanax operations available on a com.netflix.astyanax.ColumnMutation.

Operations

The get operation returns the column if it exists. Use getWith to name the serializer for composite columns.

val maybeCol = (cfUsers \ username \ ("name").get
val needsWork = maybeCol.map{_.getValue}.getOrElse("-unknown-")

// Short-cut for get with a default
val needsWork = (cfUsers \ username \ ("name").getOrElse("-unknown-")

The execute and executeAsync operations allow for modifying the Column found at this ColumnPath.

A ColumnPath can be used to construct a Column.

val col = colpath \ 7

Linear Supertypes

Serializable, Serializable, Product, Equals, modelish.ColumnPathish[K, N], modelish.RowPathish[K], modelish.ColFamish, AnyRef, Any

Instance Constructors

new ColumnPath(rowpath: RowPath[K], colname: N)(implicit arg0: Manifest[K], arg1: Manifest[N])

Value Members

final def !=(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def !=(arg0: Any): Boolean

Definition Classes
Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def ==(arg0: Any): Boolean

Definition Classes
Any
def \[V](colval: V, ttl: Int)(implicit arg0: Manifest[V]): Column[K, N, V]
def \[V](colval: V)(implicit arg0: Manifest[V]): Column[K, N, V]
final def asInstanceOf[T0]: T0

Definition Classes
Any
val cfname: String

Definition Classes
ColumnPath → ColFamish
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws()
val colname: N

Definition Classes
ColumnPath → ColumnPathish
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def execute(body: (ColumnMutation) ⇒ Execution[Void]): Either[ConnectionException, OperationResult[Void]]

Executes a com.netflix.astyanax.ColumnMutation based on this ColumnPath.
Executes a com.netflix.astyanax.ColumnMutation based on this ColumnPath.
You should pass in a function which will take the ColumnMutation to an Execution[Void]. E.g.,
```
// `null` here is the ttl
(cfUsers \ username \ "age").execute {_.putValue(3, null)}
```
The Execution[Void] will then be run.
def executeAsync(body: (ColumnMutation) ⇒ Execution[Void]): Either[ConnectionException, Future[OperationResult[Void]]]

Executes a com.netflix.astyanax.ColumnMutation based on this ColumnPath asynchronously.
Executes a com.netflix.astyanax.ColumnMutation based on this ColumnPath asynchronously.
You should pass in a function which will take the ColumnMutation to an Execution[Void]. E.g.,
```
// `null` here is the ttl
(cfUsers \ username \ "age").executeAsync {_.putValue(3, null)}
```
The Execution[Void] will then be run asynchronously resulting in a java.util.concurrent.Future.
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws()
def get: Option[netflix.astyanax.model.Column[N]]

Optionally returns a com.netflix.astyanax.model.Column if it exists at this ColumnPath.
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getOrElse[V](default: ⇒ V)(implicit arg0: Manifest[V]): V

Return the value at this ColumnPath or a default if no column exists in Cassandra.
Return the value at this ColumnPath or a default if no column exists in Cassandra.
The column could exist and have an empty value. If you need to check for that use
```
// Assuming the value is a String.
colPath.get.flatMap{c => if (c.hasValue) Some(c.getStringValue) else None}.getOrElse(default)
```
def getWith[M](acsM: AnnotatedCompositeSerializer[M]): Option[netflix.astyanax.model.Column[M]]

Optionally returns a com.netflix.astyanax.model.Column if it exists at this ColumnPath.
Optionally returns a com.netflix.astyanax.model.Column if it exists at this ColumnPath.
Note that the colname and serializer type products must agree. E.g., both (String, String) or both (String, Int, String).
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
val keyspace: Keyspace

Definition Classes
ColumnPath → ColFamish
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val rowkey: K

Definition Classes
ColumnPath → RowPathish
val rowpath: RowPath[K]
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws()
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws()
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws()

case class ColumnPath[K, N](rowpath: RowPath[K], colname: N)(implicit evidence$1: Manifest[K], evidence$2: Manifest[N]) extends ColumnPathish[K, N] with Product with Serializable

Operations

Instance Constructors

new ColumnPath(rowpath: RowPath[K], colname: N)(implicit arg0: Manifest[K], arg1: Manifest[N])

Value Members

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

def \[V](colval: V, ttl: Int)(implicit arg0: Manifest[V]): Column[K, N, V]

def \[V](colval: V)(implicit arg0: Manifest[V]): Column[K, N, V]

final def asInstanceOf[T0]: T0

val cfname: String

def clone(): AnyRef

val colname: N

final def eq(arg0: AnyRef): Boolean

def execute(body: (ColumnMutation) ⇒ Execution[Void]): Either[ConnectionException, OperationResult[Void]]

def executeAsync(body: (ColumnMutation) ⇒ Execution[Void]): Either[ConnectionException, Future[OperationResult[Void]]]

def finalize(): Unit

def get: Option[netflix.astyanax.model.Column[N]]

final def getClass(): Class[_]

def getOrElse[V](default: ⇒ V)(implicit arg0: Manifest[V]): V

def getWith[M](acsM: AnnotatedCompositeSerializer[M]): Option[netflix.astyanax.model.Column[M]]

final def isInstanceOf[T0]: Boolean

val keyspace: Keyspace

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val rowkey: K

val rowpath: RowPath[K]

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

final def wait(): Unit

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

final def wait(arg0: Long): Unit

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from modelish.ColumnPathish[K, N]

Inherited from modelish.RowPathish[K]

Inherited from modelish.ColFamish

Inherited from AnyRef

Inherited from Any

Ungrouped