public class org.apache.cassandra.streaming.management.StreamStateCompositeData
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: org.apache.cassandra.streaming.management.StreamStateCompositeData
  super_class: java.lang.Object
{
  private static final java.lang.String[] ITEM_NAMES;
    descriptor: [Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final java.lang.String[] ITEM_DESCS;
    descriptor: [Ljava/lang/String;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private static final javax.management.openmbean.OpenType<?>[] ITEM_TYPES;
    descriptor: [Ljavax/management/openmbean/OpenType;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
    Signature: [Ljavax/management/openmbean/OpenType<*>;

  public static final javax.management.openmbean.CompositeType COMPOSITE_TYPE;
    descriptor: Ljavax/management/openmbean/CompositeType;
    flags: (0x0019) ACC_PUBLIC, ACC_STATIC, 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=7, locals=1, args_size=0
         0: .line 34
            ldc Lorg/apache/cassandra/streaming/management/StreamStateCompositeData;
            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.management.StreamStateCompositeData.$assertionsDisabled:Z
         3: .line 36
            bipush 9
            anewarray java.lang.String
            dup
            iconst_0
            ldc "planId"
            aastore
            dup
            iconst_1
            ldc "description"
            aastore
            dup
            iconst_2
            ldc "sessions"
            aastore
            dup
            iconst_3
         4: .line 37
            ldc "currentRxBytes"
            aastore
            dup
            iconst_4
            ldc "totalRxBytes"
            aastore
            dup
            iconst_5
            ldc "rxPercentage"
            aastore
            dup
            bipush 6
         5: .line 38
            ldc "currentTxBytes"
            aastore
            dup
            bipush 7
            ldc "totalTxBytes"
            aastore
            dup
            bipush 8
            ldc "txPercentage"
            aastore
         6: .line 36
            putstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
         7: .line 39
            bipush 9
            anewarray java.lang.String
            dup
            iconst_0
            ldc "Plan ID of this stream"
            aastore
            dup
            iconst_1
         8: .line 40
            ldc "Stream plan description"
            aastore
            dup
            iconst_2
         9: .line 41
            ldc "Active stream sessions"
            aastore
            dup
            iconst_3
        10: .line 42
            ldc "Number of bytes received across all streams"
            aastore
            dup
            iconst_4
        11: .line 43
            ldc "Total bytes available to receive across all streams"
            aastore
            dup
            iconst_5
        12: .line 44
            ldc "Percentage received across all streams"
            aastore
            dup
            bipush 6
        13: .line 45
            ldc "Number of bytes sent across all streams"
            aastore
            dup
            bipush 7
        14: .line 46
            ldc "Total bytes available to send across all streams"
            aastore
            dup
            bipush 8
        15: .line 47
            ldc "Percentage sent across all streams"
            aastore
        16: .line 39
            putstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_DESCS:[Ljava/lang/String;
        17: .line 55
            bipush 9
            anewarray javax.management.openmbean.OpenType
            dup
            iconst_0
            getstatic javax.management.openmbean.SimpleType.STRING:Ljavax/management/openmbean/SimpleType;
            aastore
            dup
            iconst_1
        18: .line 56
            getstatic javax.management.openmbean.SimpleType.STRING:Ljavax/management/openmbean/SimpleType;
            aastore
            dup
            iconst_2
        19: .line 57
            getstatic org.apache.cassandra.streaming.management.SessionInfoCompositeData.COMPOSITE_TYPE:Ljavax/management/openmbean/CompositeType;
            invokestatic javax.management.openmbean.ArrayType.getArrayType:(Ljavax/management/openmbean/OpenType;)Ljavax/management/openmbean/ArrayType;
            aastore
            dup
            iconst_3
        20: .line 58
            getstatic javax.management.openmbean.SimpleType.LONG:Ljavax/management/openmbean/SimpleType;
            aastore
            dup
            iconst_4
            getstatic javax.management.openmbean.SimpleType.LONG:Ljavax/management/openmbean/SimpleType;
            aastore
            dup
            iconst_5
            getstatic javax.management.openmbean.SimpleType.DOUBLE:Ljavax/management/openmbean/SimpleType;
            aastore
            dup
            bipush 6
        21: .line 59
            getstatic javax.management.openmbean.SimpleType.LONG:Ljavax/management/openmbean/SimpleType;
            aastore
            dup
            bipush 7
            getstatic javax.management.openmbean.SimpleType.LONG:Ljavax/management/openmbean/SimpleType;
            aastore
            dup
            bipush 8
            getstatic javax.management.openmbean.SimpleType.DOUBLE:Ljavax/management/openmbean/SimpleType;
            aastore
        22: .line 55
            putstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_TYPES:[Ljavax/management/openmbean/OpenType;
        23: .line 60
            new javax.management.openmbean.CompositeType
            dup
            ldc Lorg/apache/cassandra/streaming/StreamState;
            invokevirtual java.lang.Class.getName:()Ljava/lang/String;
        24: .line 61
            ldc "StreamState"
        25: .line 62
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
        26: .line 63
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_DESCS:[Ljava/lang/String;
        27: .line 64
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_TYPES:[Ljavax/management/openmbean/OpenType;
        28: .line 60
            invokespecial javax.management.openmbean.CompositeType.<init>:(Ljava/lang/String;Ljava/lang/String;[Ljava/lang/String;[Ljava/lang/String;[Ljavax/management/openmbean/OpenType;)V
            putstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.COMPOSITE_TYPE:Ljavax/management/openmbean/CompositeType;
        29: .line 65
            goto 32
        30: .line 66
      StackMap locals:
      StackMap stack: javax.management.openmbean.OpenDataException
            astore 0 /* e */
        start local 0 // javax.management.openmbean.OpenDataException e
        31: .line 68
            aload 0 /* e */
            invokestatic com.google.common.base.Throwables.propagate:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
            athrow
        end local 0 // javax.management.openmbean.OpenDataException e
        32: .line 70
      StackMap locals:
      StackMap stack:
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature
           31   32     0     e  Ljavax/management/openmbean/OpenDataException;
      Exception table:
        from    to  target  type
          17    29      30  Class javax.management.openmbean.OpenDataException

  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.streaming.management.StreamStateCompositeData this
         0: .line 34
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // org.apache.cassandra.streaming.management.StreamStateCompositeData this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/streaming/management/StreamStateCompositeData;

  public static javax.management.openmbean.CompositeData toCompositeData(org.apache.cassandra.streaming.StreamState);
    descriptor: (Lorg/apache/cassandra/streaming/StreamState;)Ljavax/management/openmbean/CompositeData;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=16, args_size=1
        start local 0 // org.apache.cassandra.streaming.StreamState streamState
         0: .line 74
            new java.util.HashMap
            dup
            invokespecial java.util.HashMap.<init>:()V
            astore 1 /* valueMap */
        start local 1 // java.util.Map valueMap
         1: .line 75
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            iconst_0
            aaload
            aload 0 /* streamState */
            getfield org.apache.cassandra.streaming.StreamState.planId:Ljava/util/UUID;
            invokevirtual java.util.UUID.toString:()Ljava/lang/String;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         2: .line 76
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            iconst_1
            aaload
            aload 0 /* streamState */
            getfield org.apache.cassandra.streaming.StreamState.description:Ljava/lang/String;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         3: .line 78
            aload 0 /* streamState */
            getfield org.apache.cassandra.streaming.StreamState.sessions:Ljava/util/Set;
            invokeinterface java.util.Set.size:()I
            anewarray javax.management.openmbean.CompositeData
            astore 2 /* sessions */
        start local 2 // javax.management.openmbean.CompositeData[] sessions
         4: .line 79
            aload 0 /* streamState */
            getfield org.apache.cassandra.streaming.StreamState.sessions:Ljava/util/Set;
            new org.apache.cassandra.streaming.management.StreamStateCompositeData$1
            dup
            aload 0 /* streamState */
            invokespecial org.apache.cassandra.streaming.management.StreamStateCompositeData$1.<init>:(Lorg/apache/cassandra/streaming/StreamState;)V
            invokestatic com.google.common.collect.Iterables.transform:(Ljava/lang/Iterable;Lcom/google/common/base/Function;)Ljava/lang/Iterable;
            invokestatic com.google.common.collect.Lists.newArrayList:(Ljava/lang/Iterable;)Ljava/util/ArrayList;
         5: .line 85
            aload 2 /* sessions */
            invokevirtual java.util.ArrayList.toArray:([Ljava/lang/Object;)[Ljava/lang/Object;
            pop
         6: .line 86
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            iconst_2
            aaload
            aload 2 /* sessions */
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
         7: .line 88
            lconst_0
            lstore 3 /* currentRxBytes */
        start local 3 // long currentRxBytes
         8: .line 89
            lconst_0
            lstore 5 /* totalRxBytes */
        start local 5 // long totalRxBytes
         9: .line 90
            lconst_0
            lstore 7 /* currentTxBytes */
        start local 7 // long currentTxBytes
        10: .line 91
            lconst_0
            lstore 9 /* totalTxBytes */
        start local 9 // long totalTxBytes
        11: .line 92
            aload 0 /* streamState */
            getfield org.apache.cassandra.streaming.StreamState.sessions:Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 12
            goto 17
      StackMap locals: org.apache.cassandra.streaming.StreamState java.util.Map javax.management.openmbean.CompositeData[] long long long long top java.util.Iterator
      StackMap stack:
        12: aload 12
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast org.apache.cassandra.streaming.SessionInfo
            astore 11 /* sessInfo */
        start local 11 // org.apache.cassandra.streaming.SessionInfo sessInfo
        13: .line 94
            lload 3 /* currentRxBytes */
            aload 11 /* sessInfo */
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeReceived:()J
            ladd
            lstore 3 /* currentRxBytes */
        14: .line 95
            lload 5 /* totalRxBytes */
            aload 11 /* sessInfo */
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeToReceive:()J
            ladd
            lstore 5 /* totalRxBytes */
        15: .line 96
            lload 7 /* currentTxBytes */
            aload 11 /* sessInfo */
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeSent:()J
            ladd
            lstore 7 /* currentTxBytes */
        16: .line 97
            lload 9 /* totalTxBytes */
            aload 11 /* sessInfo */
            invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeToSend:()J
            ladd
            lstore 9 /* totalTxBytes */
        end local 11 // org.apache.cassandra.streaming.SessionInfo sessInfo
        17: .line 92
      StackMap locals:
      StackMap stack:
            aload 12
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 12
        18: .line 99
            lload 5 /* totalRxBytes */
            lconst_0
            lcmp
            ifne 19
            ldc 100
            goto 20
      StackMap locals: org.apache.cassandra.streaming.StreamState java.util.Map javax.management.openmbean.CompositeData[] long long long long
      StackMap stack:
        19: lload 3 /* currentRxBytes */
            ldc 100
            lmul
            lload 5 /* totalRxBytes */
            ldiv
      StackMap locals:
      StackMap stack: long
        20: l2d
            dstore 11 /* rxPercentage */
        start local 11 // double rxPercentage
        21: .line 100
            lload 9 /* totalTxBytes */
            lconst_0
            lcmp
            ifne 22
            ldc 100
            goto 23
      StackMap locals: double
      StackMap stack:
        22: lload 7 /* currentTxBytes */
            ldc 100
            lmul
            lload 9 /* totalTxBytes */
            ldiv
      StackMap locals:
      StackMap stack: long
        23: l2d
            dstore 13 /* txPercentage */
        start local 13 // double txPercentage
        24: .line 102
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            iconst_3
            aaload
            lload 3 /* currentRxBytes */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        25: .line 103
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            iconst_4
            aaload
            lload 5 /* totalRxBytes */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        26: .line 104
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            iconst_5
            aaload
            dload 11 /* rxPercentage */
            invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        27: .line 105
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            bipush 6
            aaload
            lload 7 /* currentTxBytes */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        28: .line 106
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            bipush 7
            aaload
            lload 9 /* totalTxBytes */
            invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        29: .line 107
            aload 1 /* valueMap */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            bipush 8
            aaload
            dload 13 /* txPercentage */
            invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
            invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
            pop
        30: .line 111
            new javax.management.openmbean.CompositeDataSupport
            dup
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.COMPOSITE_TYPE:Ljavax/management/openmbean/CompositeType;
            aload 1 /* valueMap */
            invokespecial javax.management.openmbean.CompositeDataSupport.<init>:(Ljavax/management/openmbean/CompositeType;Ljava/util/Map;)V
        31: areturn
        32: .line 113
      StackMap locals: org.apache.cassandra.streaming.StreamState java.util.Map javax.management.openmbean.CompositeData[] long long long long double double
      StackMap stack: javax.management.openmbean.OpenDataException
            astore 15 /* e */
        start local 15 // javax.management.openmbean.OpenDataException e
        33: .line 115
            aload 15 /* e */
            invokestatic com.google.common.base.Throwables.propagate:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
            athrow
        end local 15 // javax.management.openmbean.OpenDataException e
        end local 13 // double txPercentage
        end local 11 // double rxPercentage
        end local 9 // long totalTxBytes
        end local 7 // long currentTxBytes
        end local 5 // long totalRxBytes
        end local 3 // long currentRxBytes
        end local 2 // javax.management.openmbean.CompositeData[] sessions
        end local 1 // java.util.Map valueMap
        end local 0 // org.apache.cassandra.streaming.StreamState streamState
      LocalVariableTable:
        Start  End  Slot            Name  Signature
            0   34     0     streamState  Lorg/apache/cassandra/streaming/StreamState;
            1   34     1        valueMap  Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
            4   34     2        sessions  [Ljavax/management/openmbean/CompositeData;
            8   34     3  currentRxBytes  J
            9   34     5    totalRxBytes  J
           10   34     7  currentTxBytes  J
           11   34     9    totalTxBytes  J
           13   17    11        sessInfo  Lorg/apache/cassandra/streaming/SessionInfo;
           21   34    11    rxPercentage  D
           24   34    13    txPercentage  D
           33   34    15               e  Ljavax/management/openmbean/OpenDataException;
      Exception table:
        from    to  target  type
          30    31      32  Class javax.management.openmbean.OpenDataException
    MethodParameters:
             Name  Flags
      streamState  final

  public static org.apache.cassandra.streaming.StreamState fromCompositeData(javax.management.openmbean.CompositeData);
    descriptor: (Ljavax/management/openmbean/CompositeData;)Lorg/apache/cassandra/streaming/StreamState;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=5, locals=5, args_size=1
        start local 0 // javax.management.openmbean.CompositeData cd
         0: .line 121
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.$assertionsDisabled:Z
            ifne 1
            aload 0 /* cd */
            invokeinterface javax.management.openmbean.CompositeData.getCompositeType:()Ljavax/management/openmbean/CompositeType;
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.COMPOSITE_TYPE:Ljavax/management/openmbean/CompositeType;
            invokevirtual javax.management.openmbean.CompositeType.equals:(Ljava/lang/Object;)Z
            ifne 1
            new java.lang.AssertionError
            dup
            invokespecial java.lang.AssertionError.<init>:()V
            athrow
         1: .line 122
      StackMap locals:
      StackMap stack:
            aload 0 /* cd */
            getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
            invokeinterface javax.management.openmbean.CompositeData.getAll:([Ljava/lang/String;)[Ljava/lang/Object;
            astore 1 /* values */
        start local 1 // java.lang.Object[] values
         2: .line 123
            aload 1 /* values */
            iconst_0
            aaload
            checkcast java.lang.String
            invokestatic java.util.UUID.fromString:(Ljava/lang/String;)Ljava/util/UUID;
            astore 2 /* planId */
        start local 2 // java.util.UUID planId
         3: .line 124
            aload 1 /* values */
            iconst_1
            aaload
            checkcast java.lang.String
            astore 3 /* description */
        start local 3 // java.lang.String description
         4: .line 125
            aload 1 /* values */
            iconst_2
            aaload
            checkcast javax.management.openmbean.CompositeData[]
            invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
         5: .line 126
            new org.apache.cassandra.streaming.management.StreamStateCompositeData$2
            dup
            invokespecial org.apache.cassandra.streaming.management.StreamStateCompositeData$2.<init>:()V
         6: .line 125
            invokestatic com.google.common.collect.Iterables.transform:(Ljava/lang/Iterable;Lcom/google/common/base/Function;)Ljava/lang/Iterable;
            invokestatic com.google.common.collect.Sets.newHashSet:(Ljava/lang/Iterable;)Ljava/util/HashSet;
            astore 4 /* sessions */
        start local 4 // java.util.Set sessions
         7: .line 133
            new org.apache.cassandra.streaming.StreamState
            dup
            aload 2 /* planId */
            aload 3 /* description */
            aload 4 /* sessions */
            invokespecial org.apache.cassandra.streaming.StreamState.<init>:(Ljava/util/UUID;Ljava/lang/String;Ljava/util/Set;)V
            areturn
        end local 4 // java.util.Set sessions
        end local 3 // java.lang.String description
        end local 2 // java.util.UUID planId
        end local 1 // java.lang.Object[] values
        end local 0 // javax.management.openmbean.CompositeData cd
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    8     0           cd  Ljavax/management/openmbean/CompositeData;
            2    8     1       values  [Ljava/lang/Object;
            3    8     2       planId  Ljava/util/UUID;
            4    8     3  description  Ljava/lang/String;
            7    8     4     sessions  Ljava/util/Set<Lorg/apache/cassandra/streaming/SessionInfo;>;
    MethodParameters:
      Name  Flags
      cd    
}
SourceFile: "StreamStateCompositeData.java"
NestMembers:
  org.apache.cassandra.streaming.management.StreamStateCompositeData$1  org.apache.cassandra.streaming.management.StreamStateCompositeData$2
InnerClasses:
  org.apache.cassandra.streaming.management.StreamStateCompositeData$1
  org.apache.cassandra.streaming.management.StreamStateCompositeData$2