Package

org.apache.spark

metrics

Permalink

package metrics

Visibility
  1. Public
  2. All

Type Members

  1. trait CCSTimer extends Timer

    Permalink
  2. class CassandraConnectorSource extends Source

    Permalink

    This class is a Source implementation for Cassandra Connector related Codahale metrics.

    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.

  3. sealed trait InputMetricsUpdater extends MetricsUpdater

    Permalink

    A trait that provides a method to update read metrics which are collected for connector related tasks.

    A trait that provides a method to update read metrics which are collected for connector related tasks. The appropriate instance is created by the companion object.

    Instances of this trait are not thread-safe. They do not need to because a single instance should be created for each Cassandra read task. This remains valid as long as Cassandra read tasks are single-threaded.

  4. trait MetricsUpdater extends AnyRef

    Permalink

    The base trait for metrics updaters implementations.

    The base trait for metrics updaters implementations. The metrics updater is an object which provides a unified way to update all the relevant metrics which are collected for the particular type of activity. The connector provides InputMetricsUpdater and OutputMetricsUpdater which are aimed to update all the read and write metrics respectively.

  5. sealed trait OutputMetricsUpdater extends MetricsUpdater

    Permalink

    A trait that provides a method to update write metrics which are collected for connector related tasks.

    A trait that provides a method to update write metrics which are collected for connector related tasks. The appropriate instance is created by the companion object.

    Instances of OutputMetricsUpdater are thread-safe, because the Cassandra write task implementation is multi-threaded.

  6. trait SimpleTimer extends Timer

    Permalink
  7. trait Timer extends AnyRef

    Permalink

    Timer mixin allows to measure the time of a task - or, in other words - the time from creating an instance to calling com.codahale.metrics.Timer.Context.stop method.

Value Members

  1. object InputMetricsUpdater

    Permalink
  2. object MetricsUpdater

    Permalink
  3. object OutputMetricsUpdater extends Logging

    Permalink

Ungrouped