public class org.apache.cassandra.repair.messages.RepairOption
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.repair.messages.RepairOption
super_class: java.lang.Object
{
public static final java.lang.String PARALLELISM_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "parallelism"
public static final java.lang.String PRIMARY_RANGE_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "primaryRange"
public static final java.lang.String INCREMENTAL_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "incremental"
public static final java.lang.String JOB_THREADS_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "jobThreads"
public static final java.lang.String RANGES_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "ranges"
public static final java.lang.String COLUMNFAMILIES_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "columnFamilies"
public static final java.lang.String DATACENTERS_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "dataCenters"
public static final java.lang.String HOSTS_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "hosts"
public static final java.lang.String TRACE_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "trace"
public static final java.lang.String SUB_RANGE_REPAIR_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "sub_range_repair"
public static final java.lang.String PULL_REPAIR_KEY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "pullRepair"
public static final int MAX_JOB_THREADS;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 4
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final org.apache.cassandra.repair.RepairParallelism parallelism;
descriptor: Lorg/apache/cassandra/repair/RepairParallelism;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean primaryRange;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean incremental;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean trace;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final int jobThreads;
descriptor: I
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean isSubrangeRepair;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean pullRepair;
descriptor: Z
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.Collection<java.lang.String> columnFamilies;
descriptor: Ljava/util/Collection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Collection<Ljava/lang/String;>;
private final java.util.Collection<java.lang.String> dataCenters;
descriptor: Ljava/util/Collection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Collection<Ljava/lang/String;>;
private final java.util.Collection<java.lang.String> hosts;
descriptor: Ljava/util/Collection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Collection<Ljava/lang/String;>;
private final java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>> ranges;
descriptor: Ljava/util/Collection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/repair/messages/RepairOption;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.repair.messages.RepairOption.logger:Lorg/slf4j/Logger;
return
LocalVariableTable:
Start End Slot Name Signature
public static org.apache.cassandra.repair.messages.RepairOption parse(java.util.Map<java.lang.String, java.lang.String>, org.apache.cassandra.dht.IPartitioner);
descriptor: (Ljava/util/Map;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/repair/messages/RepairOption;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=10, locals=18, args_size=2
start local 0 start local 1 0: aload 0
ldc "parallelism"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic org.apache.cassandra.repair.RepairParallelism.fromName:(Ljava/lang/String;)Lorg/apache/cassandra/repair/RepairParallelism;
astore 2
start local 2 1: aload 0
ldc "primaryRange"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic java.lang.Boolean.parseBoolean:(Ljava/lang/String;)Z
istore 3
start local 3 2: aload 0
ldc "incremental"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic java.lang.Boolean.parseBoolean:(Ljava/lang/String;)Z
istore 4
start local 4 3: aload 0
ldc "trace"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic java.lang.Boolean.parseBoolean:(Ljava/lang/String;)Z
istore 5
start local 5 4: aload 0
ldc "pullRepair"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic java.lang.Boolean.parseBoolean:(Ljava/lang/String;)Z
istore 6
start local 6 5: iconst_1
istore 7
start local 7 6: aload 0
ldc "jobThreads"
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 10
7: aload 0
ldc "jobThreads"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
invokestatic java.lang.Integer.parseInt:(Ljava/lang/String;)I
istore 7
8: goto 10
9: StackMap locals: java.util.Map org.apache.cassandra.dht.IPartitioner org.apache.cassandra.repair.RepairParallelism int int int int int
StackMap stack: java.lang.NumberFormatException
pop
10: StackMap locals:
StackMap stack:
aload 0
ldc "ranges"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 8
start local 8 11: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 9
start local 9 12: aload 8
ifnull 26
13: iload 4
ifeq 15
14: getstatic org.apache.cassandra.repair.messages.RepairOption.logger:Lorg/slf4j/Logger;
ldc "Incremental repair can't be requested with subrange repair because each subrange repair would generate an anti-compacted table. The repair will occur but without anti-compaction."
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;)V
15: StackMap locals: java.lang.String java.util.Set
StackMap stack:
new java.util.StringTokenizer
dup
aload 8
ldc ","
invokespecial java.util.StringTokenizer.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 10
start local 10 16: goto 25
17: StackMap locals: java.util.StringTokenizer
StackMap stack:
aload 10
invokevirtual java.util.StringTokenizer.nextToken:()Ljava/lang/String;
ldc ":"
iconst_2
invokevirtual java.lang.String.split:(Ljava/lang/String;I)[Ljava/lang/String;
astore 11
start local 11 18: aload 11
arraylength
iconst_2
if_icmpge 20
19: goto 25
20: StackMap locals: java.lang.String[]
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.dht.IPartitioner.getTokenFactory:()Lorg/apache/cassandra/dht/Token$TokenFactory;
aload 11
iconst_0
aaload
invokevirtual java.lang.String.trim:()Ljava/lang/String;
invokevirtual org.apache.cassandra.dht.Token$TokenFactory.fromString:(Ljava/lang/String;)Lorg/apache/cassandra/dht/Token;
astore 12
start local 12 21: aload 1
invokeinterface org.apache.cassandra.dht.IPartitioner.getTokenFactory:()Lorg/apache/cassandra/dht/Token$TokenFactory;
aload 11
iconst_1
aaload
invokevirtual java.lang.String.trim:()Ljava/lang/String;
invokevirtual org.apache.cassandra.dht.Token$TokenFactory.fromString:(Ljava/lang/String;)Lorg/apache/cassandra/dht/Token;
astore 13
start local 13 22: aload 12
aload 13
invokevirtual java.lang.Object.equals:(Ljava/lang/Object;)Z
ifeq 24
23: new java.lang.IllegalArgumentException
dup
ldc "Start and end tokens must be different."
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
24: StackMap locals: org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token
StackMap stack:
aload 9
new org.apache.cassandra.dht.Range
dup
aload 12
aload 13
invokespecial org.apache.cassandra.dht.Range.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 13 end local 12 end local 11 25: StackMap locals:
StackMap stack:
aload 10
invokevirtual java.util.StringTokenizer.hasMoreTokens:()Z
ifne 17
end local 10 26: StackMap locals:
StackMap stack:
new org.apache.cassandra.repair.messages.RepairOption
dup
aload 2
iload 3
iload 4
iload 5
iload 7
aload 9
aload 9
invokeinterface java.util.Set.isEmpty:()Z
ifeq 27
iconst_0
goto 28
StackMap locals: java.util.Map org.apache.cassandra.dht.IPartitioner org.apache.cassandra.repair.RepairParallelism int int int int int java.lang.String java.util.Set
StackMap stack: new 26 new 26 org.apache.cassandra.repair.RepairParallelism int int int int java.util.Set
27: iconst_1
StackMap locals: java.util.Map org.apache.cassandra.dht.IPartitioner org.apache.cassandra.repair.RepairParallelism int int int int int java.lang.String java.util.Set
StackMap stack: new 26 new 26 org.apache.cassandra.repair.RepairParallelism int int int int java.util.Set int
28: iload 6
invokespecial org.apache.cassandra.repair.messages.RepairOption.<init>:(Lorg/apache/cassandra/repair/RepairParallelism;ZZZILjava/util/Collection;ZZ)V
astore 10
start local 10 29: aload 0
ldc "dataCenters"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 11
start local 11 30: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 12
start local 12 31: aload 11
ifnull 37
32: new java.util.StringTokenizer
dup
aload 11
ldc ","
invokespecial java.util.StringTokenizer.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 13
start local 13 33: goto 35
34: StackMap locals: java.util.Map org.apache.cassandra.dht.IPartitioner org.apache.cassandra.repair.RepairParallelism int int int int int java.lang.String java.util.Set org.apache.cassandra.repair.messages.RepairOption java.lang.String java.util.Collection java.util.StringTokenizer
StackMap stack:
aload 12
aload 13
invokevirtual java.util.StringTokenizer.nextToken:()Ljava/lang/String;
invokevirtual java.lang.String.trim:()Ljava/lang/String;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
35: StackMap locals:
StackMap stack:
aload 13
invokevirtual java.util.StringTokenizer.hasMoreTokens:()Z
ifne 34
36: aload 10
invokevirtual org.apache.cassandra.repair.messages.RepairOption.getDataCenters:()Ljava/util/Collection;
aload 12
invokeinterface java.util.Collection.addAll:(Ljava/util/Collection;)Z
pop
end local 13 37: StackMap locals:
StackMap stack:
aload 0
ldc "hosts"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 13
start local 13 38: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 14
start local 14 39: aload 13
ifnull 45
40: new java.util.StringTokenizer
dup
aload 13
ldc ","
invokespecial java.util.StringTokenizer.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 15
start local 15 41: goto 43
42: StackMap locals: java.lang.String java.util.Collection java.util.StringTokenizer
StackMap stack:
aload 14
aload 15
invokevirtual java.util.StringTokenizer.nextToken:()Ljava/lang/String;
invokevirtual java.lang.String.trim:()Ljava/lang/String;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
43: StackMap locals:
StackMap stack:
aload 15
invokevirtual java.util.StringTokenizer.hasMoreTokens:()Z
ifne 42
44: aload 10
invokevirtual org.apache.cassandra.repair.messages.RepairOption.getHosts:()Ljava/util/Collection;
aload 14
invokeinterface java.util.Collection.addAll:(Ljava/util/Collection;)Z
pop
end local 15 45: StackMap locals:
StackMap stack:
aload 0
ldc "columnFamilies"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 15
start local 15 46: aload 15
ifnull 53
47: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 16
start local 16 48: new java.util.StringTokenizer
dup
aload 15
ldc ","
invokespecial java.util.StringTokenizer.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 17
start local 17 49: goto 51
50: StackMap locals: java.lang.String java.util.Collection java.util.StringTokenizer
StackMap stack:
aload 16
aload 17
invokevirtual java.util.StringTokenizer.nextToken:()Ljava/lang/String;
invokevirtual java.lang.String.trim:()Ljava/lang/String;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
51: StackMap locals:
StackMap stack:
aload 17
invokevirtual java.util.StringTokenizer.hasMoreTokens:()Z
ifne 50
52: aload 10
invokevirtual org.apache.cassandra.repair.messages.RepairOption.getColumnFamilies:()Ljava/util/Collection;
aload 16
invokeinterface java.util.Collection.addAll:(Ljava/util/Collection;)Z
pop
end local 17 end local 16 53: StackMap locals:
StackMap stack:
iload 7
iconst_4
if_icmple 55
54: new java.lang.IllegalArgumentException
dup
ldc "Too many job threads. Max is 4"
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
55: StackMap locals:
StackMap stack:
aload 12
invokeinterface java.util.Collection.isEmpty:()Z
ifne 57
aload 14
invokeinterface java.util.Collection.isEmpty:()Z
ifne 57
56: new java.lang.IllegalArgumentException
dup
ldc "Cannot combine -dc and -hosts options."
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
57: StackMap locals:
StackMap stack:
iload 3
ifeq 60
aload 12
invokeinterface java.util.Collection.isEmpty:()Z
ifne 58
aload 10
invokevirtual org.apache.cassandra.repair.messages.RepairOption.isInLocalDCOnly:()Z
ifeq 59
StackMap locals:
StackMap stack:
58: aload 14
invokeinterface java.util.Collection.isEmpty:()Z
ifne 60
59: StackMap locals:
StackMap stack:
new java.lang.IllegalArgumentException
dup
ldc "You need to run primary range repair on all nodes in the cluster."
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
60: StackMap locals:
StackMap stack:
iload 6
ifeq 65
61: aload 14
invokeinterface java.util.Collection.size:()I
iconst_2
if_icmpeq 63
62: new java.lang.IllegalArgumentException
dup
ldc "Pull repair can only be performed between two hosts. Please specify two hosts, one of which must be this host."
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
63: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Set.isEmpty:()Z
ifeq 65
64: new java.lang.IllegalArgumentException
dup
ldc "Token ranges must be specified when performing pull repair. Please specify at least one token range which both hosts have in common."
invokespecial java.lang.IllegalArgumentException.<init>:(Ljava/lang/String;)V
athrow
65: StackMap locals:
StackMap stack:
aload 10
areturn
end local 15 end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 66 0 options Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
0 66 1 partitioner Lorg/apache/cassandra/dht/IPartitioner;
1 66 2 parallelism Lorg/apache/cassandra/repair/RepairParallelism;
2 66 3 primaryRange Z
3 66 4 incremental Z
4 66 5 trace Z
5 66 6 pullRepair Z
6 66 7 jobThreads I
11 66 8 rangesStr Ljava/lang/String;
12 66 9 ranges Ljava/util/Set<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
16 26 10 tokenizer Ljava/util/StringTokenizer;
18 25 11 rangeStr [Ljava/lang/String;
21 25 12 parsedBeginToken Lorg/apache/cassandra/dht/Token;
22 25 13 parsedEndToken Lorg/apache/cassandra/dht/Token;
29 66 10 option Lorg/apache/cassandra/repair/messages/RepairOption;
30 66 11 dataCentersStr Ljava/lang/String;
31 66 12 dataCenters Ljava/util/Collection<Ljava/lang/String;>;
33 37 13 tokenizer Ljava/util/StringTokenizer;
38 66 13 hostsStr Ljava/lang/String;
39 66 14 hosts Ljava/util/Collection<Ljava/lang/String;>;
41 45 15 tokenizer Ljava/util/StringTokenizer;
46 66 15 cfStr Ljava/lang/String;
48 53 16 columnFamilies Ljava/util/Collection<Ljava/lang/String;>;
49 53 17 tokenizer Ljava/util/StringTokenizer;
Exception table:
from to target type
7 8 9 Class java.lang.NumberFormatException
Signature: (Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/repair/messages/RepairOption;
MethodParameters:
Name Flags
options
partitioner
public void <init>(org.apache.cassandra.repair.RepairParallelism, boolean, boolean, boolean, int, java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>, boolean, );
descriptor: (Lorg/apache/cassandra/repair/RepairParallelism;ZZZILjava/util/Collection;ZZ)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=9, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield org.apache.cassandra.repair.messages.RepairOption.columnFamilies:Ljava/util/Collection;
2: aload 0
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield org.apache.cassandra.repair.messages.RepairOption.dataCenters:Ljava/util/Collection;
3: aload 0
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield org.apache.cassandra.repair.messages.RepairOption.hosts:Ljava/util/Collection;
4: aload 0
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
putfield org.apache.cassandra.repair.messages.RepairOption.ranges:Ljava/util/Collection;
5: getstatic org.apache.cassandra.utils.FBUtilities.isWindows:Z
ifeq 11
6: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getDiskAccessMode:()Lorg/apache/cassandra/config/Config$DiskAccessMode;
getstatic org.apache.cassandra.config.Config$DiskAccessMode.standard:Lorg/apache/cassandra/config/Config$DiskAccessMode;
if_acmpne 7
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getIndexAccessMode:()Lorg/apache/cassandra/config/Config$DiskAccessMode;
getstatic org.apache.cassandra.config.Config$DiskAccessMode.standard:Lorg/apache/cassandra/config/Config$DiskAccessMode;
if_acmpeq 11
7: StackMap locals: org.apache.cassandra.repair.messages.RepairOption org.apache.cassandra.repair.RepairParallelism int int int int java.util.Collection int int
StackMap stack:
aload 1
getstatic org.apache.cassandra.repair.RepairParallelism.SEQUENTIAL:Lorg/apache/cassandra/repair/RepairParallelism;
if_acmpne 11
8: getstatic org.apache.cassandra.repair.messages.RepairOption.logger:Lorg/slf4j/Logger;
ldc "Sequential repair disabled when memory-mapped I/O is configured on Windows. Reverting to parallel."
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;)V
9: aload 0
getstatic org.apache.cassandra.repair.RepairParallelism.PARALLEL:Lorg/apache/cassandra/repair/RepairParallelism;
putfield org.apache.cassandra.repair.messages.RepairOption.parallelism:Lorg/apache/cassandra/repair/RepairParallelism;
10: goto 12
11: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield org.apache.cassandra.repair.messages.RepairOption.parallelism:Lorg/apache/cassandra/repair/RepairParallelism;
12: StackMap locals:
StackMap stack:
aload 0
iload 2
putfield org.apache.cassandra.repair.messages.RepairOption.primaryRange:Z
13: aload 0
iload 3
putfield org.apache.cassandra.repair.messages.RepairOption.incremental:Z
14: aload 0
iload 4
putfield org.apache.cassandra.repair.messages.RepairOption.trace:Z
15: aload 0
iload 5
putfield org.apache.cassandra.repair.messages.RepairOption.jobThreads:I
16: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.ranges:Ljava/util/Collection;
aload 6
invokeinterface java.util.Collection.addAll:(Ljava/util/Collection;)Z
pop
17: aload 0
iload 7
putfield org.apache.cassandra.repair.messages.RepairOption.isSubrangeRepair:Z
18: aload 0
iload 8
putfield org.apache.cassandra.repair.messages.RepairOption.pullRepair:Z
19: return
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
0 20 1 parallelism Lorg/apache/cassandra/repair/RepairParallelism;
0 20 2 primaryRange Z
0 20 3 incremental Z
0 20 4 trace Z
0 20 5 jobThreads I
0 20 6 ranges Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
0 20 7 isSubrangeRepair Z
0 20 8 pullRepair Z
Signature: (Lorg/apache/cassandra/repair/RepairParallelism;ZZZILjava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;ZZ)V
MethodParameters:
Name Flags
parallelism
primaryRange
incremental
trace
jobThreads
ranges
isSubrangeRepair
pullRepair
public org.apache.cassandra.repair.RepairParallelism getParallelism();
descriptor: ()Lorg/apache/cassandra/repair/RepairParallelism;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.parallelism:Lorg/apache/cassandra/repair/RepairParallelism;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public boolean isPrimaryRange();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.primaryRange:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public boolean isIncremental();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.incremental:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public boolean isTraced();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.trace:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public boolean isPullRepair();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.pullRepair:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public int getJobThreads();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.jobThreads:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public java.util.Collection<java.lang.String> getColumnFamilies();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.columnFamilies:Ljava/util/Collection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
Signature: ()Ljava/util/Collection<Ljava/lang/String;>;
public java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>> getRanges();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.ranges:Ljava/util/Collection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
public java.util.Collection<java.lang.String> getDataCenters();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.dataCenters:Ljava/util/Collection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
Signature: ()Ljava/util/Collection<Ljava/lang/String;>;
public java.util.Collection<java.lang.String> getHosts();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.hosts:Ljava/util/Collection;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
Signature: ()Ljava/util/Collection<Ljava/lang/String;>;
public boolean isGlobal();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.dataCenters:Ljava/util/Collection;
invokeinterface java.util.Collection.isEmpty:()Z
ifeq 1
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.hosts:Ljava/util/Collection;
invokeinterface java.util.Collection.isEmpty:()Z
ifeq 1
aload 0
invokevirtual org.apache.cassandra.repair.messages.RepairOption.isSubrangeRepair:()Z
ifne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public boolean isSubrangeRepair();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.isSubrangeRepair:Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public boolean isInLocalDCOnly();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.dataCenters:Ljava/util/Collection;
invokeinterface java.util.Collection.size:()I
iconst_1
if_icmpne 1
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.dataCenters:Ljava/util/Collection;
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getLocalDataCenter:()Ljava/lang/String;
invokeinterface java.util.Collection.contains:(Ljava/lang/Object;)Z
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "repair options (parallelism: "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
1: aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.parallelism:Lorg/apache/cassandra/repair/RepairParallelism;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
2: ldc ", primary range: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.primaryRange:Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
3: ldc ", incremental: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.incremental:Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
4: ldc ", job threads: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.jobThreads:I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
5: ldc ", ColumnFamilies: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.columnFamilies:Ljava/util/Collection;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
6: ldc ", dataCenters: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.dataCenters:Ljava/util/Collection;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
7: ldc ", hosts: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.hosts:Ljava/util/Collection;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
8: ldc ", # of ranges: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.ranges:Ljava/util/Collection;
invokeinterface java.util.Collection.size:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
9: ldc ", pull repair: "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.pullRepair:Z
invokevirtual java.lang.StringBuilder.append:(Z)Ljava/lang/StringBuilder;
10: bipush 41
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
11: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
public java.util.Map<java.lang.String, java.lang.String> asMap();
descriptor: ()Ljava/util/Map;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, 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
ldc "parallelism"
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.parallelism:Lorg/apache/cassandra/repair/RepairParallelism;
invokevirtual org.apache.cassandra.repair.RepairParallelism.toString:()Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: aload 1
ldc "primaryRange"
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.primaryRange:Z
invokestatic java.lang.Boolean.toString:(Z)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
3: aload 1
ldc "incremental"
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.incremental:Z
invokestatic java.lang.Boolean.toString:(Z)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
4: aload 1
ldc "jobThreads"
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.jobThreads:I
invokestatic java.lang.Integer.toString:(I)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
5: aload 1
ldc "columnFamilies"
ldc ","
invokestatic com.google.common.base.Joiner.on:(Ljava/lang/String;)Lcom/google/common/base/Joiner;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.columnFamilies:Ljava/util/Collection;
invokevirtual com.google.common.base.Joiner.join:(Ljava/lang/Iterable;)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: aload 1
ldc "dataCenters"
ldc ","
invokestatic com.google.common.base.Joiner.on:(Ljava/lang/String;)Lcom/google/common/base/Joiner;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.dataCenters:Ljava/util/Collection;
invokevirtual com.google.common.base.Joiner.join:(Ljava/lang/Iterable;)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 1
ldc "hosts"
ldc ","
invokestatic com.google.common.base.Joiner.on:(Ljava/lang/String;)Lcom/google/common/base/Joiner;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.hosts:Ljava/util/Collection;
invokevirtual com.google.common.base.Joiner.join:(Ljava/lang/Iterable;)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
8: aload 1
ldc "sub_range_repair"
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.isSubrangeRepair:Z
invokestatic java.lang.Boolean.toString:(Z)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
9: aload 1
ldc "trace"
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.trace:Z
invokestatic java.lang.Boolean.toString:(Z)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
10: aload 1
ldc "ranges"
ldc ","
invokestatic com.google.common.base.Joiner.on:(Ljava/lang/String;)Lcom/google/common/base/Joiner;
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.ranges:Ljava/util/Collection;
invokevirtual com.google.common.base.Joiner.join:(Ljava/lang/Iterable;)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
11: aload 1
ldc "pullRepair"
aload 0
getfield org.apache.cassandra.repair.messages.RepairOption.pullRepair:Z
invokestatic java.lang.Boolean.toString:(Z)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
12: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/repair/messages/RepairOption;
1 13 1 options Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: ()Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
}
SourceFile: "RepairOption.java"
InnerClasses:
public final DiskAccessMode = org.apache.cassandra.config.Config$DiskAccessMode of org.apache.cassandra.config.Config
public abstract TokenFactory = org.apache.cassandra.dht.Token$TokenFactory of org.apache.cassandra.dht.Token