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 class org.apache.cassandra.streaming.messages.StreamInitMessage
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.streaming.messages.StreamInitMessage
  super_class: java.lang.Object
{
  public static org.apache.cassandra.io.IVersionedSerializer<org.apache.cassandra.streaming.messages.StreamInitMessage> serializer;
    descriptor: Lorg/apache/cassandra/io/IVersionedSerializer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Signature: Lorg/apache/cassandra/io/IVersionedSerializer<Lorg/apache/cassandra/streaming/messages/StreamInitMessage;>;

  public final java.net.InetAddress from;
    descriptor: Ljava/net/InetAddress;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final int sessionIndex;
    descriptor: I
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final java.util.UUID planId;
    descriptor: Ljava/util/UUID;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final java.lang.String description;
    descriptor: Ljava/lang/String;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final boolean isForOutgoing;
    descriptor: Z
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final boolean keepSSTableLevel;
    descriptor: Z
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  public final boolean isIncremental;
    descriptor: Z
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  static final boolean $assertionsDisabled;
    descriptor: Z
    flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 39
            ldc Lorg/apache/cassandra/streaming/messages/StreamInitMessage;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic org.apache.cassandra.streaming.messages.StreamInitMessage.$assertionsDisabled:Z
         3: .line 41
            new org.apache.cassandra.streaming.messages.StreamInitMessage$StreamInitMessageSerializer
            dup
            invokespecial org.apache.cassandra.streaming.messages.StreamInitMessage$StreamInitMessageSerializer.<init>:()V
            putstatic org.apache.cassandra.streaming.messages.StreamInitMessage.serializer:Lorg/apache/cassandra/io/IVersionedSerializer;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(java.net.InetAddress, int, java.util.UUID, java.lang.String, boolean, boolean, boolean);
    descriptor: (Ljava/net/InetAddress;ILjava/util/UUID;Ljava/lang/String;ZZZ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=8, args_size=8
        start local 0 // org.apache.cassandra.streaming.messages.StreamInitMessage this
        start local 1 // java.net.InetAddress from
        start local 2 // int sessionIndex
        start local 3 // java.util.UUID planId
        start local 4 // java.lang.String description
        start local 5 // boolean isForOutgoing
        start local 6 // boolean keepSSTableLevel
        start local 7 // boolean isIncremental
         0: .line 53
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 55
            aload 0 /* this */
            aload 1 /* from */
            putfield org.apache.cassandra.streaming.messages.StreamInitMessage.from:Ljava/net/InetAddress;
         2: .line 56
            aload 0 /* this */
            iload 2 /* sessionIndex */
            putfield org.apache.cassandra.streaming.messages.StreamInitMessage.sessionIndex:I
         3: .line 57
            aload 0 /* this */
            aload 3 /* planId */
            putfield org.apache.cassandra.streaming.messages.StreamInitMessage.planId:Ljava/util/UUID;
         4: .line 58
            aload 0 /* this */
            aload 4 /* description */
            putfield org.apache.cassandra.streaming.messages.StreamInitMessage.description:Ljava/lang/String;
         5: .line 59
            aload 0 /* this */
            iload 5 /* isForOutgoing */
            putfield org.apache.cassandra.streaming.messages.StreamInitMessage.isForOutgoing:Z
         6: .line 60
            aload 0 /* this */
            iload 6 /* keepSSTableLevel */
            putfield org.apache.cassandra.streaming.messages.StreamInitMessage.keepSSTableLevel:Z
         7: .line 61
            aload 0 /* this */
            iload 7 /* isIncremental */
            putfield org.apache.cassandra.streaming.messages.StreamInitMessage.isIncremental:Z
         8: .line 62
            return
        end local 7 // boolean isIncremental
        end local 6 // boolean keepSSTableLevel
        end local 5 // boolean isForOutgoing
        end local 4 // java.lang.String description
        end local 3 // java.util.UUID planId
        end local 2 // int sessionIndex
        end local 1 // java.net.InetAddress from
        end local 0 // org.apache.cassandra.streaming.messages.StreamInitMessage this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0    9     0              this  Lorg/apache/cassandra/streaming/messages/StreamInitMessage;
            0    9     1              from  Ljava/net/InetAddress;
            0    9     2      sessionIndex  I
            0    9     3            planId  Ljava/util/UUID;
            0    9     4       description  Ljava/lang/String;
            0    9     5     isForOutgoing  Z
            0    9     6  keepSSTableLevel  Z
            0    9     7     isIncremental  Z
    MethodParameters:
                  Name  Flags
      from              
      sessionIndex      
      planId            
      description       
      isForOutgoing     
      keepSSTableLevel  
      isIncremental     

  public java.nio.ByteBuffer createMessage(boolean, int);
    descriptor: (ZI)Ljava/nio/ByteBuffer;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=4, locals=9, args_size=3
        start local 0 // org.apache.cassandra.streaming.messages.StreamInitMessage this
        start local 1 // boolean compress
        start local 2 // int version
         0: .line 73
            iconst_0
            istore 3 /* header */
        start local 3 // int header
         1: .line 75
            iload 1 /* compress */
            ifeq 3
         2: .line 76
            iload 3 /* header */
            iconst_4
            ior
            istore 3 /* header */
         3: .line 78
      StackMap locals: int
      StackMap stack:
            iload 3 /* header */
            bipush 8
            ior
            istore 3 /* header */
         4: .line 80
            iload 3 /* header */
            iload 2 /* version */
            bipush 8
            ishl
            ior
            istore 3 /* header */
         5: .line 85
            getstatic org.apache.cassandra.streaming.messages.StreamInitMessage.serializer:Lorg/apache/cassandra/io/IVersionedSerializer;
            aload 0 /* this */
            iload 2 /* version */
            invokeinterface org.apache.cassandra.io.IVersionedSerializer.serializedSize:(Ljava/lang/Object;I)J
            l2i
            istore 5 /* size */
        start local 5 // int size
         6: .line 86
            aconst_null
            astore 6
            aconst_null
            astore 7
         7: new org.apache.cassandra.io.util.DataOutputBufferFixed
            dup
            iload 5 /* size */
            invokespecial org.apache.cassandra.io.util.DataOutputBufferFixed.<init>:(I)V
            astore 8 /* buffer */
        start local 8 // org.apache.cassandra.io.util.DataOutputBuffer buffer
         8: .line 88
            getstatic org.apache.cassandra.streaming.messages.StreamInitMessage.serializer:Lorg/apache/cassandra/io/IVersionedSerializer;
            aload 0 /* this */
            aload 8 /* buffer */
            iload 2 /* version */
            invokeinterface org.apache.cassandra.io.IVersionedSerializer.serialize:(Ljava/lang/Object;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
         9: .line 89
            aload 8 /* buffer */
            invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.getData:()[B
            astore 4 /* bytes */
        start local 4 // byte[] bytes
        10: .line 90
            aload 8 /* buffer */
            ifnull 18
            aload 8 /* buffer */
            invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.close:()V
            goto 18
        end local 4 // byte[] bytes
      StackMap locals: org.apache.cassandra.streaming.messages.StreamInitMessage int int int top int java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.DataOutputBuffer
      StackMap stack: java.lang.Throwable
        11: astore 6
            aload 8 /* buffer */
            ifnull 12
            aload 8 /* buffer */
            invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.close:()V
        end local 8 // org.apache.cassandra.io.util.DataOutputBuffer buffer
      StackMap locals:
      StackMap stack:
        12: aload 6
            athrow
      StackMap locals:
      StackMap stack: java.lang.Throwable
        13: astore 7
            aload 6
            ifnonnull 14
            aload 7
            astore 6
            goto 15
      StackMap locals:
      StackMap stack:
        14: aload 6
            aload 7
            if_acmpeq 15
            aload 6
            aload 7
            invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
      StackMap locals:
      StackMap stack:
        15: aload 6
            athrow
        end local 5 // int size
        16: .line 92
      StackMap locals: org.apache.cassandra.streaming.messages.StreamInitMessage int int int
      StackMap stack: java.io.IOException
            astore 5 /* e */
        start local 5 // java.io.IOException e
        17: .line 94
            new java.lang.RuntimeException
            dup
            aload 5 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 5 // java.io.IOException e
        start local 4 // byte[] bytes
        18: .line 96
      StackMap locals: byte[]
      StackMap stack:
            getstatic org.apache.cassandra.streaming.messages.StreamInitMessage.$assertionsDisabled:Z
            ifne 19
            aload 4 /* bytes */
            arraylength
            ifgt 19
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
        19: .line 98
      StackMap locals:
      StackMap stack:
            bipush 8
            aload 4 /* bytes */
            arraylength
            iadd
            invokestatic java.nio.ByteBuffer.allocate:(I)Ljava/nio/ByteBuffer;
            astore 5 /* buffer */
        start local 5 // java.nio.ByteBuffer buffer
        20: .line 99
            aload 5 /* buffer */
            ldc -900387334
            invokevirtual java.nio.ByteBuffer.putInt:(I)Ljava/nio/ByteBuffer;
            pop
        21: .line 100
            aload 5 /* buffer */
            iload 3 /* header */
            invokevirtual java.nio.ByteBuffer.putInt:(I)Ljava/nio/ByteBuffer;
            pop
        22: .line 101
            aload 5 /* buffer */
            aload 4 /* bytes */
            invokevirtual java.nio.ByteBuffer.put:([B)Ljava/nio/ByteBuffer;
            pop
        23: .line 102
            aload 5 /* buffer */
            invokevirtual java.nio.ByteBuffer.flip:()Ljava/nio/Buffer;
            pop
        24: .line 103
            aload 5 /* buffer */
            areturn
        end local 5 // java.nio.ByteBuffer buffer
        end local 4 // byte[] bytes
        end local 3 // int header
        end local 2 // int version
        end local 1 // boolean compress
        end local 0 // org.apache.cassandra.streaming.messages.StreamInitMessage this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   25     0      this  Lorg/apache/cassandra/streaming/messages/StreamInitMessage;
            0   25     1  compress  Z
            0   25     2   version  I
            1   25     3    header  I
           10   11     4     bytes  [B
           18   25     4     bytes  [B
            6   16     5      size  I
            8   12     8    buffer  Lorg/apache/cassandra/io/util/DataOutputBuffer;
           17   18     5         e  Ljava/io/IOException;
           20   25     5    buffer  Ljava/nio/ByteBuffer;
      Exception table:
        from    to  target  type
           8    10      11  any
           7    13      13  any
           5    16      16  Class java.io.IOException
    MethodParameters:
          Name  Flags
      compress  
      version   
}
SourceFile: "StreamInitMessage.java"
NestMembers:
  org.apache.cassandra.streaming.messages.StreamInitMessage$StreamInitMessageSerializer
InnerClasses:
  private StreamInitMessageSerializer = org.apache.cassandra.streaming.messages.StreamInitMessage$StreamInitMessageSerializer of org.apache.cassandra.streaming.messages.StreamInitMessage