https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.
  • Andres de la Peña
  • Avinash Lakshman
  • Aleksey Yeschenko
  • Aaron Morton
  • Ariel Weisberg
  • Blake Eggleston
  • Benedict Elliott Smith
  • Benjamin Lerer
  • Branimir Lambov
  • Brandon Williams
  • Carl Yeksigian
  • David Brosiusd
  • Dikang Gu
  • Eric Evans
  • Gary Dusbabek
  • Chris Goffinet
  • Alex Petrov
  • Laine Jaakko Olavi
  • T Jake Luciani
  • Jason Brown
  • Jonathan Ellis
  • Jake Farrell
  • Jeff Jirsa
  • Joel Knighton
  • Josh McKenzie
  • Johan Oskarsson
  • Jun Rao
  • Jay Zhuang
  • Sankalp Kohli
  • Marcus Eriksson
  • Michael Semb Wever
  • Mikhail Stepura
  • Michael Shuler
  • Paulo Motta
  • Prashant Malik
  • Robert Stupp
  • Peter Schuller
  • Sam Tunnicliffe
  • Sylvain Lebresne
  • Stefania Alborghetti
  • Tyler Hobbs
  • Vijay Parthasarathy
  • Pavel Yaskevich
  • Yuki Morishita
  • Nate McCall 
