class
CassandraConnectorSource extends Source
Instance Constructors
-
new
CassandraConnectorSource()
Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
def
+(other: String): String
-
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
-
-
-
-
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
-
final
def
isInstanceOf[T0]: Boolean
-
val
metricRegistry: MetricRegistry
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
val
readByteMeter: Meter
-
val
readRowMeter: Meter
-
val
readTaskTimer: com.codahale.metrics.Timer
-
val
sourceName: String
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
-
val
writeBatchTimer: com.codahale.metrics.Timer
-
val
writeBatchWaitTimer: com.codahale.metrics.Timer
-
val
writeByteMeter: Meter
-
val
writeFailureCounter: Counter
-
val
writeRowMeter: Meter
-
val
writeSuccessCounter: Counter
-
val
writeTaskTimer: com.codahale.metrics.Timer
-
Shadowed Implicit Value Members
-
val
self: Any
-
val
self: Any
Inherited from AnyRef
Inherited from Any
This class is a Source implementation for Cassandra Connector related Codahale metrics. It is automatically instantiated and registered by Spark metrics system if this source is specified in metrics configuration file.
Spark instantiates this class when
SparkEnv
is started. There can be only a single instance ofSparkEnv
so there can be at most a single active instance ofCassandraConnectorSource
. The active instance is assigned toCassandraConnectorSource._instance
so that it can be retrieved from anywhere by CassandraConnectorSource.instance method. We need this because we have to access the meters from the task execution.