TableWriter

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
def +(other: String): String

Implicit information
This member is added by an implicit conversion from TableWriter[T] to any2stringadd[TableWriter[T]] performed by method any2stringadd in scala.Predef.
Definition Classes
any2stringadd
def ->[B](y: B): (TableWriter[T], B)

Implicit information
This member is added by an implicit conversion from TableWriter[T] to ArrowAssoc[TableWriter[T]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc
Annotations
@inline()
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def batchRoutingKey(session: Session, routingKeyGenerator: RoutingKeyGenerator)(bs: BoundStatement): Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
val columnNames: Seq[String]
val columns: Seq[ColumnDef]
def delete(columns: ColumnSelector)(taskContext: TaskContext, data: Iterator[T]): Unit

Cql DELETE statement
Cql DELETE statement
columns
columns to delete, the row will be deleted completely if the list is empty
data
primary key values to select delete rows
def ensuring(cond: (TableWriter[T]) ⇒ Boolean, msg: ⇒ Any): TableWriter[T]

Implicit information
This member is added by an implicit conversion from TableWriter[T] to Ensuring[TableWriter[T]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: (TableWriter[T]) ⇒ Boolean): TableWriter[T]

Implicit information
This member is added by an implicit conversion from TableWriter[T] to Ensuring[TableWriter[T]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean, msg: ⇒ Any): TableWriter[T]

Implicit information
This member is added by an implicit conversion from TableWriter[T] to Ensuring[TableWriter[T]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
def ensuring(cond: Boolean): TableWriter[T]

Implicit information
This member is added by an implicit conversion from TableWriter[T] to Ensuring[TableWriter[T]] performed by method Ensuring in scala.Predef.
Definition Classes
Ensuring
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def formatted(fmtstr: String): String

Implicit information
This member is added by an implicit conversion from TableWriter[T] to StringFormat[TableWriter[T]] performed by method StringFormat in scala.Predef.
Definition Classes
StringFormat
Annotations
@inline()
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
def insert(taskContext: TaskContext, data: Iterator[T]): Unit

Write data with Cql INSERT statement
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def isTraceEnabled(): Boolean

Attributes
protected
Definition Classes
Logging
val keyspaceName: String
def log: Logger

Attributes
protected
Definition Classes
Logging
def logDebug(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logDebug(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logError(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logError(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logInfo(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logInfo(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logName: String

Attributes
protected
Definition Classes
Logging
def logTrace(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logTrace(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logWarning(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logWarning(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
val tableName: String
def toString(): String

Definition Classes
AnyRef → Any
def update(taskContext: TaskContext, data: Iterator[T]): Unit

Write data with Cql UPDATE statement
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( ... )
def write(taskContext: TaskContext, data: Iterator[T]): Unit

Main entry point if counter or collection column need to be updated Cql UPDATE command will be used INSERT otherwise
def →[B](y: B): (TableWriter[T], B)

Implicit information
This member is added by an implicit conversion from TableWriter[T] to ArrowAssoc[TableWriter[T]] performed by method ArrowAssoc in scala.Predef.
Definition Classes
ArrowAssoc

Inherited from Logging

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from TableWriter[T] to any2stringadd[TableWriter[T]]

Inherited by implicit conversion StringFormat from TableWriter[T] to StringFormat[TableWriter[T]]

Inherited by implicit conversion Ensuring from TableWriter[T] to Ensuring[TableWriter[T]]

Inherited by implicit conversion ArrowAssoc from TableWriter[T] to ArrowAssoc[TableWriter[T]]

Ungrouped

Related Docs: object TableWriter | package writer

class TableWriter[T] extends Serializable with Logging

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

def +(other: String): String

def ->[B](y: B): (TableWriter[T], B)

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def batchRoutingKey(session: Session, routingKeyGenerator: RoutingKeyGenerator)(bs: BoundStatement): Any

def clone(): AnyRef

val columnNames: Seq[String]

val columns: Seq[ColumnDef]

def delete(columns: ColumnSelector)(taskContext: TaskContext, data: Iterator[T]): Unit

def ensuring(cond: (TableWriter[T]) ⇒ Boolean, msg: ⇒ Any): TableWriter[T]

def ensuring(cond: (TableWriter[T]) ⇒ Boolean): TableWriter[T]

def ensuring(cond: Boolean, msg: ⇒ Any): TableWriter[T]

def ensuring(cond: Boolean): TableWriter[T]

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

def formatted(fmtstr: String): String

final def getClass(): Class[_]

def hashCode(): Int

def insert(taskContext: TaskContext, data: Iterator[T]): Unit

final def isInstanceOf[T0]: Boolean

def isTraceEnabled(): Boolean

val keyspaceName: String

def log: Logger

def logDebug(msg: ⇒ String, throwable: Throwable): Unit

def logDebug(msg: ⇒ String): Unit

def logError(msg: ⇒ String, throwable: Throwable): Unit

def logError(msg: ⇒ String): Unit

def logInfo(msg: ⇒ String, throwable: Throwable): Unit

def logInfo(msg: ⇒ String): Unit

def logName: String

def logTrace(msg: ⇒ String, throwable: Throwable): Unit

def logTrace(msg: ⇒ String): Unit

def logWarning(msg: ⇒ String, throwable: Throwable): Unit

def logWarning(msg: ⇒ String): Unit

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

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

val tableName: String

def toString(): String

def update(taskContext: TaskContext, data: Iterator[T]): Unit

final def wait(): Unit

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

final def wait(arg0: Long): Unit

def write(taskContext: TaskContext, data: Iterator[T]): Unit

def →[B](y: B): (TableWriter[T], B)

Inherited from Logging

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from TableWriter[T] to any2stringadd[TableWriter[T]]

Inherited by implicit conversion StringFormat from TableWriter[T] to StringFormat[TableWriter[T]]

Inherited by implicit conversion Ensuring from TableWriter[T] to Ensuring[TableWriter[T]]

Inherited by implicit conversion ArrowAssoc from TableWriter[T] to ArrowAssoc[TableWriter[T]]

Ungrouped