case class WriteConf(batchSize: BatchSize = BatchSize.Automatic, batchGroupingBufferSize: Int = ..., batchGroupingKey: BatchGroupingKey = WriteConf.BatchLevelParam.default, consistencyLevel: ConsistencyLevel = ..., ifNotExists: Boolean = WriteConf.IfNotExistsParam.default, ignoreNulls: Boolean = WriteConf.IgnoreNullsParam.default, parallelismLevel: Int = ..., throughputMiBPS: Option[Double] = ..., ttl: TTLOption = TTLOption.defaultValue, timestamp: TimestampOption = TimestampOption.defaultValue, taskMetricsEnabled: Boolean = WriteConf.TaskMetricsParam.default, executeAs: Option[String] = None) extends Product with Serializable
Write settings for RDD
- batchSize
approx. number of bytes to be written in a single batch or exact number of rows to be written in a single batch;
- batchGroupingBufferSize
the number of distinct batches that can be buffered before they are written to Cassandra
- batchGroupingKey
which rows can be grouped into a single batch
- consistencyLevel
consistency level for writes, default LOCAL_QUORUM
- ifNotExists
inserting a row should happen only if it does not already exist
- parallelismLevel
number of batches to be written in parallel
- ttl
the default TTL value which is used when it is defined (in seconds)
- timestamp
the default timestamp value which is used when it is defined (in microseconds)
- taskMetricsEnabled
whether or not enable task metrics updates (requires Spark 1.2+)
- Alphabetic
- By Inheritance
- WriteConf
- Serializable
- Serializable
- Product
- Equals
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
WriteConf(batchSize: BatchSize = BatchSize.Automatic, batchGroupingBufferSize: Int = ..., batchGroupingKey: BatchGroupingKey = WriteConf.BatchLevelParam.default, consistencyLevel: ConsistencyLevel = ..., ifNotExists: Boolean = WriteConf.IfNotExistsParam.default, ignoreNulls: Boolean = WriteConf.IgnoreNullsParam.default, parallelismLevel: Int = ..., throughputMiBPS: Option[Double] = ..., ttl: TTLOption = TTLOption.defaultValue, timestamp: TimestampOption = TimestampOption.defaultValue, taskMetricsEnabled: Boolean = WriteConf.TaskMetricsParam.default, executeAs: Option[String] = None)
- batchSize
approx. number of bytes to be written in a single batch or exact number of rows to be written in a single batch;
- batchGroupingBufferSize
the number of distinct batches that can be buffered before they are written to Cassandra
- batchGroupingKey
which rows can be grouped into a single batch
- consistencyLevel
consistency level for writes, default LOCAL_QUORUM
- ifNotExists
inserting a row should happen only if it does not already exist
- parallelismLevel
number of batches to be written in parallel
- ttl
the default TTL value which is used when it is defined (in seconds)
- timestamp
the default timestamp value which is used when it is defined (in microseconds)
- taskMetricsEnabled
whether or not enable task metrics updates (requires Spark 1.2+)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
- val batchGroupingBufferSize: Int
- val batchGroupingKey: BatchGroupingKey
- val batchSize: BatchSize
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- val consistencyLevel: ConsistencyLevel
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val executeAs: Option[String]
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- val ifNotExists: Boolean
- val ignoreNulls: Boolean
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- val parallelismLevel: Int
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- val taskMetricsEnabled: Boolean
- val throttlingEnabled: Boolean
- val throughputMiBPS: Option[Double]
- val timestamp: TimestampOption
- val ttl: TTLOption
-
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( ... ) @native()