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: 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: 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: ldc "currentRxBytes"
aastore
dup
iconst_4
ldc "totalRxBytes"
aastore
dup
iconst_5
ldc "rxPercentage"
aastore
dup
bipush 6
5: ldc "currentTxBytes"
aastore
dup
bipush 7
ldc "totalTxBytes"
aastore
dup
bipush 8
ldc "txPercentage"
aastore
6: putstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
7: bipush 9
anewarray java.lang.String
dup
iconst_0
ldc "Plan ID of this stream"
aastore
dup
iconst_1
8: ldc "Stream plan description"
aastore
dup
iconst_2
9: ldc "Active stream sessions"
aastore
dup
iconst_3
10: ldc "Number of bytes received across all streams"
aastore
dup
iconst_4
11: ldc "Total bytes available to receive across all streams"
aastore
dup
iconst_5
12: ldc "Percentage received across all streams"
aastore
dup
bipush 6
13: ldc "Number of bytes sent across all streams"
aastore
dup
bipush 7
14: ldc "Total bytes available to send across all streams"
aastore
dup
bipush 8
15: ldc "Percentage sent across all streams"
aastore
16: putstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_DESCS:[Ljava/lang/String;
17: 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: getstatic javax.management.openmbean.SimpleType.STRING:Ljavax/management/openmbean/SimpleType;
aastore
dup
iconst_2
19: 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: 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: 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: putstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_TYPES:[Ljavax/management/openmbean/OpenType;
23: new javax.management.openmbean.CompositeType
dup
ldc Lorg/apache/cassandra/streaming/StreamState;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
24: ldc "StreamState"
25: getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
26: getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_DESCS:[Ljava/lang/String;
27: getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_TYPES:[Ljavax/management/openmbean/OpenType;
28: 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: goto 32
30: StackMap locals:
StackMap stack: javax.management.openmbean.OpenDataException
astore 0
start local 0 31: aload 0
invokestatic com.google.common.base.Throwables.propagate:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
athrow
end local 0 32: 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 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 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 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 1
start local 1 1: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
iconst_0
aaload
aload 0
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: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
iconst_1
aaload
aload 0
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: aload 0
getfield org.apache.cassandra.streaming.StreamState.sessions:Ljava/util/Set;
invokeinterface java.util.Set.size:()I
anewarray javax.management.openmbean.CompositeData
astore 2
start local 2 4: aload 0
getfield org.apache.cassandra.streaming.StreamState.sessions:Ljava/util/Set;
new org.apache.cassandra.streaming.management.StreamStateCompositeData$1
dup
aload 0
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: aload 2
invokevirtual java.util.ArrayList.toArray:([Ljava/lang/Object;)[Ljava/lang/Object;
pop
6: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
iconst_2
aaload
aload 2
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: lconst_0
lstore 3
start local 3 8: lconst_0
lstore 5
start local 5 9: lconst_0
lstore 7
start local 7 10: lconst_0
lstore 9
start local 9 11: aload 0
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
start local 11 13: lload 3
aload 11
invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeReceived:()J
ladd
lstore 3
14: lload 5
aload 11
invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeToReceive:()J
ladd
lstore 5
15: lload 7
aload 11
invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeSent:()J
ladd
lstore 7
16: lload 9
aload 11
invokevirtual org.apache.cassandra.streaming.SessionInfo.getTotalSizeToSend:()J
ladd
lstore 9
end local 11 17: StackMap locals:
StackMap stack:
aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifne 12
18: lload 5
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
ldc 100
lmul
lload 5
ldiv
StackMap locals:
StackMap stack: long
20: l2d
dstore 11
start local 11 21: lload 9
lconst_0
lcmp
ifne 22
ldc 100
goto 23
StackMap locals: double
StackMap stack:
22: lload 7
ldc 100
lmul
lload 9
ldiv
StackMap locals:
StackMap stack: long
23: l2d
dstore 13
start local 13 24: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
iconst_3
aaload
lload 3
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: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
iconst_4
aaload
lload 5
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: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
iconst_5
aaload
dload 11
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: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
bipush 6
aaload
lload 7
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: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
bipush 7
aaload
lload 9
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: aload 1
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.ITEM_NAMES:[Ljava/lang/String;
bipush 8
aaload
dload 13
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: new javax.management.openmbean.CompositeDataSupport
dup
getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.COMPOSITE_TYPE:Ljavax/management/openmbean/CompositeType;
aload 1
invokespecial javax.management.openmbean.CompositeDataSupport.<init>:(Ljavax/management/openmbean/CompositeType;Ljava/util/Map;)V
31: areturn
32: 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
start local 15 33: aload 15
invokestatic com.google.common.base.Throwables.propagate:(Ljava/lang/Throwable;)Ljava/lang/RuntimeException;
athrow
end local 15 end local 13 end local 11 end local 9 end local 7 end local 5 end local 3 end local 2 end local 1 end local 0 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 0: getstatic org.apache.cassandra.streaming.management.StreamStateCompositeData.$assertionsDisabled:Z
ifne 1
aload 0
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: StackMap locals:
StackMap stack:
aload 0
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
start local 1 2: aload 1
iconst_0
aaload
checkcast java.lang.String
invokestatic java.util.UUID.fromString:(Ljava/lang/String;)Ljava/util/UUID;
astore 2
start local 2 3: aload 1
iconst_1
aaload
checkcast java.lang.String
astore 3
start local 3 4: aload 1
iconst_2
aaload
checkcast javax.management.openmbean.CompositeData[]
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
5: new org.apache.cassandra.streaming.management.StreamStateCompositeData$2
dup
invokespecial org.apache.cassandra.streaming.management.StreamStateCompositeData$2.<init>:()V
6: 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
start local 4 7: new org.apache.cassandra.streaming.StreamState
dup
aload 2
aload 3
aload 4
invokespecial org.apache.cassandra.streaming.StreamState.<init>:(Ljava/util/UUID;Ljava/lang/String;Ljava/util/Set;)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 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