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.OutgoingFileMessage extends org.apache.cassandra.streaming.messages.StreamMessage
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.streaming.messages.OutgoingFileMessage
  super_class: org.apache.cassandra.streaming.messages.StreamMessage
{
  public static org.apache.cassandra.streaming.messages.StreamMessage$Serializer<org.apache.cassandra.streaming.messages.OutgoingFileMessage> serializer;
    descriptor: Lorg/apache/cassandra/streaming/messages/StreamMessage$Serializer;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Signature: Lorg/apache/cassandra/streaming/messages/StreamMessage$Serializer<Lorg/apache/cassandra/streaming/messages/OutgoingFileMessage;>;

  public final org.apache.cassandra.streaming.messages.FileMessageHeader header;
    descriptor: Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL

  private final org.apache.cassandra.utils.concurrent.Ref<org.apache.cassandra.io.sstable.format.SSTableReader> ref;
    descriptor: Lorg/apache/cassandra/utils/concurrent/Ref;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lorg/apache/cassandra/utils/concurrent/Ref<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;

  private final java.lang.String filename;
    descriptor: Ljava/lang/String;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private boolean completed;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  private boolean transferring;
    descriptor: Z
    flags: (0x0002) ACC_PRIVATE

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=2, locals=0, args_size=0
         0: .line 40
            new org.apache.cassandra.streaming.messages.OutgoingFileMessage$1
            dup
            invokespecial org.apache.cassandra.streaming.messages.OutgoingFileMessage$1.<init>:()V
            putstatic org.apache.cassandra.streaming.messages.OutgoingFileMessage.serializer:Lorg/apache/cassandra/streaming/messages/StreamMessage$Serializer;
         1: .line 60
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  public void <init>(org.apache.cassandra.utils.concurrent.Ref<org.apache.cassandra.io.sstable.format.SSTableReader>, int, long, java.util.List<org.apache.cassandra.utils.Pair<java.lang.Long, java.lang.Long>>, long, );
    descriptor: (Lorg/apache/cassandra/utils/concurrent/Ref;IJLjava/util/List;JZ)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=15, locals=10, args_size=7
        start local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
        start local 1 // org.apache.cassandra.utils.concurrent.Ref ref
        start local 2 // int sequenceNumber
        start local 3 // long estimatedKeys
        start local 5 // java.util.List sections
        start local 6 // long repairedAt
        start local 8 // boolean keepSSTableLevel
         0: .line 70
            aload 0 /* this */
            getstatic org.apache.cassandra.streaming.messages.StreamMessage$Type.FILE:Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;
            invokespecial org.apache.cassandra.streaming.messages.StreamMessage.<init>:(Lorg/apache/cassandra/streaming/messages/StreamMessage$Type;)V
         1: .line 65
            aload 0 /* this */
            iconst_0
            putfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.completed:Z
         2: .line 66
            aload 0 /* this */
            iconst_0
            putfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.transferring:Z
         3: .line 71
            aload 0 /* this */
            aload 1 /* ref */
            putfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
         4: .line 73
            aload 1 /* ref */
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.get:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 9 /* sstable */
        start local 9 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
         5: .line 74
            aload 0 /* this */
            aload 9 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getFilename:()Ljava/lang/String;
            putfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.filename:Ljava/lang/String;
         6: .line 75
            aload 0 /* this */
         7: new org.apache.cassandra.streaming.messages.FileMessageHeader
            dup
            aload 9 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.metadata:Lorg/apache/cassandra/config/CFMetaData;
            getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
         8: .line 76
            iload 2 /* sequenceNumber */
         9: .line 77
            aload 9 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.version:Lorg/apache/cassandra/io/sstable/format/Version;
        10: .line 78
            aload 9 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.descriptor:Lorg/apache/cassandra/io/sstable/Descriptor;
            getfield org.apache.cassandra.io.sstable.Descriptor.formatType:Lorg/apache/cassandra/io/sstable/format/SSTableFormat$Type;
        11: .line 79
            lload 3 /* estimatedKeys */
        12: .line 80
            aload 5 /* sections */
        13: .line 81
            aload 9 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.compression:Z
            ifeq 14
            aload 9 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getCompressionMetadata:()Lorg/apache/cassandra/io/compress/CompressionMetadata;
            goto 15
      StackMap locals: org.apache.cassandra.streaming.messages.OutgoingFileMessage org.apache.cassandra.utils.concurrent.Ref int long java.util.List long int org.apache.cassandra.io.sstable.format.SSTableReader
      StackMap stack: org.apache.cassandra.streaming.messages.OutgoingFileMessage new 7 new 7 java.util.UUID int org.apache.cassandra.io.sstable.format.Version org.apache.cassandra.io.sstable.format.SSTableFormat$Type long java.util.List
        14: aconst_null
        15: .line 82
      StackMap locals: org.apache.cassandra.streaming.messages.OutgoingFileMessage org.apache.cassandra.utils.concurrent.Ref int long java.util.List long int org.apache.cassandra.io.sstable.format.SSTableReader
      StackMap stack: org.apache.cassandra.streaming.messages.OutgoingFileMessage new 7 new 7 java.util.UUID int org.apache.cassandra.io.sstable.format.Version org.apache.cassandra.io.sstable.format.SSTableFormat$Type long java.util.List org.apache.cassandra.io.compress.CompressionMetadata
            lload 6 /* repairedAt */
        16: .line 83
            iload 8 /* keepSSTableLevel */
            ifeq 17
            aload 9 /* sstable */
            invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getSSTableLevel:()I
            goto 18
      StackMap locals: org.apache.cassandra.streaming.messages.OutgoingFileMessage org.apache.cassandra.utils.concurrent.Ref int long java.util.List long int org.apache.cassandra.io.sstable.format.SSTableReader
      StackMap stack: org.apache.cassandra.streaming.messages.OutgoingFileMessage new 7 new 7 java.util.UUID int org.apache.cassandra.io.sstable.format.Version org.apache.cassandra.io.sstable.format.SSTableFormat$Type long java.util.List org.apache.cassandra.io.compress.CompressionMetadata long
        17: iconst_0
        18: .line 84
      StackMap locals: org.apache.cassandra.streaming.messages.OutgoingFileMessage org.apache.cassandra.utils.concurrent.Ref int long java.util.List long int org.apache.cassandra.io.sstable.format.SSTableReader
      StackMap stack: org.apache.cassandra.streaming.messages.OutgoingFileMessage new 7 new 7 java.util.UUID int org.apache.cassandra.io.sstable.format.Version org.apache.cassandra.io.sstable.format.SSTableFormat$Type long java.util.List org.apache.cassandra.io.compress.CompressionMetadata long int
            aload 9 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.header:Lorg/apache/cassandra/db/SerializationHeader;
            ifnonnull 19
            aconst_null
            goto 20
      StackMap locals: org.apache.cassandra.streaming.messages.OutgoingFileMessage org.apache.cassandra.utils.concurrent.Ref int long java.util.List long int org.apache.cassandra.io.sstable.format.SSTableReader
      StackMap stack: org.apache.cassandra.streaming.messages.OutgoingFileMessage new 7 new 7 java.util.UUID int org.apache.cassandra.io.sstable.format.Version org.apache.cassandra.io.sstable.format.SSTableFormat$Type long java.util.List org.apache.cassandra.io.compress.CompressionMetadata long int
        19: aload 9 /* sstable */
            getfield org.apache.cassandra.io.sstable.format.SSTableReader.header:Lorg/apache/cassandra/db/SerializationHeader;
            invokevirtual org.apache.cassandra.db.SerializationHeader.toComponent:()Lorg/apache/cassandra/db/SerializationHeader$Component;
      StackMap locals: org.apache.cassandra.streaming.messages.OutgoingFileMessage org.apache.cassandra.utils.concurrent.Ref int long java.util.List long int org.apache.cassandra.io.sstable.format.SSTableReader
      StackMap stack: org.apache.cassandra.streaming.messages.OutgoingFileMessage new 7 new 7 java.util.UUID int org.apache.cassandra.io.sstable.format.Version org.apache.cassandra.io.sstable.format.SSTableFormat$Type long java.util.List org.apache.cassandra.io.compress.CompressionMetadata long int org.apache.cassandra.db.SerializationHeader$Component
        20: invokespecial org.apache.cassandra.streaming.messages.FileMessageHeader.<init>:(Ljava/util/UUID;ILorg/apache/cassandra/io/sstable/format/Version;Lorg/apache/cassandra/io/sstable/format/SSTableFormat$Type;JLjava/util/List;Lorg/apache/cassandra/io/compress/CompressionMetadata;JILorg/apache/cassandra/db/SerializationHeader$Component;)V
        21: .line 75
            putfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
        22: .line 85
            return
        end local 9 // org.apache.cassandra.io.sstable.format.SSTableReader sstable
        end local 8 // boolean keepSSTableLevel
        end local 6 // long repairedAt
        end local 5 // java.util.List sections
        end local 3 // long estimatedKeys
        end local 2 // int sequenceNumber
        end local 1 // org.apache.cassandra.utils.concurrent.Ref ref
        end local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
      LocalVariableTable:
        Start  End  Slot              Name  Signature
            0   23     0              this  Lorg/apache/cassandra/streaming/messages/OutgoingFileMessage;
            0   23     1               ref  Lorg/apache/cassandra/utils/concurrent/Ref<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
            0   23     2    sequenceNumber  I
            0   23     3     estimatedKeys  J
            0   23     5          sections  Ljava/util/List<Lorg/apache/cassandra/utils/Pair<Ljava/lang/Long;Ljava/lang/Long;>;>;
            0   23     6        repairedAt  J
            0   23     8  keepSSTableLevel  Z
            5   23     9           sstable  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
    Signature: (Lorg/apache/cassandra/utils/concurrent/Ref<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;IJLjava/util/List<Lorg/apache/cassandra/utils/Pair<Ljava/lang/Long;Ljava/lang/Long;>;>;JZ)V
    MethodParameters:
                  Name  Flags
      ref               
      sequenceNumber    
      estimatedKeys     
      sections          
      repairedAt        
      keepSSTableLevel  

  public synchronized void serialize(org.apache.cassandra.io.util.DataOutputStreamPlus, int, org.apache.cassandra.streaming.StreamSession);
    descriptor: (Lorg/apache/cassandra/io/util/DataOutputStreamPlus;ILorg/apache/cassandra/streaming/StreamSession;)V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=6, locals=7, args_size=4
        start local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
        start local 1 // org.apache.cassandra.io.util.DataOutputStreamPlus out
        start local 2 // int version
        start local 3 // org.apache.cassandra.streaming.StreamSession session
         0: .line 89
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.completed:Z
            ifeq 2
         1: .line 91
            return
         2: .line 94
      StackMap locals:
      StackMap stack:
            getstatic org.apache.cassandra.streaming.messages.FileMessageHeader.serializer:Lorg/apache/cassandra/streaming/messages/FileMessageHeader$FileMessageHeaderSerializer;
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
            aload 1 /* out */
            iload 2 /* version */
            invokevirtual org.apache.cassandra.streaming.messages.FileMessageHeader$FileMessageHeaderSerializer.serialize:(Lorg/apache/cassandra/streaming/messages/FileMessageHeader;Lorg/apache/cassandra/io/util/DataOutputPlus;I)Lorg/apache/cassandra/streaming/compress/CompressionInfo;
            astore 4 /* compressionInfo */
        start local 4 // org.apache.cassandra.streaming.compress.CompressionInfo compressionInfo
         3: .line 96
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.get:()Ljava/lang/Object;
            checkcast org.apache.cassandra.io.sstable.format.SSTableReader
            astore 5 /* reader */
        start local 5 // org.apache.cassandra.io.sstable.format.SSTableReader reader
         4: .line 97
            aload 4 /* compressionInfo */
            ifnonnull 6
         5: .line 98
            new org.apache.cassandra.streaming.StreamWriter
            dup
            aload 5 /* reader */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
            getfield org.apache.cassandra.streaming.messages.FileMessageHeader.sections:Ljava/util/List;
            aload 3 /* session */
            invokespecial org.apache.cassandra.streaming.StreamWriter.<init>:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Ljava/util/Collection;Lorg/apache/cassandra/streaming/StreamSession;)V
            goto 9
         6: .line 99
      StackMap locals: org.apache.cassandra.streaming.compress.CompressionInfo org.apache.cassandra.io.sstable.format.SSTableReader
      StackMap stack:
            new org.apache.cassandra.streaming.compress.CompressedStreamWriter
            dup
            aload 5 /* reader */
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
            getfield org.apache.cassandra.streaming.messages.FileMessageHeader.sections:Ljava/util/List;
         7: .line 100
            aload 4 /* compressionInfo */
            aload 3 /* session */
         8: .line 99
            invokespecial org.apache.cassandra.streaming.compress.CompressedStreamWriter.<init>:(Lorg/apache/cassandra/io/sstable/format/SSTableReader;Ljava/util/Collection;Lorg/apache/cassandra/streaming/compress/CompressionInfo;Lorg/apache/cassandra/streaming/StreamSession;)V
         9: .line 97
      StackMap locals:
      StackMap stack: org.apache.cassandra.streaming.StreamWriter
            astore 6 /* writer */
        start local 6 // org.apache.cassandra.streaming.StreamWriter writer
        10: .line 101
            aload 6 /* writer */
            aload 1 /* out */
            invokevirtual org.apache.cassandra.streaming.StreamWriter.write:(Lorg/apache/cassandra/io/util/DataOutputStreamPlus;)V
        11: .line 102
            return
        end local 6 // org.apache.cassandra.streaming.StreamWriter writer
        end local 5 // org.apache.cassandra.io.sstable.format.SSTableReader reader
        end local 4 // org.apache.cassandra.streaming.compress.CompressionInfo compressionInfo
        end local 3 // org.apache.cassandra.streaming.StreamSession session
        end local 2 // int version
        end local 1 // org.apache.cassandra.io.util.DataOutputStreamPlus out
        end local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   12     0             this  Lorg/apache/cassandra/streaming/messages/OutgoingFileMessage;
            0   12     1              out  Lorg/apache/cassandra/io/util/DataOutputStreamPlus;
            0   12     2          version  I
            0   12     3          session  Lorg/apache/cassandra/streaming/StreamSession;
            3   12     4  compressionInfo  Lorg/apache/cassandra/streaming/compress/CompressionInfo;
            4   12     5           reader  Lorg/apache/cassandra/io/sstable/format/SSTableReader;
           10   12     6           writer  Lorg/apache/cassandra/streaming/StreamWriter;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
         Name  Flags
      out      
      version  
      session  

  public synchronized void finishTransfer();
    descriptor: ()V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
         0: .line 107
            aload 0 /* this */
            iconst_0
            putfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.transferring:Z
         1: .line 109
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.completed:Z
            ifeq 3
         2: .line 111
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.release:()V
         3: .line 113
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lorg/apache/cassandra/streaming/messages/OutgoingFileMessage;
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()

  public synchronized void startTransfer();
    descriptor: ()V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=7, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
         0: .line 118
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.completed:Z
            ifeq 4
         1: .line 119
            new java.lang.RuntimeException
            dup
            ldc "Transfer of file %s already completed or aborted (perhaps session failed?)."
            iconst_1
            anewarray java.lang.Object
            dup
            iconst_0
         2: .line 120
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.filename:Ljava/lang/String;
            aastore
         3: .line 119
            invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/String;)V
            athrow
         4: .line 121
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            iconst_1
            putfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.transferring:Z
         5: .line 122
            return
        end local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    6     0  this  Lorg/apache/cassandra/streaming/messages/OutgoingFileMessage;
    RuntimeInvisibleAnnotations: 
      com.google.common.annotations.VisibleForTesting()

  public synchronized void complete();
    descriptor: ()V
    flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
         0: .line 126
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.completed:Z
            ifne 4
         1: .line 128
            aload 0 /* this */
            iconst_1
            putfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.completed:Z
         2: .line 130
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.transferring:Z
            ifne 4
         3: .line 132
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.ref:Lorg/apache/cassandra/utils/concurrent/Ref;
            invokevirtual org.apache.cassandra.utils.concurrent.Ref.release:()V
         4: .line 135
      StackMap locals:
      StackMap stack:
            return
        end local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/apache/cassandra/streaming/messages/OutgoingFileMessage;

  public java.lang.String toString();
    descriptor: ()Ljava/lang/String;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
         0: .line 140
            new java.lang.StringBuilder
            dup
            ldc "File ("
            invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.header:Lorg/apache/cassandra/streaming/messages/FileMessageHeader;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
            ldc ", file: "
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            aload 0 /* this */
            getfield org.apache.cassandra.streaming.messages.OutgoingFileMessage.filename:Ljava/lang/String;
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            ldc ")"
            invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
            invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
            areturn
        end local 0 // org.apache.cassandra.streaming.messages.OutgoingFileMessage this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/messages/OutgoingFileMessage;
}
SourceFile: "OutgoingFileMessage.java"
NestMembers:
  org.apache.cassandra.streaming.messages.OutgoingFileMessage$1
InnerClasses:
  public Component = org.apache.cassandra.db.SerializationHeader$Component of org.apache.cassandra.db.SerializationHeader
  public final Type = org.apache.cassandra.io.sstable.format.SSTableFormat$Type of org.apache.cassandra.io.sstable.format.SSTableFormat
  FileMessageHeaderSerializer = org.apache.cassandra.streaming.messages.FileMessageHeader$FileMessageHeaderSerializer of org.apache.cassandra.streaming.messages.FileMessageHeader
  org.apache.cassandra.streaming.messages.OutgoingFileMessage$1
  public abstract Serializer = org.apache.cassandra.streaming.messages.StreamMessage$Serializer of org.apache.cassandra.streaming.messages.StreamMessage
  public final Type = org.apache.cassandra.streaming.messages.StreamMessage$Type of org.apache.cassandra.streaming.messages.StreamMessage