Package zipkin2.storage.cassandra

Class CassandraStorage

java.lang.Object
zipkin2.Component
zipkin2.storage.StorageComponent
zipkin2.storage.cassandra.CassandraStorage
All Implemented Interfaces:
Closeable, AutoCloseable
public final class CassandraStorage extends zipkin2.storage.StorageComponent
CQL3 implementation of zipkin storage.

Queries are logged to the category "com.datastax.oss.driver.api.core.cql.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.

  • Method Details

    • newBuilder

      public static CassandraStorage.Builder newBuilder()

    • spanStore

      public zipkin2.storage.SpanStore spanStore()
      Memoized in order to avoid re-preparing statements
      Specified by:
      spanStore in class zipkin2.storage.StorageComponent

    • traces

      public zipkin2.storage.Traces traces()
      Overrides:
      traces in class zipkin2.storage.StorageComponent

    • serviceAndSpanNames

      public zipkin2.storage.ServiceAndSpanNames serviceAndSpanNames()
      Overrides:
      serviceAndSpanNames in class zipkin2.storage.StorageComponent

    • autocompleteTags

      public zipkin2.storage.AutocompleteTags autocompleteTags()
      Overrides:
      autocompleteTags in class zipkin2.storage.StorageComponent

    • spanConsumer

      public zipkin2.storage.SpanConsumer spanConsumer()
      Specified by:
      spanConsumer in class zipkin2.storage.StorageComponent

    • isOverCapacity

      public boolean isOverCapacity(Throwable e)
      Overrides:
      isOverCapacity in class zipkin2.storage.StorageComponent

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • check

      public zipkin2.CheckResult check()
      Overrides:
      check in class zipkin2.Component

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Overrides:
      close in class zipkin2.Component