public final class org.apache.cassandra.tracing.TraceKeyspace
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.tracing.TraceKeyspace
  super_class: java.lang.Object
{
  public static final java.lang.String SESSIONS;
    descriptor: Ljava/lang/String;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: "sessions"

  public static final java.lang.String EVENTS;
    descriptor: Ljava/lang/String;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
    ConstantValue: "events"

  private static final org.apache.cassandra.config.CFMetaData Sessions;
    descriptor: Lorg/apache/cassandra/config/CFMetaData;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final org.apache.cassandra.config.CFMetaData Events;
    descriptor: Lorg/apache/cassandra/config/CFMetaData;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=3, locals=0, args_size=0
         0: .line 45
            ldc "sessions"
         1: .line 46
            ldc "tracing sessions"
         2: .line 47
            ldc "CREATE TABLE %s (session_id uuid,command text,client inet,coordinator inet,duration int,parameters map<text, text>,request text,started_at timestamp,PRIMARY KEY ((session_id)))"
         3: .line 45
            invokestatic org.apache.cassandra.tracing.TraceKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
         4: .line 44
            putstatic org.apache.cassandra.tracing.TraceKeyspace.Sessions:Lorg/apache/cassandra/config/CFMetaData;
         5: .line 59
            ldc "events"
         6: .line 60
            ldc "tracing events"
         7: .line 61
            ldc "CREATE TABLE %s (session_id uuid,event_id timeuuid,activity text,source inet,source_elapsed int,thread text,PRIMARY KEY ((session_id), event_id))"
         8: .line 59
            invokestatic org.apache.cassandra.tracing.TraceKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
         9: .line 58
            putstatic org.apache.cassandra.tracing.TraceKeyspace.Events:Lorg/apache/cassandra/config/CFMetaData;
        10: .line 68
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.tracing.TraceKeyspace this
         0: .line 37
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 39
            return
        end local 0 // org.apache.cassandra.tracing.TraceKeyspace this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/tracing/TraceKeyspace;

  private static org.apache.cassandra.config.CFMetaData compile(java.lang.String, java.lang.String, java.lang.String);
    descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
    flags: (0x000a) ACC_PRIVATE, ACC_STATIC
    Code:
      stack=5, locals=3, args_size=3
        start local 0 // java.lang.String name
        start local 1 // java.lang.String description
        start local 2 // java.lang.String schema
         0: .line 72
            aload 2 /* schema */
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* name */
            aastore
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            ldc "system_traces"
            invokestatic org.apache.cassandra.config.CFMetaData.compile:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
         1: .line 73
            aload 1 /* description */
            invokevirtual org.apache.cassandra.config.CFMetaData.comment:(Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
         2: .line 72
            areturn
        end local 2 // java.lang.String schema
        end local 1 // java.lang.String description
        end local 0 // java.lang.String name
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    3     0         name  Ljava/lang/String;
            0    3     1  description  Ljava/lang/String;
            0    3     2       schema  Ljava/lang/String;
    MethodParameters:
             Name  Flags
      name         
      description  
      schema       

  public static org.apache.cassandra.schema.KeyspaceMetadata metadata();
    descriptor: ()Lorg/apache/cassandra/schema/KeyspaceMetadata;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=6, locals=0, args_size=0
         0: .line 78
            ldc "system_traces"
            iconst_2
            invokestatic org.apache.cassandra.schema.KeyspaceParams.simple:(I)Lorg/apache/cassandra/schema/KeyspaceParams;
            iconst_2
            anewarray org.apache.cassandra.config.CFMetaData
            dup
            iconst_0
            getstatic org.apache.cassandra.tracing.TraceKeyspace.Sessions:Lorg/apache/cassandra/config/CFMetaData;
            aastore
            dup
            iconst_1
            getstatic org.apache.cassandra.tracing.TraceKeyspace.Events:Lorg/apache/cassandra/config/CFMetaData;
            aastore
            invokestatic org.apache.cassandra.schema.Tables.of:([Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/schema/Tables;
            invokestatic org.apache.cassandra.schema.KeyspaceMetadata.create:(Ljava/lang/String;Lorg/apache/cassandra/schema/KeyspaceParams;Lorg/apache/cassandra/schema/Tables;)Lorg/apache/cassandra/schema/KeyspaceMetadata;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  static org.apache.cassandra.db.Mutation makeStartSessionMutation(java.nio.ByteBuffer, java.net.InetAddress, java.util.Map<java.lang.String, java.lang.String>, java.lang.String, long, java.lang.String, int);
    descriptor: (Ljava/nio/ByteBuffer;Ljava/net/InetAddress;Ljava/util/Map;Ljava/lang/String;JLjava/lang/String;I)Lorg/apache/cassandra/db/Mutation;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=6, locals=9, args_size=7
        start local 0 // java.nio.ByteBuffer sessionId
        start local 1 // java.net.InetAddress client
        start local 2 // java.util.Map parameters
        start local 3 // java.lang.String request
        start local 4 // long startedAt
        start local 6 // java.lang.String command
        start local 7 // int ttl
         0: .line 89
            getstatic org.apache.cassandra.tracing.TraceKeyspace.Sessions:Lorg/apache/cassandra/config/CFMetaData;
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* sessionId */
            aastore
            invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.simpleBuilder:(Lorg/apache/cassandra/config/CFMetaData;[Ljava/lang/Object;)Lorg/apache/cassandra/db/partitions/PartitionUpdate$SimpleBuilder;
            astore 8 /* builder */
        start local 8 // org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder builder
         1: .line 90
            aload 8 /* builder */
            iconst_0
            anewarray java.lang.Object
            invokeinterface org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder.row:([Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         2: .line 91
            iload 7 /* ttl */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.ttl:(I)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         3: .line 92
            ldc "client"
            aload 1 /* client */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         4: .line 93
            ldc "coordinator"
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         5: .line 94
            ldc "request"
            aload 3 /* request */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         6: .line 95
            ldc "started_at"
            new java.util.Date
            dup
            lload 4 /* startedAt */
            invokespecial java.util.Date.<init>:(J)V
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         7: .line 96
            ldc "command"
            aload 6 /* command */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         8: .line 97
            ldc "parameters"
            aload 2 /* parameters */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.appendAll:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
            pop
         9: .line 99
            aload 8 /* builder */
            invokeinterface org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder.buildAsMutation:()Lorg/apache/cassandra/db/Mutation;
            areturn
        end local 8 // org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder builder
        end local 7 // int ttl
        end local 6 // java.lang.String command
        end local 4 // long startedAt
        end local 3 // java.lang.String request
        end local 2 // java.util.Map parameters
        end local 1 // java.net.InetAddress client
        end local 0 // java.nio.ByteBuffer sessionId
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   10     0   sessionId  Ljava/nio/ByteBuffer;
            0   10     1      client  Ljava/net/InetAddress;
            0   10     2  parameters  Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
            0   10     3     request  Ljava/lang/String;
            0   10     4   startedAt  J
            0   10     6     command  Ljava/lang/String;
            0   10     7         ttl  I
            1   10     8     builder  Lorg/apache/cassandra/db/partitions/PartitionUpdate$SimpleBuilder;
    Signature: (Ljava/nio/ByteBuffer;Ljava/net/InetAddress;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Ljava/lang/String;JLjava/lang/String;I)Lorg/apache/cassandra/db/Mutation;
    MethodParameters:
            Name  Flags
      sessionId   
      client      
      parameters  
      request     
      startedAt   
      command     
      ttl         

  static org.apache.cassandra.db.Mutation makeStopSessionMutation(java.nio.ByteBuffer, int, int);
    descriptor: (Ljava/nio/ByteBuffer;II)Lorg/apache/cassandra/db/Mutation;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=5, locals=4, args_size=3
        start local 0 // java.nio.ByteBuffer sessionId
        start local 1 // int elapsed
        start local 2 // int ttl
         0: .line 104
            getstatic org.apache.cassandra.tracing.TraceKeyspace.Sessions:Lorg/apache/cassandra/config/CFMetaData;
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* sessionId */
            aastore
            invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.simpleBuilder:(Lorg/apache/cassandra/config/CFMetaData;[Ljava/lang/Object;)Lorg/apache/cassandra/db/partitions/PartitionUpdate$SimpleBuilder;
            astore 3 /* builder */
        start local 3 // org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder builder
         1: .line 105
            aload 3 /* builder */
            iconst_0
            anewarray java.lang.Object
            invokeinterface org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder.row:([Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         2: .line 106
            iload 2 /* ttl */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.ttl:(I)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         3: .line 107
            ldc "duration"
            iload 1 /* elapsed */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
            pop
         4: .line 108
            aload 3 /* builder */
            invokeinterface org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder.buildAsMutation:()Lorg/apache/cassandra/db/Mutation;
            areturn
        end local 3 // org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder builder
        end local 2 // int ttl
        end local 1 // int elapsed
        end local 0 // java.nio.ByteBuffer sessionId
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    5     0  sessionId  Ljava/nio/ByteBuffer;
            0    5     1    elapsed  I
            0    5     2        ttl  I
            1    5     3    builder  Lorg/apache/cassandra/db/partitions/PartitionUpdate$SimpleBuilder;
    MethodParameters:
           Name  Flags
      sessionId  
      elapsed    
      ttl        

  static org.apache.cassandra.db.Mutation makeEventMutation(java.nio.ByteBuffer, java.lang.String, int, java.lang.String, int);
    descriptor: (Ljava/nio/ByteBuffer;Ljava/lang/String;ILjava/lang/String;I)Lorg/apache/cassandra/db/Mutation;
    flags: (0x0008) ACC_STATIC
    Code:
      stack=5, locals=7, args_size=5
        start local 0 // java.nio.ByteBuffer sessionId
        start local 1 // java.lang.String message
        start local 2 // int elapsed
        start local 3 // java.lang.String threadName
        start local 4 // int ttl
         0: .line 113
            getstatic org.apache.cassandra.tracing.TraceKeyspace.Events:Lorg/apache/cassandra/config/CFMetaData;
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            aload 0 /* sessionId */
            aastore
            invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.simpleBuilder:(Lorg/apache/cassandra/config/CFMetaData;[Ljava/lang/Object;)Lorg/apache/cassandra/db/partitions/PartitionUpdate$SimpleBuilder;
            astore 5 /* builder */
        start local 5 // org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder builder
         1: .line 114
            aload 5 /* builder */
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
            invokestatic org.apache.cassandra.utils.UUIDGen.getTimeUUID:()Ljava/util/UUID;
            aastore
            invokeinterface org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder.row:([Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         2: .line 115
            iload 4 /* ttl */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.ttl:(I)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         3: .line 114
            astore 6 /* rowBuilder */
        start local 6 // org.apache.cassandra.db.rows.Row$SimpleBuilder rowBuilder
         4: .line 117
            aload 6 /* rowBuilder */
            ldc "activity"
            aload 1 /* message */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         5: .line 118
            ldc "source"
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
         6: .line 119
            ldc "thread"
            aload 3 /* threadName */
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
            pop
         7: .line 121
            iload 2 /* elapsed */
            iflt 9
         8: .line 122
            aload 6 /* rowBuilder */
            ldc "source_elapsed"
            iload 2 /* elapsed */
            invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
            invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
            pop
         9: .line 124
      StackMap locals: org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder org.apache.cassandra.db.rows.Row$SimpleBuilder
      StackMap stack:
            aload 5 /* builder */
            invokeinterface org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder.buildAsMutation:()Lorg/apache/cassandra/db/Mutation;
            areturn
        end local 6 // org.apache.cassandra.db.rows.Row$SimpleBuilder rowBuilder
        end local 5 // org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder builder
        end local 4 // int ttl
        end local 3 // java.lang.String threadName
        end local 2 // int elapsed
        end local 1 // java.lang.String message
        end local 0 // java.nio.ByteBuffer sessionId
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   10     0   sessionId  Ljava/nio/ByteBuffer;
            0   10     1     message  Ljava/lang/String;
            0   10     2     elapsed  I
            0   10     3  threadName  Ljava/lang/String;
            0   10     4         ttl  I
            1   10     5     builder  Lorg/apache/cassandra/db/partitions/PartitionUpdate$SimpleBuilder;
            4   10     6  rowBuilder  Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
    MethodParameters:
            Name  Flags
      sessionId   
      message     
      elapsed     
      threadName  
      ttl         
}
SourceFile: "TraceKeyspace.java"
InnerClasses:
  public abstract SimpleBuilder = org.apache.cassandra.db.partitions.PartitionUpdate$SimpleBuilder of org.apache.cassandra.db.partitions.PartitionUpdate
  public abstract SimpleBuilder = org.apache.cassandra.db.rows.Row$SimpleBuilder of org.apache.cassandra.db.rows.Row