Package zipkin2.storage.cassandra

Class CassandraStorage

java.lang.Object

zipkin2.Component

zipkin2.storage.StorageComponent

zipkin2.storage.cassandra.CassandraStorage

All Implemented Interfaces:

Closeable, AutoCloseable

public abstract class CassandraStorage
extends StorageComponent

CQL3 implementation of zipkin storage.

Queries are logged to the category "com.datastax.driver.core.QueryLogger" when debug or trace is enabled via SLF4J. Trace level includes bound values.

Schema is installed by default from "/zipkin2-schema.cql"

When StorageComponent.Builder.strictTraceId(boolean) is disabled, span and index data are uniformly written with 64-bit trace ID length. When retrieving data, an extra "trace_id_high" field clarifies if a 128-bit trace ID was sent.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CassandraStorage.Builder
static interface	CassandraStorage.SessionFactory

Method Summary

Modifier and Type	Method	Description
AutocompleteTags	autocompleteTags()	Memoized in order to avoid re-preparing statements
CheckResult	check()
void	close()
boolean	isOverCapacity(Throwable e)
static CassandraStorage.Builder	newBuilder()
ServiceAndSpanNames	serviceAndSpanNames()
SpanConsumer	spanConsumer()	Memoized in order to avoid re-preparing statements
SpanStore	spanStore()	Memoized in order to avoid re-preparing statements
String	toString()
Traces	traces()

Methods inherited from class java.lang.Object

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

Method Details

newBuilder

public static CassandraStorage.Builder newBuilder()

spanStore

@Memoized public SpanStore spanStore()

Memoized in order to avoid re-preparing statements

Specified by:

spanStore in class StorageComponent

traces

public Traces traces()

Overrides:

traces in class StorageComponent

serviceAndSpanNames

public ServiceAndSpanNames serviceAndSpanNames()

Overrides:

serviceAndSpanNames in class StorageComponent

autocompleteTags

@Memoized public AutocompleteTags autocompleteTags()

Memoized in order to avoid re-preparing statements

Overrides:

autocompleteTags in class StorageComponent

spanConsumer

@Memoized public SpanConsumer spanConsumer()

Memoized in order to avoid re-preparing statements

Specified by:

spanConsumer in class StorageComponent

check

public CheckResult check()

Overrides:

check in class Component

isOverCapacity

public boolean isOverCapacity(Throwable e)

Overrides:

isOverCapacity in class StorageComponent

toString

public final String toString()

Overrides:

toString in class Object

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class Component