Package kieker.extension.cassandra.writer

Class CassandraDbWriter

java.lang.Object

kieker.monitoring.writer.AbstractMonitoringWriter

kieker.extension.cassandra.writer.CassandraDbWriter

public class CassandraDbWriter
extends AbstractMonitoringWriter

Since:

1.16

Author:

Armin Moebius, Sven Ulrich, Reiner Jung

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CONFIG_BENCHMARK_ID
static java.lang.String	CONFIG_CONTACTPOINTS
static java.lang.String	CONFIG_KEYSPACE
static java.lang.String	CONFIG_OVERWRITE
static java.lang.String	CONFIG_TABLE_PREFIX

Fields inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

configuration

Constructor Summary

Constructors

Constructor	Description
CassandraDbWriter(Configuration configuration)	Creates a new instance of this class using the given parameter.

Method Summary

Modifier and Type	Method	Description
void	onStarting()	This event fires when Kieker has been initialized and is ready to monitor.
void	onTerminating()	This event fires when Kieker has been notified to terminate.
void	writeMonitoringRecord(IMonitoringRecord record)	This event fires when Kieker has received a new record.

Methods inherited from class kieker.monitoring.writer.AbstractMonitoringWriter

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

CONFIG_KEYSPACE

public static final java.lang.String CONFIG_KEYSPACE

CONFIG_CONTACTPOINTS

public static final java.lang.String CONFIG_CONTACTPOINTS

CONFIG_TABLE_PREFIX

public static final java.lang.String CONFIG_TABLE_PREFIX

CONFIG_OVERWRITE

public static final java.lang.String CONFIG_OVERWRITE

CONFIG_BENCHMARK_ID

public static final java.lang.String CONFIG_BENCHMARK_ID

Constructor Details

CassandraDbWriter

public CassandraDbWriter(Configuration configuration)

Creates a new instance of this class using the given parameter.

Parameters:

configuration -

Method Details

onStarting

public void onStarting()

Description copied from class: AbstractMonitoringWriter

This event fires when Kieker has been initialized and is ready to monitor. It is executed by the MonitoringWriterThread just before reading the writer queue.

Specified by:

onStarting in class AbstractMonitoringWriter

writeMonitoringRecord

public void writeMonitoringRecord(IMonitoringRecord record)

Description copied from class: AbstractMonitoringWriter

This event fires when Kieker has received a new record.

Specified by:

writeMonitoringRecord in class AbstractMonitoringWriter

onTerminating

public void onTerminating()

Description copied from class: AbstractMonitoringWriter

This event fires when Kieker has been notified to terminate. It is executed by the MonitoringWriterThread just after finishing the writer queue.

Specified by:

onTerminating in class AbstractMonitoringWriter