public final class org.apache.cassandra.db.SystemKeyspace
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: org.apache.cassandra.db.SystemKeyspace
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final org.apache.cassandra.utils.CassandraVersion UNREADABLE_VERSION;
descriptor: Lorg/apache/cassandra/utils/CassandraVersion;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
public static final org.apache.cassandra.utils.CassandraVersion NULL_VERSION;
descriptor: Lorg/apache/cassandra/utils/CassandraVersion;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
public static final java.lang.String BATCHES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "batches"
public static final java.lang.String PAXOS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "paxos"
public static final java.lang.String BUILT_INDEXES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "IndexInfo"
public static final java.lang.String LOCAL;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "local"
public static final java.lang.String PEERS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "peers"
public static final java.lang.String PEER_EVENTS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "peer_events"
public static final java.lang.String RANGE_XFERS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "range_xfers"
public static final java.lang.String COMPACTION_HISTORY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "compaction_history"
public static final java.lang.String SSTABLE_ACTIVITY;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "sstable_activity"
public static final java.lang.String SIZE_ESTIMATES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "size_estimates"
public static final java.lang.String AVAILABLE_RANGES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "available_ranges"
public static final java.lang.String TRANSFERRED_RANGES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "transferred_ranges"
public static final java.lang.String VIEWS_BUILDS_IN_PROGRESS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "views_builds_in_progress"
public static final java.lang.String BUILT_VIEWS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "built_views"
public static final java.lang.String PREPARED_STATEMENTS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "prepared_statements"
public static final java.lang.String LEGACY_HINTS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "hints"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final java.lang.String LEGACY_BATCHLOG;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "batchlog"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final java.lang.String LEGACY_KEYSPACES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "schema_keyspaces"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final java.lang.String LEGACY_COLUMNFAMILIES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "schema_columnfamilies"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final java.lang.String LEGACY_COLUMNS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "schema_columns"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final java.lang.String LEGACY_TRIGGERS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "schema_triggers"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final java.lang.String LEGACY_USERTYPES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "schema_usertypes"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final java.lang.String LEGACY_FUNCTIONS;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "schema_functions"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final java.lang.String LEGACY_AGGREGATES;
descriptor: Ljava/lang/String;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: "schema_aggregates"
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData Batches;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData Paxos;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData BuiltIndexes;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData Local;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData Peers;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData PeerEvents;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData RangeXfers;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData CompactionHistory;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData SSTableActivity;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData SizeEstimates;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData AvailableRanges;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData TransferredRanges;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData ViewsBuildsInProgress;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData BuiltViews;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final org.apache.cassandra.config.CFMetaData PreparedStatements;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final org.apache.cassandra.config.CFMetaData LegacyHints;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData LegacyBatchlog;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData LegacyKeyspaces;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData LegacyColumnfamilies;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData LegacyColumns;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData LegacyTriggers;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData LegacyUsertypes;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData LegacyFunctions;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
public static final org.apache.cassandra.config.CFMetaData LegacyAggregates;
descriptor: Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
RuntimeVisibleAnnotations:
java.lang.Deprecated()
private static volatile java.util.Map<java.util.UUID, org.apache.cassandra.utils.Pair<org.apache.cassandra.db.commitlog.CommitLogPosition, java.lang.Long>> truncationRecords;
descriptor: Ljava/util/Map;
flags: (0x004a) ACC_PRIVATE, ACC_STATIC, ACC_VOLATILE
Signature: Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/commitlog/CommitLogPosition;Ljava/lang/Long;>;>;
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=4, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/db/SystemKeyspace;
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.db.SystemKeyspace.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/db/SystemKeyspace;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
4: new org.apache.cassandra.utils.CassandraVersion
dup
ldc "0.0.0-unknown"
invokespecial org.apache.cassandra.utils.CassandraVersion.<init>:(Ljava/lang/String;)V
putstatic org.apache.cassandra.db.SystemKeyspace.UNREADABLE_VERSION:Lorg/apache/cassandra/utils/CassandraVersion;
5: new org.apache.cassandra.utils.CassandraVersion
dup
ldc "0.0.0-absent"
invokespecial org.apache.cassandra.utils.CassandraVersion.<init>:(Ljava/lang/String;)V
putstatic org.apache.cassandra.db.SystemKeyspace.NULL_VERSION:Lorg/apache/cassandra/utils/CassandraVersion;
6: ldc "batches"
7: ldc "batches awaiting replay"
8: ldc "CREATE TABLE %s (id timeuuid,mutations list<blob>,version int,PRIMARY KEY ((id)))"
9: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
10: new org.apache.cassandra.dht.LocalPartitioner
dup
getstatic org.apache.cassandra.db.marshal.TimeUUIDType.instance:Lorg/apache/cassandra/db/marshal/TimeUUIDType;
invokespecial org.apache.cassandra.dht.LocalPartitioner.<init>:(Lorg/apache/cassandra/db/marshal/AbstractType;)V
invokevirtual org.apache.cassandra.config.CFMetaData.copy:(Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/config/CFMetaData;
11: ldc "min_threshold"
ldc "2"
invokestatic java.util.Collections.singletonMap:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;
invokestatic org.apache.cassandra.schema.CompactionParams.scts:(Ljava/util/Map;)Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.config.CFMetaData.compaction:(Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/config/CFMetaData;
12: iconst_0
invokevirtual org.apache.cassandra.config.CFMetaData.gcGraceSeconds:(I)Lorg/apache/cassandra/config/CFMetaData;
13: putstatic org.apache.cassandra.db.SystemKeyspace.Batches:Lorg/apache/cassandra/config/CFMetaData;
14: ldc "paxos"
15: ldc "in-progress paxos proposals"
16: ldc "CREATE TABLE %s (row_key blob,cf_id UUID,in_progress_ballot timeuuid,most_recent_commit blob,most_recent_commit_at timeuuid,most_recent_commit_version int,proposal blob,proposal_ballot timeuuid,proposal_version int,PRIMARY KEY ((row_key), cf_id))"
17: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
18: invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
invokestatic org.apache.cassandra.schema.CompactionParams.lcs:(Ljava/util/Map;)Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.config.CFMetaData.compaction:(Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/config/CFMetaData;
19: putstatic org.apache.cassandra.db.SystemKeyspace.Paxos:Lorg/apache/cassandra/config/CFMetaData;
20: ldc "IndexInfo"
21: ldc "built column indexes"
22: ldc "CREATE TABLE \"%s\" (table_name text,index_name text,PRIMARY KEY ((table_name), index_name)) WITH COMPACT STORAGE"
23: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
24: putstatic org.apache.cassandra.db.SystemKeyspace.BuiltIndexes:Lorg/apache/cassandra/config/CFMetaData;
25: ldc "local"
26: ldc "information about the local node"
27: ldc "CREATE TABLE %s (key text,bootstrapped text,broadcast_address inet,cluster_name text,cql_version text,data_center text,gossip_generation int,host_id uuid,listen_address inet,native_protocol_version text,partitioner text,rack text,release_version text,rpc_address inet,schema_version uuid,thrift_version text,tokens set<varchar>,truncated_at map<uuid, blob>,PRIMARY KEY ((key)))"
28: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
29: putstatic org.apache.cassandra.db.SystemKeyspace.Local:Lorg/apache/cassandra/config/CFMetaData;
30: ldc "peers"
31: ldc "information about known peers in the cluster"
32: ldc "CREATE TABLE %s (peer inet,data_center text,host_id uuid,preferred_ip inet,rack text,release_version text,rpc_address inet,schema_version uuid,tokens set<varchar>,PRIMARY KEY ((peer)))"
33: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
34: putstatic org.apache.cassandra.db.SystemKeyspace.Peers:Lorg/apache/cassandra/config/CFMetaData;
35: ldc "peer_events"
36: ldc "events related to peers"
37: ldc "CREATE TABLE %s (peer inet,hints_dropped map<uuid, int>,PRIMARY KEY ((peer)))"
38: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
39: putstatic org.apache.cassandra.db.SystemKeyspace.PeerEvents:Lorg/apache/cassandra/config/CFMetaData;
40: ldc "range_xfers"
41: ldc "ranges requested for transfer"
42: ldc "CREATE TABLE %s (token_bytes blob,requested_at timestamp,PRIMARY KEY ((token_bytes)))"
43: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
44: putstatic org.apache.cassandra.db.SystemKeyspace.RangeXfers:Lorg/apache/cassandra/config/CFMetaData;
45: ldc "compaction_history"
46: ldc "week-long compaction history"
47: ldc "CREATE TABLE %s (id uuid,bytes_in bigint,bytes_out bigint,columnfamily_name text,compacted_at timestamp,keyspace_name text,rows_merged map<int, bigint>,PRIMARY KEY ((id)))"
48: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
49: getstatic java.util.concurrent.TimeUnit.DAYS:Ljava/util/concurrent/TimeUnit;
ldc 7
invokevirtual java.util.concurrent.TimeUnit.toSeconds:(J)J
l2i
invokevirtual org.apache.cassandra.config.CFMetaData.defaultTimeToLive:(I)Lorg/apache/cassandra/config/CFMetaData;
50: putstatic org.apache.cassandra.db.SystemKeyspace.CompactionHistory:Lorg/apache/cassandra/config/CFMetaData;
51: ldc "sstable_activity"
52: ldc "historic sstable read rates"
53: ldc "CREATE TABLE %s (keyspace_name text,columnfamily_name text,generation int,rate_120m double,rate_15m double,PRIMARY KEY ((keyspace_name, columnfamily_name, generation)))"
54: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
55: putstatic org.apache.cassandra.db.SystemKeyspace.SSTableActivity:Lorg/apache/cassandra/config/CFMetaData;
56: ldc "size_estimates"
57: ldc "per-table primary range size estimates"
58: ldc "CREATE TABLE %s (keyspace_name text,table_name text,range_start text,range_end text,mean_partition_size bigint,partitions_count bigint,PRIMARY KEY ((keyspace_name), table_name, range_start, range_end))"
59: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
60: iconst_0
invokevirtual org.apache.cassandra.config.CFMetaData.gcGraceSeconds:(I)Lorg/apache/cassandra/config/CFMetaData;
61: putstatic org.apache.cassandra.db.SystemKeyspace.SizeEstimates:Lorg/apache/cassandra/config/CFMetaData;
62: ldc "available_ranges"
63: ldc "available keyspace/ranges during bootstrap/replace that are ready to be served"
64: ldc "CREATE TABLE %s (keyspace_name text,ranges set<blob>,PRIMARY KEY ((keyspace_name)))"
65: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
66: putstatic org.apache.cassandra.db.SystemKeyspace.AvailableRanges:Lorg/apache/cassandra/config/CFMetaData;
67: ldc "transferred_ranges"
68: ldc "record of transferred ranges for streaming operation"
69: ldc "CREATE TABLE %s (operation text,peer inet,keyspace_name text,ranges set<blob>,PRIMARY KEY ((operation, keyspace_name), peer))"
70: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
71: putstatic org.apache.cassandra.db.SystemKeyspace.TransferredRanges:Lorg/apache/cassandra/config/CFMetaData;
72: ldc "views_builds_in_progress"
73: ldc "views builds current progress"
74: ldc "CREATE TABLE %s (keyspace_name text,view_name text,last_token varchar,generation_number int,PRIMARY KEY ((keyspace_name), view_name))"
75: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
76: putstatic org.apache.cassandra.db.SystemKeyspace.ViewsBuildsInProgress:Lorg/apache/cassandra/config/CFMetaData;
77: ldc "built_views"
78: ldc "built views"
79: ldc "CREATE TABLE %s (keyspace_name text,view_name text,status_replicated boolean,PRIMARY KEY ((keyspace_name), view_name))"
80: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
81: putstatic org.apache.cassandra.db.SystemKeyspace.BuiltViews:Lorg/apache/cassandra/config/CFMetaData;
82: ldc "prepared_statements"
83: ldc "prepared statements"
84: ldc "CREATE TABLE %s (prepared_id blob,logged_keyspace text,query_string text,PRIMARY KEY ((prepared_id)))"
85: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
86: putstatic org.apache.cassandra.db.SystemKeyspace.PreparedStatements:Lorg/apache/cassandra/config/CFMetaData;
87: ldc "hints"
88: ldc "*DEPRECATED* hints awaiting delivery"
89: ldc "CREATE TABLE %s (target_id uuid,hint_id timeuuid,message_version int,mutation blob,PRIMARY KEY ((target_id), hint_id, message_version)) WITH COMPACT STORAGE"
90: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
91: ldc "enabled"
ldc "false"
invokestatic java.util.Collections.singletonMap:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;
invokestatic org.apache.cassandra.schema.CompactionParams.scts:(Ljava/util/Map;)Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.config.CFMetaData.compaction:(Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/config/CFMetaData;
92: iconst_0
invokevirtual org.apache.cassandra.config.CFMetaData.gcGraceSeconds:(I)Lorg/apache/cassandra/config/CFMetaData;
93: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyHints:Lorg/apache/cassandra/config/CFMetaData;
94: ldc "batchlog"
95: ldc "*DEPRECATED* batchlog entries"
96: ldc "CREATE TABLE %s (id uuid,data blob,version int,written_at timestamp,PRIMARY KEY ((id)))"
97: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
98: ldc "min_threshold"
ldc "2"
invokestatic java.util.Collections.singletonMap:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;
invokestatic org.apache.cassandra.schema.CompactionParams.scts:(Ljava/util/Map;)Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.config.CFMetaData.compaction:(Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/config/CFMetaData;
99: iconst_0
invokevirtual org.apache.cassandra.config.CFMetaData.gcGraceSeconds:(I)Lorg/apache/cassandra/config/CFMetaData;
100: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyBatchlog:Lorg/apache/cassandra/config/CFMetaData;
101: ldc "schema_keyspaces"
102: ldc "*DEPRECATED* keyspace definitions"
103: ldc "CREATE TABLE %s (keyspace_name text,durable_writes boolean,strategy_class text,strategy_options text,PRIMARY KEY ((keyspace_name))) WITH COMPACT STORAGE"
104: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
105: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyKeyspaces:Lorg/apache/cassandra/config/CFMetaData;
106: ldc "schema_columnfamilies"
107: ldc "*DEPRECATED* table definitions"
108: ldc "CREATE TABLE %s (keyspace_name text,columnfamily_name text,bloom_filter_fp_chance double,caching text,cf_id uuid,comment text,compaction_strategy_class text,compaction_strategy_options text,comparator text,compression_parameters text,default_time_to_live int,default_validator text,dropped_columns map<text, bigint>,gc_grace_seconds int,is_dense boolean,key_validator text,local_read_repair_chance double,max_compaction_threshold int,max_index_interval int,memtable_flush_period_in_ms int,min_compaction_threshold int,min_index_interval int,read_repair_chance double,speculative_retry text,subcomparator text,type text,PRIMARY KEY ((keyspace_name), columnfamily_name))"
109: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
110: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyColumnfamilies:Lorg/apache/cassandra/config/CFMetaData;
111: ldc "schema_columns"
112: ldc "*DEPRECATED* column definitions"
113: ldc "CREATE TABLE %s (keyspace_name text,columnfamily_name text,column_name text,component_index int,index_name text,index_options text,index_type text,type text,validator text,PRIMARY KEY ((keyspace_name), columnfamily_name, column_name))"
114: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
115: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyColumns:Lorg/apache/cassandra/config/CFMetaData;
116: ldc "schema_triggers"
117: ldc "*DEPRECATED* trigger definitions"
118: ldc "CREATE TABLE %s (keyspace_name text,columnfamily_name text,trigger_name text,trigger_options map<text, text>,PRIMARY KEY ((keyspace_name), columnfamily_name, trigger_name))"
119: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
120: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyTriggers:Lorg/apache/cassandra/config/CFMetaData;
121: ldc "schema_usertypes"
122: ldc "*DEPRECATED* user defined type definitions"
123: ldc "CREATE TABLE %s (keyspace_name text,type_name text,field_names list<text>,field_types list<text>,PRIMARY KEY ((keyspace_name), type_name))"
124: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
125: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyUsertypes:Lorg/apache/cassandra/config/CFMetaData;
126: ldc "schema_functions"
127: ldc "*DEPRECATED* user defined function definitions"
128: ldc "CREATE TABLE %s (keyspace_name text,function_name text,signature frozen<list<text>>,argument_names list<text>,argument_types list<text>,body text,language text,return_type text,called_on_null_input boolean,PRIMARY KEY ((keyspace_name), function_name, signature))"
129: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
130: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyFunctions:Lorg/apache/cassandra/config/CFMetaData;
131: ldc "schema_aggregates"
132: ldc "*DEPRECATED* user defined aggregate definitions"
133: ldc "CREATE TABLE %s (keyspace_name text,aggregate_name text,signature frozen<list<text>>,argument_types list<text>,final_func text,initcond blob,return_type text,state_func text,state_type text,PRIMARY KEY ((keyspace_name), aggregate_name, signature))"
134: invokestatic org.apache.cassandra.db.SystemKeyspace.compile:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
135: putstatic org.apache.cassandra.db.SystemKeyspace.LegacyAggregates:Lorg/apache/cassandra/config/CFMetaData;
136: return
LocalVariableTable:
Start End Slot Name Signature
private void <init>();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/db/SystemKeyspace;
private static org.apache.cassandra.config.CFMetaData compile(java.lang.String, java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
ldc "system"
invokestatic org.apache.cassandra.config.CFMetaData.compile:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
1: aload 1
invokevirtual org.apache.cassandra.config.CFMetaData.comment:(Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
2: areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 name Ljava/lang/String;
0 3 1 description Ljava/lang/String;
0 3 2 schema Ljava/lang/String;
MethodParameters:
Name Flags
name
description
schema
public static org.apache.cassandra.schema.KeyspaceMetadata metadata();
descriptor: ()Lorg/apache/cassandra/schema/KeyspaceMetadata;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=0, args_size=0
0: ldc "system"
invokestatic org.apache.cassandra.schema.KeyspaceParams.local:()Lorg/apache/cassandra/schema/KeyspaceParams;
invokestatic org.apache.cassandra.db.SystemKeyspace.tables:()Lorg/apache/cassandra/schema/Tables;
invokestatic org.apache.cassandra.schema.Views.none:()Lorg/apache/cassandra/schema/Views;
invokestatic org.apache.cassandra.schema.Types.none:()Lorg/apache/cassandra/schema/Types;
invokestatic org.apache.cassandra.db.SystemKeyspace.functions:()Lorg/apache/cassandra/schema/Functions;
invokestatic org.apache.cassandra.schema.KeyspaceMetadata.create:(Ljava/lang/String;Lorg/apache/cassandra/schema/KeyspaceParams;Lorg/apache/cassandra/schema/Tables;Lorg/apache/cassandra/schema/Views;Lorg/apache/cassandra/schema/Types;Lorg/apache/cassandra/schema/Functions;)Lorg/apache/cassandra/schema/KeyspaceMetadata;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static org.apache.cassandra.schema.Tables tables();
descriptor: ()Lorg/apache/cassandra/schema/Tables;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=0, args_size=0
0: bipush 24
anewarray org.apache.cassandra.config.CFMetaData
dup
iconst_0
getstatic org.apache.cassandra.db.SystemKeyspace.BuiltIndexes:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
iconst_1
1: getstatic org.apache.cassandra.db.SystemKeyspace.Batches:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
iconst_2
2: getstatic org.apache.cassandra.db.SystemKeyspace.Paxos:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
iconst_3
3: getstatic org.apache.cassandra.db.SystemKeyspace.Local:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
iconst_4
4: getstatic org.apache.cassandra.db.SystemKeyspace.Peers:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
iconst_5
5: getstatic org.apache.cassandra.db.SystemKeyspace.PeerEvents:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 6
6: getstatic org.apache.cassandra.db.SystemKeyspace.RangeXfers:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 7
7: getstatic org.apache.cassandra.db.SystemKeyspace.CompactionHistory:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 8
8: getstatic org.apache.cassandra.db.SystemKeyspace.SSTableActivity:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 9
9: getstatic org.apache.cassandra.db.SystemKeyspace.SizeEstimates:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 10
10: getstatic org.apache.cassandra.db.SystemKeyspace.AvailableRanges:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 11
11: getstatic org.apache.cassandra.db.SystemKeyspace.TransferredRanges:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 12
12: getstatic org.apache.cassandra.db.SystemKeyspace.ViewsBuildsInProgress:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 13
13: getstatic org.apache.cassandra.db.SystemKeyspace.BuiltViews:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 14
14: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyHints:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 15
15: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyBatchlog:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 16
16: getstatic org.apache.cassandra.db.SystemKeyspace.PreparedStatements:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 17
17: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyKeyspaces:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 18
18: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyColumnfamilies:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 19
19: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyColumns:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 20
20: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyTriggers:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 21
21: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyUsertypes:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 22
22: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyFunctions:Lorg/apache/cassandra/config/CFMetaData;
aastore
dup
bipush 23
23: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyAggregates:Lorg/apache/cassandra/config/CFMetaData;
aastore
24: invokestatic org.apache.cassandra.schema.Tables.of:([Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/schema/Tables;
areturn
LocalVariableTable:
Start End Slot Name Signature
private static org.apache.cassandra.schema.Functions functions();
descriptor: ()Lorg/apache/cassandra/schema/Functions;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: invokestatic org.apache.cassandra.schema.Functions.builder:()Lorg/apache/cassandra/schema/Functions$Builder;
1: invokestatic org.apache.cassandra.cql3.functions.UuidFcts.all:()Ljava/util/Collection;
invokevirtual org.apache.cassandra.schema.Functions$Builder.add:(Ljava/lang/Iterable;)Lorg/apache/cassandra/schema/Functions$Builder;
2: invokestatic org.apache.cassandra.cql3.functions.TimeFcts.all:()Ljava/util/Collection;
invokevirtual org.apache.cassandra.schema.Functions$Builder.add:(Ljava/lang/Iterable;)Lorg/apache/cassandra/schema/Functions$Builder;
3: invokestatic org.apache.cassandra.cql3.functions.BytesConversionFcts.all:()Ljava/util/Collection;
invokevirtual org.apache.cassandra.schema.Functions$Builder.add:(Ljava/lang/Iterable;)Lorg/apache/cassandra/schema/Functions$Builder;
4: invokestatic org.apache.cassandra.cql3.functions.AggregateFcts.all:()Ljava/util/Collection;
invokevirtual org.apache.cassandra.schema.Functions$Builder.add:(Ljava/lang/Iterable;)Lorg/apache/cassandra/schema/Functions$Builder;
5: invokestatic org.apache.cassandra.cql3.functions.CastFcts.all:()Ljava/util/Collection;
invokevirtual org.apache.cassandra.schema.Functions$Builder.add:(Ljava/lang/Iterable;)Lorg/apache/cassandra/schema/Functions$Builder;
6: invokevirtual org.apache.cassandra.schema.Functions$Builder.build:()Lorg/apache/cassandra/schema/Functions;
7: areturn
LocalVariableTable:
Start End Slot Name Signature
public static void finishStartup();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=0, locals=0, args_size=0
0: invokestatic org.apache.cassandra.schema.SchemaKeyspace.saveSystemKeyspacesSchema:()V
1: return
LocalVariableTable:
Start End Slot Name Signature
public static void persistLocalMetadata();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=2, args_size=0
0: ldc "INSERT INTO system.%s (key,cluster_name,release_version,cql_version,thrift_version,native_protocol_version,data_center,rack,partitioner,rpc_address,broadcast_address,listen_address) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)"
astore 0
start local 0 1: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEndpointSnitch:()Lorg/apache/cassandra/locator/IEndpointSnitch;
astore 1
start local 1 2: aload 0
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
bipush 12
anewarray java.lang.Object
dup
iconst_0
3: ldc "local"
aastore
dup
iconst_1
4: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getClusterName:()Ljava/lang/String;
aastore
dup
iconst_2
5: invokestatic org.apache.cassandra.utils.FBUtilities.getReleaseVersionString:()Ljava/lang/String;
aastore
dup
iconst_3
6: getstatic org.apache.cassandra.cql3.QueryProcessor.CQL_VERSION:Lorg/apache/cassandra/utils/CassandraVersion;
invokevirtual org.apache.cassandra.utils.CassandraVersion.toString:()Ljava/lang/String;
aastore
dup
iconst_4
7: ldc "20.1.0"
aastore
dup
iconst_5
8: getstatic org.apache.cassandra.transport.ProtocolVersion.CURRENT:Lorg/apache/cassandra/transport/ProtocolVersion;
invokevirtual org.apache.cassandra.transport.ProtocolVersion.asInt:()I
invokestatic java.lang.String.valueOf:(I)Ljava/lang/String;
aastore
dup
bipush 6
9: aload 1
invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
aastore
dup
bipush 7
10: aload 1
invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getRack:(Ljava/net/InetAddress;)Ljava/lang/String;
aastore
dup
bipush 8
11: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
invokevirtual java.lang.Class.getName:()Ljava/lang/String;
aastore
dup
bipush 9
12: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getRpcAddress:()Ljava/net/InetAddress;
aastore
dup
bipush 10
13: invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
aastore
dup
bipush 11
14: invokestatic org.apache.cassandra.utils.FBUtilities.getLocalAddress:()Ljava/net/InetAddress;
aastore
15: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeOnceInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
16: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 17 0 req Ljava/lang/String;
2 17 1 snitch Lorg/apache/cassandra/locator/IEndpointSnitch;
public static void updateCompactionHistory(java.lang.String, java.lang.String, long, long, long, java.util.Map<java.lang.Integer, java.lang.Long>);
descriptor: (Ljava/lang/String;Ljava/lang/String;JJJLjava/util/Map;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=10, args_size=6
start local 0 start local 1 start local 2 start local 4 start local 6 start local 8 0: aload 0
ldc "system"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 2
aload 1
ldc "compaction_history"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
ldc "INSERT INTO system.%s (id, keyspace_name, columnfamily_name, compacted_at, bytes_in, bytes_out, rows_merged) VALUES (?, ?, ?, ?, ?, ?, ?)"
astore 9
start local 9 3: aload 9
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "compaction_history"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
bipush 7
anewarray java.lang.Object
dup
iconst_0
4: invokestatic org.apache.cassandra.utils.UUIDGen.getTimeUUID:()Ljava/util/UUID;
aastore
dup
iconst_1
5: aload 0
aastore
dup
iconst_2
6: aload 1
aastore
dup
iconst_3
7: lload 2
invokestatic org.apache.cassandra.utils.ByteBufferUtil.bytes:(J)Ljava/nio/ByteBuffer;
aastore
dup
iconst_4
8: lload 4
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_5
9: lload 6
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
bipush 6
10: aload 8
aastore
11: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
12: return
end local 9 end local 8 end local 6 end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 ksname Ljava/lang/String;
0 13 1 cfname Ljava/lang/String;
0 13 2 compactedAt J
0 13 4 bytesIn J
0 13 6 bytesOut J
0 13 8 rowsMerged Ljava/util/Map<Ljava/lang/Integer;Ljava/lang/Long;>;
3 13 9 req Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/lang/String;JJJLjava/util/Map<Ljava/lang/Integer;Ljava/lang/Long;>;)V
MethodParameters:
Name Flags
ksname
cfname
compactedAt
bytesIn
bytesOut
rowsMerged
public static javax.management.openmbean.TabularData getCompactionHistory();
descriptor: ()Ljavax/management/openmbean/TabularData;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=1, args_size=0
0: ldc "SELECT * from system.%s"
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "compaction_history"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 0
start local 0 1: aload 0
invokestatic org.apache.cassandra.db.compaction.CompactionHistoryTabularData.from:(Lorg/apache/cassandra/cql3/UntypedResultSet;)Ljavax/management/openmbean/TabularData;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 2 0 queryResultSet Lorg/apache/cassandra/cql3/UntypedResultSet;
Exceptions:
throws javax.management.openmbean.OpenDataException
public static boolean isViewBuilt(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: ldc "SELECT view_name FROM %s.\"%s\" WHERE keyspace_name=? AND view_name=?"
astore 2
start local 2 1: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "built_views"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 3
start local 3 2: aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifeq 3
iconst_0
goto 4
StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
3: iconst_1
StackMap locals:
StackMap stack: int
4: ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 keyspaceName Ljava/lang/String;
0 5 1 viewName Ljava/lang/String;
1 5 2 req Ljava/lang/String;
2 5 3 result Lorg/apache/cassandra/cql3/UntypedResultSet;
MethodParameters:
Name Flags
keyspaceName
viewName
public static boolean isViewStatusReplicated(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: ldc "SELECT status_replicated FROM %s.\"%s\" WHERE keyspace_name=? AND view_name=?"
astore 2
start local 2 1: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "built_views"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 3
start local 3 2: aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifeq 4
3: iconst_0
ireturn
4: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 4
start local 4 5: aload 4
ldc "status_replicated"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 6
aload 4
ldc "status_replicated"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getBoolean:(Ljava/lang/String;)Z
ifeq 6
iconst_1
ireturn
StackMap locals: org.apache.cassandra.cql3.UntypedResultSet$Row
StackMap stack:
6: iconst_0
ireturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 keyspaceName Ljava/lang/String;
0 7 1 viewName Ljava/lang/String;
1 7 2 req Ljava/lang/String;
2 7 3 result Lorg/apache/cassandra/cql3/UntypedResultSet;
5 7 4 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
MethodParameters:
Name Flags
keyspaceName
viewName
public static void setViewBuilt(java.lang.String, java.lang.String, boolean);
descriptor: (Ljava/lang/String;Ljava/lang/String;Z)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: ldc "INSERT INTO %s.\"%s\" (keyspace_name, view_name, status_replicated) VALUES (?, ?, ?)"
astore 3
start local 3 1: aload 3
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "built_views"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
iload 2
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: ldc "built_views"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
3: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 keyspaceName Ljava/lang/String;
0 4 1 viewName Ljava/lang/String;
0 4 2 replicated Z
1 4 3 req Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
viewName
replicated
public static void setViewRemoved(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: ldc "DELETE FROM %S.%s WHERE keyspace_name = ? AND view_name = ?"
astore 2
start local 2 1: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "views_builds_in_progress"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: ldc "views_builds_in_progress"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
3: ldc "DELETE FROM %s.\"%s\" WHERE keyspace_name = ? AND view_name = ?"
astore 3
start local 3 4: aload 3
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "built_views"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
5: ldc "built_views"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
6: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 keyspaceName Ljava/lang/String;
0 7 1 viewName Ljava/lang/String;
1 7 2 buildReq Ljava/lang/String;
4 7 3 builtReq Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
viewName
public static void beginViewBuild(java.lang.String, java.lang.String, int);
descriptor: (Ljava/lang/String;Ljava/lang/String;I)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: ldc "INSERT INTO system.%s (keyspace_name, view_name, generation_number) VALUES (?, ?, ?)"
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "views_builds_in_progress"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_3
anewarray java.lang.Object
dup
iconst_0
1: aload 0
aastore
dup
iconst_1
2: aload 1
aastore
dup
iconst_2
3: iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
4: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
5: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 ksname Ljava/lang/String;
0 6 1 viewName Ljava/lang/String;
0 6 2 generationNumber I
MethodParameters:
Name Flags
ksname
viewName
generationNumber
public static void finishViewBuildStatus(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_0
invokestatic org.apache.cassandra.db.SystemKeyspace.setViewBuilt:(Ljava/lang/String;Ljava/lang/String;Z)V
1: ldc "DELETE FROM system.%s WHERE keyspace_name = ? AND view_name = ?"
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "views_builds_in_progress"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: ldc "views_builds_in_progress"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 ksname Ljava/lang/String;
0 4 1 viewName Ljava/lang/String;
MethodParameters:
Name Flags
ksname
viewName
public static void setViewBuiltReplicated(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
iconst_1
invokestatic org.apache.cassandra.db.SystemKeyspace.setViewBuilt:(Ljava/lang/String;Ljava/lang/String;Z)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 ksname Ljava/lang/String;
0 2 1 viewName Ljava/lang/String;
MethodParameters:
Name Flags
ksname
viewName
public static void updateViewBuildStatus(java.lang.String, java.lang.String, org.apache.cassandra.dht.Token);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/dht/Token;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=3
start local 0 start local 1 start local 2 0: ldc "INSERT INTO system.%s (keyspace_name, view_name, last_token) VALUES (?, ?, ?)"
astore 3
start local 3 1: getstatic org.apache.cassandra.db.SystemKeyspace.ViewsBuildsInProgress:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.partitioner:Lorg/apache/cassandra/dht/IPartitioner;
invokeinterface org.apache.cassandra.dht.IPartitioner.getTokenFactory:()Lorg/apache/cassandra/dht/Token$TokenFactory;
astore 4
start local 4 2: aload 3
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "views_builds_in_progress"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 4
aload 2
invokevirtual org.apache.cassandra.dht.Token$TokenFactory.toString:(Lorg/apache/cassandra/dht/Token;)Ljava/lang/String;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
3: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 ksname Ljava/lang/String;
0 4 1 viewName Ljava/lang/String;
0 4 2 token Lorg/apache/cassandra/dht/Token;
1 4 3 req Ljava/lang/String;
2 4 4 factory Lorg/apache/cassandra/dht/Token$TokenFactory;
MethodParameters:
Name Flags
ksname
viewName
token
public static org.apache.cassandra.utils.Pair<java.lang.Integer, org.apache.cassandra.dht.Token> getViewBuildStatus(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/utils/Pair;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=8, args_size=2
start local 0 start local 1 0: ldc "SELECT generation_number, last_token FROM system.%s WHERE keyspace_name = ? AND view_name = ?"
astore 2
start local 2 1: aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "views_builds_in_progress"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 3
start local 3 2: aload 3
ifnull 3
aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifeq 4
3: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aconst_null
areturn
4: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 4
start local 4 5: aconst_null
astore 5
start local 5 6: aconst_null
astore 6
start local 6 7: aload 4
ldc "generation_number"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 9
8: aload 4
ldc "generation_number"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
astore 5
9: StackMap locals: org.apache.cassandra.cql3.UntypedResultSet$Row java.lang.Integer org.apache.cassandra.dht.Token
StackMap stack:
aload 4
ldc "last_key"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 12
10: getstatic org.apache.cassandra.db.SystemKeyspace.ViewsBuildsInProgress:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.partitioner:Lorg/apache/cassandra/dht/IPartitioner;
invokeinterface org.apache.cassandra.dht.IPartitioner.getTokenFactory:()Lorg/apache/cassandra/dht/Token$TokenFactory;
astore 7
start local 7 11: aload 7
aload 4
ldc "last_key"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual org.apache.cassandra.dht.Token$TokenFactory.fromString:(Ljava/lang/String;)Lorg/apache/cassandra/dht/Token;
astore 6
end local 7 12: StackMap locals:
StackMap stack:
aload 5
aload 6
invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
areturn
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 13 0 ksname Ljava/lang/String;
0 13 1 viewName Ljava/lang/String;
1 13 2 req Ljava/lang/String;
2 13 3 queryResultSet Lorg/apache/cassandra/cql3/UntypedResultSet;
5 13 4 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
6 13 5 generation Ljava/lang/Integer;
7 13 6 lastKey Lorg/apache/cassandra/dht/Token;
11 12 7 factory Lorg/apache/cassandra/dht/Token$TokenFactory;
Signature: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/utils/Pair<Ljava/lang/Integer;Lorg/apache/cassandra/dht/Token;>;
MethodParameters:
Name Flags
ksname
viewName
public static synchronized void saveTruncationRecord(org.apache.cassandra.db.ColumnFamilyStore, long, org.apache.cassandra.db.commitlog.CommitLogPosition);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;JLorg/apache/cassandra/db/commitlog/CommitLogPosition;)V
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=8, locals=5, args_size=3
start local 0 start local 1 start local 3 0: ldc "UPDATE system.%s SET truncated_at = truncated_at + ? WHERE key = '%s'"
astore 4
start local 4 1: aload 4
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
lload 1
aload 3
invokestatic org.apache.cassandra.db.SystemKeyspace.truncationAsMapEntry:(Lorg/apache/cassandra/db/ColumnFamilyStore;JLorg/apache/cassandra/db/commitlog/CommitLogPosition;)Ljava/util/Map;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: aconst_null
putstatic org.apache.cassandra.db.SystemKeyspace.truncationRecords:Ljava/util/Map;
3: ldc "local"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
4: return
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 5 1 truncatedAt J
0 5 3 position Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
1 5 4 req Ljava/lang/String;
MethodParameters:
Name Flags
cfs
truncatedAt
position
public static synchronized void removeTruncationRecord(java.util.UUID);
descriptor: (Ljava/util/UUID;)V
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=2, args_size=1
start local 0 0: ldc "DELETE truncated_at[?] from system.%s WHERE key = '%s'"
astore 1
start local 1 1: aload 1
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: aconst_null
putstatic org.apache.cassandra.db.SystemKeyspace.truncationRecords:Ljava/util/Map;
3: ldc "local"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 cfId Ljava/util/UUID;
1 5 1 req Ljava/lang/String;
MethodParameters:
Name Flags
cfId
private static java.util.Map<java.util.UUID, java.nio.ByteBuffer> truncationAsMapEntry(org.apache.cassandra.db.ColumnFamilyStore, long, org.apache.cassandra.db.commitlog.CommitLogPosition);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;JLorg/apache/cassandra/db/commitlog/CommitLogPosition;)Ljava/util/Map;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=7, args_size=3
start local 0 start local 1 start local 3 0: aconst_null
astore 4
aconst_null
astore 5
1: getstatic org.apache.cassandra.io.util.DataOutputBuffer.scratchBuffer:Lio/netty/util/concurrent/FastThreadLocal;
invokevirtual io.netty.util.concurrent.FastThreadLocal.get:()Ljava/lang/Object;
checkcast org.apache.cassandra.io.util.DataOutputBuffer
astore 6
start local 6 2: getstatic org.apache.cassandra.db.commitlog.CommitLogPosition.serializer:Lorg/apache/cassandra/db/commitlog/CommitLogPosition$CommitLogPositionSerializer;
aload 3
aload 6
invokevirtual org.apache.cassandra.db.commitlog.CommitLogPosition$CommitLogPositionSerializer.serialize:(Lorg/apache/cassandra/db/commitlog/CommitLogPosition;Lorg/apache/cassandra/io/util/DataOutputPlus;)V
3: aload 6
lload 1
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.writeLong:(J)V
4: aload 0
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.asNewBuffer:()Ljava/nio/ByteBuffer;
invokestatic java.util.Collections.singletonMap:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/util/Map;
5: aload 6
ifnull 6
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.close:()V
6: StackMap locals: org.apache.cassandra.db.ColumnFamilyStore long org.apache.cassandra.db.commitlog.CommitLogPosition java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.DataOutputBuffer
StackMap stack: java.util.Map
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
7: astore 4
8: aload 6
ifnull 9
aload 6
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.close:()V
end local 6 StackMap locals:
StackMap stack:
9: aload 4
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
10: astore 5
aload 4
ifnonnull 11
aload 5
astore 4
goto 12
StackMap locals:
StackMap stack:
11: aload 4
aload 5
if_acmpeq 12
aload 4
aload 5
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
12: aload 4
athrow
13: StackMap locals: org.apache.cassandra.db.ColumnFamilyStore long org.apache.cassandra.db.commitlog.CommitLogPosition
StackMap stack: java.io.IOException
astore 4
start local 4 14: new java.lang.RuntimeException
dup
aload 4
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
0 15 1 truncatedAt J
0 15 3 position Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
2 9 6 out Lorg/apache/cassandra/io/util/DataOutputBuffer;
14 15 4 e Ljava/io/IOException;
Exception table:
from to target type
2 5 7 any
1 6 10 any
7 10 10 any
0 6 13 Class java.io.IOException
7 13 13 Class java.io.IOException
Signature: (Lorg/apache/cassandra/db/ColumnFamilyStore;JLorg/apache/cassandra/db/commitlog/CommitLogPosition;)Ljava/util/Map<Ljava/util/UUID;Ljava/nio/ByteBuffer;>;
MethodParameters:
Name Flags
cfs
truncatedAt
position
public static org.apache.cassandra.db.commitlog.CommitLogPosition getTruncatedPosition(java.util.UUID);
descriptor: (Ljava/util/UUID;)Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=2, args_size=1
start local 0 0: aload 0
invokestatic org.apache.cassandra.db.SystemKeyspace.getTruncationRecord:(Ljava/util/UUID;)Lorg/apache/cassandra/utils/Pair;
astore 1
start local 1 1: aload 1
ifnonnull 2
aconst_null
goto 3
StackMap locals: org.apache.cassandra.utils.Pair
StackMap stack:
2: aload 1
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
checkcast org.apache.cassandra.db.commitlog.CommitLogPosition
StackMap locals:
StackMap stack: org.apache.cassandra.db.commitlog.CommitLogPosition
3: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 cfId Ljava/util/UUID;
1 4 1 record Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/commitlog/CommitLogPosition;Ljava/lang/Long;>;
MethodParameters:
Name Flags
cfId
public static long getTruncatedAt(java.util.UUID);
descriptor: (Ljava/util/UUID;)J
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
invokestatic org.apache.cassandra.db.SystemKeyspace.getTruncationRecord:(Ljava/util/UUID;)Lorg/apache/cassandra/utils/Pair;
astore 1
start local 1 1: aload 1
ifnonnull 2
ldc -9223372036854775808
goto 3
StackMap locals: org.apache.cassandra.utils.Pair
StackMap stack:
2: aload 1
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
checkcast java.lang.Long
invokevirtual java.lang.Long.longValue:()J
StackMap locals:
StackMap stack: long
3: lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 cfId Ljava/util/UUID;
1 4 1 record Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/commitlog/CommitLogPosition;Ljava/lang/Long;>;
MethodParameters:
Name Flags
cfId
private static synchronized org.apache.cassandra.utils.Pair<org.apache.cassandra.db.commitlog.CommitLogPosition, java.lang.Long> getTruncationRecord(java.util.UUID);
descriptor: (Ljava/util/UUID;)Lorg/apache/cassandra/utils/Pair;
flags: (0x002a) ACC_PRIVATE, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.SystemKeyspace.truncationRecords:Ljava/util/Map;
ifnonnull 2
1: invokestatic org.apache.cassandra.db.SystemKeyspace.readTruncationRecords:()Ljava/util/Map;
putstatic org.apache.cassandra.db.SystemKeyspace.truncationRecords:Ljava/util/Map;
2: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.SystemKeyspace.truncationRecords:Ljava/util/Map;
aload 0
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.utils.Pair
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 cfId Ljava/util/UUID;
Signature: (Ljava/util/UUID;)Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/commitlog/CommitLogPosition;Ljava/lang/Long;>;
MethodParameters:
Name Flags
cfId
private static java.util.Map<java.util.UUID, org.apache.cassandra.utils.Pair<org.apache.cassandra.db.commitlog.CommitLogPosition, java.lang.Long>> readTruncationRecords();
descriptor: ()Ljava/util/Map;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=5, args_size=0
0: ldc "SELECT truncated_at FROM system.%s WHERE key = '%s'"
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 0
start local 0 1: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 1
start local 1 2: aload 0
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 8
aload 0
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "truncated_at"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 8
3: aload 0
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "truncated_at"
getstatic org.apache.cassandra.db.marshal.UUIDType.instance:Lorg/apache/cassandra/db/marshal/UUIDType;
getstatic org.apache.cassandra.db.marshal.BytesType.instance:Lorg/apache/cassandra/db/marshal/BytesType;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getMap:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/Map;
astore 2
start local 2 4: aload 2
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 4
goto 7
StackMap locals: org.apache.cassandra.cql3.UntypedResultSet java.util.Map java.util.Map top java.util.Iterator
StackMap stack:
5: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 3
start local 3 6: aload 1
aload 3
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.util.UUID
aload 3
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
invokestatic org.apache.cassandra.db.SystemKeyspace.truncationRecordFromBlob:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/utils/Pair;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 3 7: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
end local 2 8: StackMap locals: org.apache.cassandra.cql3.UntypedResultSet java.util.Map
StackMap stack:
aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 9 0 rows Lorg/apache/cassandra/cql3/UntypedResultSet;
2 9 1 records Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/commitlog/CommitLogPosition;Ljava/lang/Long;>;>;
4 8 2 map Ljava/util/Map<Ljava/util/UUID;Ljava/nio/ByteBuffer;>;
6 7 3 entry Ljava/util/Map$Entry<Ljava/util/UUID;Ljava/nio/ByteBuffer;>;
Signature: ()Ljava/util/Map<Ljava/util/UUID;Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/commitlog/CommitLogPosition;Ljava/lang/Long;>;>;
private static org.apache.cassandra.utils.Pair<org.apache.cassandra.db.commitlog.CommitLogPosition, java.lang.Long> truncationRecordFromBlob(java.nio.ByteBuffer);
descriptor: (Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/utils/Pair;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=4, args_size=1
start local 0 0: aconst_null
astore 1
aconst_null
astore 2
1: new org.apache.cassandra.io.util.DataInputBuffer
dup
aload 0
iconst_1
invokespecial org.apache.cassandra.io.util.DataInputBuffer.<init>:(Ljava/nio/ByteBuffer;Z)V
astore 3
start local 3 2: getstatic org.apache.cassandra.db.commitlog.CommitLogPosition.serializer:Lorg/apache/cassandra/db/commitlog/CommitLogPosition$CommitLogPositionSerializer;
aload 3
invokevirtual org.apache.cassandra.db.commitlog.CommitLogPosition$CommitLogPositionSerializer.deserialize:(Lorg/apache/cassandra/io/util/DataInputPlus;)Lorg/apache/cassandra/db/commitlog/CommitLogPosition;
aload 3
invokevirtual org.apache.cassandra.io.util.RebufferingInputStream.available:()I
ifle 3
aload 3
invokevirtual org.apache.cassandra.io.util.RebufferingInputStream.readLong:()J
goto 4
StackMap locals: java.nio.ByteBuffer java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RebufferingInputStream
StackMap stack: org.apache.cassandra.db.commitlog.CommitLogPosition
3: ldc -9223372036854775808
StackMap locals: java.nio.ByteBuffer java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.RebufferingInputStream
StackMap stack: org.apache.cassandra.db.commitlog.CommitLogPosition long
4: invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
5: aload 3
ifnull 6
aload 3
invokevirtual org.apache.cassandra.io.util.RebufferingInputStream.close:()V
6: StackMap locals:
StackMap stack: org.apache.cassandra.utils.Pair
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
7: astore 1
8: aload 3
ifnull 9
aload 3
invokevirtual org.apache.cassandra.io.util.RebufferingInputStream.close:()V
end local 3 StackMap locals:
StackMap stack:
9: aload 1
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
10: astore 2
aload 1
ifnonnull 11
aload 2
astore 1
goto 12
StackMap locals:
StackMap stack:
11: aload 1
aload 2
if_acmpeq 12
aload 1
aload 2
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
12: aload 1
athrow
13: StackMap locals: java.nio.ByteBuffer
StackMap stack: java.io.IOException
astore 1
start local 1 14: new java.lang.RuntimeException
dup
aload 1
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 15 0 bytes Ljava/nio/ByteBuffer;
2 9 3 in Lorg/apache/cassandra/io/util/RebufferingInputStream;
14 15 1 e Ljava/io/IOException;
Exception table:
from to target type
2 5 7 any
1 6 10 any
7 10 10 any
0 6 13 Class java.io.IOException
7 13 13 Class java.io.IOException
Signature: (Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/utils/Pair<Lorg/apache/cassandra/db/commitlog/CommitLogPosition;Ljava/lang/Long;>;
MethodParameters:
Name Flags
bytes
public static java.util.concurrent.Future<?> updateTokens(java.net.InetAddress, java.util.Collection<org.apache.cassandra.dht.Token>, java.util.concurrent.ExecutorService);
descriptor: (Ljava/net/InetAddress;Ljava/util/Collection;Ljava/util/concurrent/ExecutorService;)Ljava/util/concurrent/Future;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
ifeq 2
1: aconst_null
invokestatic com.google.common.util.concurrent.Futures.immediateFuture:(Ljava/lang/Object;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
2: StackMap locals:
StackMap stack:
ldc "INSERT INTO system.%s (peer, tokens) VALUES (?, ?)"
astore 3
start local 3 3: aload 2
aload 3
aload 0
aload 1
invokedynamic run(Ljava/lang/String;Ljava/net/InetAddress;Ljava/util/Collection;)Ljava/lang/Runnable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
org/apache/cassandra/db/SystemKeyspace.lambda$0(Ljava/lang/String;Ljava/net/InetAddress;Ljava/util/Collection;)V (6)
()V
invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 ep Ljava/net/InetAddress;
0 4 1 tokens Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
0 4 2 executorService Ljava/util/concurrent/ExecutorService;
3 4 3 req Ljava/lang/String;
Signature: (Ljava/net/InetAddress;Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;Ljava/util/concurrent/ExecutorService;)Ljava/util/concurrent/Future<*>;
MethodParameters:
Name Flags
ep final
tokens final
executorService
public static void updatePreferredIP(java.net.InetAddress, java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;Ljava/net/InetAddress;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: ldc "INSERT INTO system.%s (peer, preferred_ip) VALUES (?, ?)"
astore 2
start local 2 1: aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "peers"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: ldc "peers"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 ep Ljava/net/InetAddress;
0 4 1 preferred_ip Ljava/net/InetAddress;
1 4 2 req Ljava/lang/String;
MethodParameters:
Name Flags
ep
preferred_ip
public static java.util.concurrent.Future<?> updatePeerInfo(java.net.InetAddress, java.lang.String, , java.util.concurrent.ExecutorService);
descriptor: (Ljava/net/InetAddress;Ljava/lang/String;Ljava/lang/Object;Ljava/util/concurrent/ExecutorService;)Ljava/util/concurrent/Future;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
ifeq 2
1: aconst_null
invokestatic com.google.common.util.concurrent.Futures.immediateFuture:(Ljava/lang/Object;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
2: StackMap locals:
StackMap stack:
ldc "INSERT INTO system.%s (peer, %s) VALUES (?, ?)"
astore 4
start local 4 3: aload 3
aload 4
aload 1
aload 0
aload 2
invokedynamic run(Ljava/lang/String;Ljava/lang/String;Ljava/net/InetAddress;Ljava/lang/Object;)Ljava/lang/Runnable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
org/apache/cassandra/db/SystemKeyspace.lambda$1(Ljava/lang/String;Ljava/lang/String;Ljava/net/InetAddress;Ljava/lang/Object;)V (6)
()V
invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 ep Ljava/net/InetAddress;
0 4 1 columnName Ljava/lang/String;
0 4 2 value Ljava/lang/Object;
0 4 3 executorService Ljava/util/concurrent/ExecutorService;
3 4 4 req Ljava/lang/String;
Signature: (Ljava/net/InetAddress;Ljava/lang/String;Ljava/lang/Object;Ljava/util/concurrent/ExecutorService;)Ljava/util/concurrent/Future<*>;
MethodParameters:
Name Flags
ep final
columnName final
value final
executorService
public static void updatePeerReleaseVersion(java.net.InetAddress, java.lang.Object, java.lang.Runnable, java.util.concurrent.ExecutorService);
descriptor: (Ljava/net/InetAddress;Ljava/lang/Object;Ljava/lang/Runnable;Ljava/util/concurrent/ExecutorService;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
ldc "INSERT INTO system.%s (peer, release_version) VALUES (?, ?)"
astore 4
start local 4 3: aload 3
aload 4
aload 0
aload 1
aload 2
invokedynamic run(Ljava/lang/String;Ljava/net/InetAddress;Ljava/lang/Object;Ljava/lang/Runnable;)Ljava/lang/Runnable;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
()V
org/apache/cassandra/db/SystemKeyspace.lambda$2(Ljava/lang/String;Ljava/net/InetAddress;Ljava/lang/Object;Ljava/lang/Runnable;)V (6)
()V
invokeinterface java.util.concurrent.ExecutorService.execute:(Ljava/lang/Runnable;)V
4: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 ep Ljava/net/InetAddress;
0 5 1 value Ljava/lang/Object;
0 5 2 postUpdateTask Ljava/lang/Runnable;
0 5 3 executorService Ljava/util/concurrent/ExecutorService;
3 5 4 req Ljava/lang/String;
MethodParameters:
Name Flags
ep final
value final
postUpdateTask
executorService
public static synchronized void updateHintsDropped(java.net.InetAddress, java.util.UUID, int);
descriptor: (Ljava/net/InetAddress;Ljava/util/UUID;I)V
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: ldc "UPDATE system.%s USING TTL 2592000 SET hints_dropped[ ? ] = ? WHERE peer = ?"
astore 3
start local 3 1: aload 3
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "peer_events"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 ep Ljava/net/InetAddress;
0 3 1 timePeriod Ljava/util/UUID;
0 3 2 value I
1 3 3 req Ljava/lang/String;
MethodParameters:
Name Flags
ep
timePeriod
value
public static synchronized void updateSchemaVersion(java.util.UUID);
descriptor: (Ljava/util/UUID;)V
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=2, args_size=1
start local 0 0: ldc "INSERT INTO system.%s (key, schema_version) VALUES ('%s', ?)"
astore 1
start local 1 1: aload 1
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 version Ljava/util/UUID;
1 3 1 req Ljava/lang/String;
MethodParameters:
Name Flags
version
private static java.util.Set<java.lang.String> tokensAsSet(java.util.Collection<org.apache.cassandra.dht.Token>);
descriptor: (Ljava/util/Collection;)Ljava/util/Set;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=5, args_size=1
start local 0 0: aload 0
invokeinterface java.util.Collection.isEmpty:()Z
ifeq 2
1: invokestatic java.util.Collections.emptySet:()Ljava/util/Set;
areturn
2: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
invokevirtual org.apache.cassandra.service.StorageService.getTokenFactory:()Lorg/apache/cassandra/dht/Token$TokenFactory;
astore 1
start local 1 3: new java.util.HashSet
dup
aload 0
invokeinterface java.util.Collection.size:()I
invokespecial java.util.HashSet.<init>:(I)V
astore 2
start local 2 4: aload 0
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 7
StackMap locals: java.util.Collection org.apache.cassandra.dht.Token$TokenFactory java.util.Set top java.util.Iterator
StackMap stack:
5: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Token
astore 3
start local 3 6: aload 2
aload 1
aload 3
invokevirtual org.apache.cassandra.dht.Token$TokenFactory.toString:(Lorg/apache/cassandra/dht/Token;)Ljava/lang/String;
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 3 7: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 5
8: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 tokens Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
3 9 1 factory Lorg/apache/cassandra/dht/Token$TokenFactory;
4 9 2 s Ljava/util/Set<Ljava/lang/String;>;
6 7 3 tk Lorg/apache/cassandra/dht/Token;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;)Ljava/util/Set<Ljava/lang/String;>;
MethodParameters:
Name Flags
tokens
private static java.util.Collection<org.apache.cassandra.dht.Token> deserializeTokens(java.util.Collection<java.lang.String>);
descriptor: (Ljava/util/Collection;)Ljava/util/Collection;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=5, args_size=1
start local 0 0: getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
invokevirtual org.apache.cassandra.service.StorageService.getTokenFactory:()Lorg/apache/cassandra/dht/Token$TokenFactory;
astore 1
start local 1 1: new java.util.ArrayList
dup
aload 0
invokeinterface java.util.Collection.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 2
start local 2 2: aload 0
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 5
StackMap locals: java.util.Collection org.apache.cassandra.dht.Token$TokenFactory java.util.List top java.util.Iterator
StackMap stack:
3: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 3
start local 3 4: aload 2
aload 1
aload 3
invokevirtual org.apache.cassandra.dht.Token$TokenFactory.fromString:(Ljava/lang/String;)Lorg/apache/cassandra/dht/Token;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 3 5: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 tokensStrings Ljava/util/Collection<Ljava/lang/String;>;
1 7 1 factory Lorg/apache/cassandra/dht/Token$TokenFactory;
2 7 2 tokens Ljava/util/List<Lorg/apache/cassandra/dht/Token;>;
4 5 3 tk Ljava/lang/String;
Signature: (Ljava/util/Collection<Ljava/lang/String;>;)Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
MethodParameters:
Name Flags
tokensStrings
public static void removeEndpoint(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: ldc "DELETE FROM system.%s WHERE peer = ?"
astore 1
start local 1 1: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "peers"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: ldc "peers"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 ep Ljava/net/InetAddress;
1 4 1 req Ljava/lang/String;
MethodParameters:
Name Flags
ep
public static synchronized void updateTokens(java.util.Collection<org.apache.cassandra.dht.Token>);
descriptor: (Ljava/util/Collection;)V
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=2, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.SystemKeyspace.$assertionsDisabled:Z
ifne 1
aload 0
invokeinterface java.util.Collection.isEmpty:()Z
ifeq 1
new java.lang.AssertionError
dup
ldc "removeEndpoint should be used instead"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
1: StackMap locals:
StackMap stack:
ldc "INSERT INTO system.%s (key, tokens) VALUES ('%s', ?)"
astore 1
start local 1 2: aload 1
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
invokestatic org.apache.cassandra.db.SystemKeyspace.tokensAsSet:(Ljava/util/Collection;)Ljava/util/Set;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
3: ldc "local"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 tokens Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
2 5 1 req Ljava/lang/String;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;)V
MethodParameters:
Name Flags
tokens
public static void forceBlockingFlush(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.isUnsafeSystem:()Z
ifne 2
1: ldc "system"
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
aload 0
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceFlush:()Lcom/google/common/util/concurrent/ListenableFuture;
invokestatic org.apache.cassandra.utils.FBUtilities.waitOnFuture:(Ljava/util/concurrent/Future;)Ljava/lang/Object;
pop
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 cfname Ljava/lang/String;
MethodParameters:
Name Flags
cfname
public static com.google.common.collect.SetMultimap<java.net.InetAddress, org.apache.cassandra.dht.Token> loadTokens();
descriptor: ()Lcom/google/common/collect/SetMultimap;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=0
0: invokestatic com.google.common.collect.HashMultimap.create:()Lcom/google/common/collect/HashMultimap;
astore 0
start local 0 1: ldc "SELECT peer, tokens FROM system.peers"
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 2
goto 6
StackMap locals: com.google.common.collect.SetMultimap top java.util.Iterator
StackMap stack:
2: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 1
start local 1 3: aload 1
ldc "peer"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInetAddress:(Ljava/lang/String;)Ljava/net/InetAddress;
astore 3
start local 3 4: aload 1
ldc "tokens"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 6
5: aload 0
aload 3
aload 1
ldc "tokens"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getSet:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/Set;
invokestatic org.apache.cassandra.db.SystemKeyspace.deserializeTokens:(Ljava/util/Collection;)Ljava/util/Collection;
invokeinterface com.google.common.collect.SetMultimap.putAll:(Ljava/lang/Object;Ljava/lang/Iterable;)Z
pop
end local 3 end local 1 6: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
7: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 8 0 tokenMap Lcom/google/common/collect/SetMultimap<Ljava/net/InetAddress;Lorg/apache/cassandra/dht/Token;>;
3 6 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
4 6 3 peer Ljava/net/InetAddress;
Signature: ()Lcom/google/common/collect/SetMultimap<Ljava/net/InetAddress;Lorg/apache/cassandra/dht/Token;>;
public static java.util.Map<java.net.InetAddress, java.util.UUID> loadHostIds();
descriptor: ()Ljava/util/Map;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=0
0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 0
start local 0 1: ldc "SELECT peer, host_id FROM system.peers"
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 2
goto 6
StackMap locals: java.util.Map top java.util.Iterator
StackMap stack:
2: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 1
start local 1 3: aload 1
ldc "peer"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInetAddress:(Ljava/lang/String;)Ljava/net/InetAddress;
astore 3
start local 3 4: aload 1
ldc "host_id"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 6
5: aload 0
aload 3
aload 1
ldc "host_id"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 3 end local 1 6: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
7: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 8 0 hostIdMap Ljava/util/Map<Ljava/net/InetAddress;Ljava/util/UUID;>;
3 6 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
4 6 3 peer Ljava/net/InetAddress;
Signature: ()Ljava/util/Map<Ljava/net/InetAddress;Ljava/util/UUID;>;
public static java.util.Map<java.net.InetAddress, org.apache.cassandra.utils.CassandraVersion> loadPeerVersions();
descriptor: ()Ljava/util/Map;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=4, args_size=0
0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 0
start local 0 1: ldc "SELECT peer, release_version FROM system.peers"
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 2
goto 13
StackMap locals: java.util.Map top java.util.Iterator
StackMap stack:
2: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 1
start local 1 3: aload 1
ldc "peer"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInetAddress:(Ljava/lang/String;)Ljava/net/InetAddress;
astore 3
start local 3 4: aload 1
ldc "release_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 11
5: aload 0
aload 3
new org.apache.cassandra.utils.CassandraVersion
dup
aload 1
ldc "release_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokespecial org.apache.cassandra.utils.CassandraVersion.<init>:(Ljava/lang/String;)V
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
6: goto 13
7: StackMap locals: java.util.Map org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator java.net.InetAddress
StackMap stack: java.lang.IllegalArgumentException
pop
8: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "Invalid version string found for {}"
aload 3
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
9: aload 0
aload 3
getstatic org.apache.cassandra.db.SystemKeyspace.NULL_VERSION:Lorg/apache/cassandra/utils/CassandraVersion;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
10: goto 13
11: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "No version string found for {}"
aload 3
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
12: aload 0
aload 3
getstatic org.apache.cassandra.db.SystemKeyspace.NULL_VERSION:Lorg/apache/cassandra/utils/CassandraVersion;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 3 end local 1 13: StackMap locals: java.util.Map top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
14: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 15 0 releaseVersionMap Ljava/util/Map<Ljava/net/InetAddress;Lorg/apache/cassandra/utils/CassandraVersion;>;
3 13 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
4 13 3 peer Ljava/net/InetAddress;
Exception table:
from to target type
5 6 7 Class java.lang.IllegalArgumentException
Signature: ()Ljava/util/Map<Ljava/net/InetAddress;Lorg/apache/cassandra/utils/CassandraVersion;>;
public static java.net.InetAddress getPreferredIP(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Ljava/net/InetAddress;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=1
start local 0 0: ldc "SELECT preferred_ip FROM system.%s WHERE peer=?"
astore 1
start local 1 1: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "peers"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 2
start local 2 2: aload 2
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 4
aload 2
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "preferred_ip"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 4
3: aload 2
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "preferred_ip"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInetAddress:(Ljava/lang/String;)Ljava/net/InetAddress;
areturn
4: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 ep Ljava/net/InetAddress;
1 5 1 req Ljava/lang/String;
2 5 2 result Lorg/apache/cassandra/cql3/UntypedResultSet;
MethodParameters:
Name Flags
ep
public static java.util.Map<java.net.InetAddress, java.util.Map<java.lang.String, java.lang.String>> loadDcRackInfo();
descriptor: ()Ljava/util/Map;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=5, args_size=0
0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 0
start local 0 1: ldc "SELECT peer, data_center, rack from system.peers"
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 2
goto 9
StackMap locals: java.util.Map top java.util.Iterator
StackMap stack:
2: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 1
start local 1 3: aload 1
ldc "peer"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInetAddress:(Ljava/lang/String;)Ljava/net/InetAddress;
astore 3
start local 3 4: aload 1
ldc "data_center"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 9
aload 1
ldc "rack"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 9
5: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 4
start local 4 6: aload 4
ldc "data_center"
aload 1
ldc "data_center"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 4
ldc "rack"
aload 1
ldc "rack"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
8: aload 0
aload 3
aload 4
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 4 end local 3 end local 1 9: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
10: aload 0
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 11 0 result Ljava/util/Map<Ljava/net/InetAddress;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;>;
3 9 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
4 9 3 peer Ljava/net/InetAddress;
6 9 4 dcRack Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
Signature: ()Ljava/util/Map<Ljava/net/InetAddress;Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;>;
public static org.apache.cassandra.utils.CassandraVersion getReleaseVersion(java.net.InetAddress);
descriptor: (Ljava/net/InetAddress;)Lorg/apache/cassandra/utils/CassandraVersion;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=1
start local 0 0: invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
aload 0
invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
ifeq 3
1: new org.apache.cassandra.utils.CassandraVersion
dup
invokestatic org.apache.cassandra.utils.FBUtilities.getReleaseVersionString:()Ljava/lang/String;
invokespecial org.apache.cassandra.utils.CassandraVersion.<init>:(Ljava/lang/String;)V
2: areturn
3: StackMap locals:
StackMap stack:
ldc "SELECT release_version FROM system.%s WHERE peer=?"
astore 1
start local 1 4: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "peers"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 2
start local 2 5: aload 2
ifnull 8
aload 2
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "release_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 8
6: new org.apache.cassandra.utils.CassandraVersion
dup
aload 2
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "release_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokespecial org.apache.cassandra.utils.CassandraVersion.<init>:(Ljava/lang/String;)V
7: areturn
8: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aconst_null
areturn
end local 2 end local 1 9: StackMap locals: java.net.InetAddress
StackMap stack: java.lang.IllegalArgumentException
pop
10: aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 ep Ljava/net/InetAddress;
4 9 1 req Ljava/lang/String;
5 9 2 result Lorg/apache/cassandra/cql3/UntypedResultSet;
Exception table:
from to target type
0 2 9 Class java.lang.IllegalArgumentException
3 7 9 Class java.lang.IllegalArgumentException
MethodParameters:
Name Flags
ep
public static void checkHealth();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=0
0: ldc "system"
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
astore 0
start local 0 1: goto 6
end local 0 2: StackMap locals:
StackMap stack: java.lang.AssertionError
astore 1
start local 1 3: new org.apache.cassandra.exceptions.ConfigurationException
dup
ldc "Could not read system keyspace!"
invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
astore 2
start local 2 4: aload 2
aload 1
invokevirtual org.apache.cassandra.exceptions.ConfigurationException.initCause:(Ljava/lang/Throwable;)Ljava/lang/Throwable;
pop
5: aload 2
athrow
end local 2 end local 1 start local 0 6: StackMap locals: org.apache.cassandra.db.Keyspace
StackMap stack:
aload 0
ldc "local"
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
astore 1
start local 1 7: ldc "SELECT cluster_name FROM system.%s WHERE key='%s'"
astore 2
start local 2 8: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 3
start local 3 9: aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 10
aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "cluster_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifne 13
10: StackMap locals: org.apache.cassandra.db.ColumnFamilyStore java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getLiveSSTables:()Ljava/util/Set;
invokeinterface java.util.Set.isEmpty:()Z
ifne 12
11: new org.apache.cassandra.exceptions.ConfigurationException
dup
ldc "Found system keyspace files, but they couldn't be loaded!"
invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
athrow
12: StackMap locals:
StackMap stack:
return
13: StackMap locals:
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "cluster_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 4
start local 4 14: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getClusterName:()Ljava/lang/String;
aload 4
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 16
15: new org.apache.cassandra.exceptions.ConfigurationException
dup
new java.lang.StringBuilder
dup
ldc "Saved cluster name "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " != configured name "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokestatic org.apache.cassandra.config.DatabaseDescriptor.getClusterName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial org.apache.cassandra.exceptions.ConfigurationException.<init>:(Ljava/lang/String;)V
athrow
16: StackMap locals: java.lang.String
StackMap stack:
return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 2 0 keyspace Lorg/apache/cassandra/db/Keyspace;
6 17 0 keyspace Lorg/apache/cassandra/db/Keyspace;
3 6 1 err Ljava/lang/AssertionError;
4 6 2 ex Lorg/apache/cassandra/exceptions/ConfigurationException;
7 17 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
8 17 2 req Ljava/lang/String;
9 17 3 result Lorg/apache/cassandra/cql3/UntypedResultSet;
14 17 4 savedClusterName Ljava/lang/String;
Exception table:
from to target type
0 1 2 Class java.lang.AssertionError
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
public static java.util.Collection<org.apache.cassandra.dht.Token> getSavedTokens();
descriptor: ()Ljava/util/Collection;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=0
0: ldc "SELECT tokens FROM system.%s WHERE key='%s'"
astore 0
start local 0 1: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 3
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "tokens"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifne 4
3: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
invokestatic java.util.Collections.emptyList:()Ljava/util/List;
goto 5
4: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "tokens"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getSet:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/Set;
invokestatic org.apache.cassandra.db.SystemKeyspace.deserializeTokens:(Ljava/util/Collection;)Ljava/util/Collection;
5: StackMap locals:
StackMap stack: java.util.Collection
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 6 0 req Ljava/lang/String;
2 6 1 result Lorg/apache/cassandra/cql3/UntypedResultSet;
Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/dht/Token;>;
public static int incrementAndGetGeneration();
descriptor: ()I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=0
0: ldc "SELECT gossip_generation FROM system.%s WHERE key='%s'"
astore 0
start local 0 1: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 3
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "gossip_generation"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifne 5
3: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
invokestatic java.lang.System.currentTimeMillis:()J
ldc 1000
ldiv
l2i
istore 2
start local 2 4: goto 14
end local 2 5: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "gossip_generation"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
iconst_1
iadd
istore 3
start local 3 6: invokestatic java.lang.System.currentTimeMillis:()J
ldc 1000
ldiv
l2i
istore 4
start local 4 7: iload 3
iload 4
if_icmplt 13
8: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "Using stored Gossip Generation {} as it is greater than current system time {}. See CASSANDRA-3654 if you experience problems"
9: iload 3
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
iload 4
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
10: invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
11: iload 3
istore 2
start local 2 12: goto 14
end local 2 13: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet top int int
StackMap stack:
iload 4
istore 2
end local 4 end local 3 start local 2 14: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet int
StackMap stack:
ldc "INSERT INTO system.%s (key, gossip_generation) VALUES ('%s', ?)"
astore 0
15: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
16: ldc "local"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
17: iload 2
ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 18 0 req Ljava/lang/String;
2 18 1 result Lorg/apache/cassandra/cql3/UntypedResultSet;
4 5 2 generation I
12 13 2 generation I
14 18 2 generation I
6 14 3 storedGeneration I
7 14 4 now I
public static org.apache.cassandra.db.SystemKeyspace$BootstrapState getBootstrapState();
descriptor: ()Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=0
0: ldc "SELECT bootstrapped FROM system.%s WHERE key='%s'"
astore 0
start local 0 1: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 3
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "bootstrapped"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifne 4
3: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
getstatic org.apache.cassandra.db.SystemKeyspace$BootstrapState.NEEDS_BOOTSTRAP:Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
areturn
4: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "bootstrapped"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.db.SystemKeyspace$BootstrapState.valueOf:(Ljava/lang/String;)Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 5 0 req Ljava/lang/String;
2 5 1 result Lorg/apache/cassandra/cql3/UntypedResultSet;
public static boolean bootstrapComplete();
descriptor: ()Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: invokestatic org.apache.cassandra.db.SystemKeyspace.getBootstrapState:()Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
getstatic org.apache.cassandra.db.SystemKeyspace$BootstrapState.COMPLETED:Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
LocalVariableTable:
Start End Slot Name Signature
public static boolean bootstrapInProgress();
descriptor: ()Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: invokestatic org.apache.cassandra.db.SystemKeyspace.getBootstrapState:()Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
getstatic org.apache.cassandra.db.SystemKeyspace$BootstrapState.IN_PROGRESS:Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
LocalVariableTable:
Start End Slot Name Signature
public static boolean wasDecommissioned();
descriptor: ()Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: invokestatic org.apache.cassandra.db.SystemKeyspace.getBootstrapState:()Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
getstatic org.apache.cassandra.db.SystemKeyspace$BootstrapState.DECOMMISSIONED:Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
if_acmpne 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
LocalVariableTable:
Start End Slot Name Signature
public static void setBootstrapState(org.apache.cassandra.db.SystemKeyspace$BootstrapState);
descriptor: (Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: ldc "INSERT INTO system.%s (key, bootstrapped) VALUES ('%s', ?)"
astore 1
start local 1 1: aload 1
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual org.apache.cassandra.db.SystemKeyspace$BootstrapState.name:()Ljava/lang/String;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: ldc "local"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 state Lorg/apache/cassandra/db/SystemKeyspace$BootstrapState;
1 4 1 req Ljava/lang/String;
MethodParameters:
Name Flags
state
public static boolean isIndexBuilt(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=2
start local 0 start local 1 0: ldc "SELECT index_name FROM %s.\"%s\" WHERE table_name=? AND index_name=?"
astore 2
start local 2 1: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "IndexInfo"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 3
start local 3 2: aload 3
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifeq 3
iconst_0
goto 4
StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
3: iconst_1
StackMap locals:
StackMap stack: int
4: ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 keyspaceName Ljava/lang/String;
0 5 1 indexName Ljava/lang/String;
1 5 2 req Ljava/lang/String;
2 5 3 result Lorg/apache/cassandra/cql3/UntypedResultSet;
MethodParameters:
Name Flags
keyspaceName
indexName
public static void setIndexBuilt(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: ldc "INSERT INTO %s.\"%s\" (table_name, index_name) VALUES (?, ?)"
astore 2
start local 2 1: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "IndexInfo"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: ldc "IndexInfo"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 keyspaceName Ljava/lang/String;
0 4 1 indexName Ljava/lang/String;
1 4 2 req Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
indexName
public static void setIndexRemoved(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: ldc "DELETE FROM %s.\"%s\" WHERE table_name = ? AND index_name = ?"
astore 2
start local 2 1: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "IndexInfo"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: ldc "IndexInfo"
invokestatic org.apache.cassandra.db.SystemKeyspace.forceBlockingFlush:(Ljava/lang/String;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 keyspaceName Ljava/lang/String;
0 4 1 indexName Ljava/lang/String;
1 4 2 req Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
indexName
public static java.util.List<java.lang.String> getBuiltIndexes(java.lang.String, java.util.Set<java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/util/Set;)Ljava/util/List;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: new java.util.ArrayList
dup
aload 1
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
astore 2
start local 2 1: ldc "SELECT index_name from %s.\"%s\" WHERE table_name=? AND index_name IN ?"
astore 3
start local 3 2: aload 3
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "IndexInfo"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 2
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.spliterator:()Ljava/util/Spliterator;
iconst_0
invokestatic java.util.stream.StreamSupport.stream:(Ljava/util/Spliterator;Z)Ljava/util/stream/Stream;
4: invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/SystemKeyspace.lambda$3(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Ljava/lang/String; (6)
(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
5: invokestatic java.util.stream.Collectors.toList:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.List
6: areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 keyspaceName Ljava/lang/String;
0 7 1 indexNames Ljava/util/Set<Ljava/lang/String;>;
1 7 2 names Ljava/util/List<Ljava/lang/String;>;
2 7 3 req Ljava/lang/String;
3 7 4 results Lorg/apache/cassandra/cql3/UntypedResultSet;
Signature: (Ljava/lang/String;Ljava/util/Set<Ljava/lang/String;>;)Ljava/util/List<Ljava/lang/String;>;
MethodParameters:
Name Flags
keyspaceName
indexNames
public static java.util.UUID getLocalHostId();
descriptor: ()Ljava/util/UUID;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=0
0: ldc "SELECT host_id FROM system.%s WHERE key='%s'"
astore 0
start local 0 1: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 4
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "host_id"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 4
3: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "host_id"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
areturn
4: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
invokestatic java.util.UUID.randomUUID:()Ljava/util/UUID;
astore 2
start local 2 5: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "No host ID found, created {} (Note: This should happen exactly once per node)."
aload 2
invokeinterface org.slf4j.Logger.warn:(Ljava/lang/String;Ljava/lang/Object;)V
6: aload 2
invokestatic org.apache.cassandra.db.SystemKeyspace.setLocalHostId:(Ljava/util/UUID;)Ljava/util/UUID;
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 7 0 req Ljava/lang/String;
2 7 1 result Lorg/apache/cassandra/cql3/UntypedResultSet;
5 7 2 hostId Ljava/util/UUID;
public static java.util.UUID setLocalHostId(java.util.UUID);
descriptor: (Ljava/util/UUID;)Ljava/util/UUID;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: ldc "INSERT INTO system.%s (key, host_id) VALUES ('%s', ?)"
astore 1
start local 1 1: aload 1
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: aload 0
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 hostId Ljava/util/UUID;
1 3 1 req Ljava/lang/String;
MethodParameters:
Name Flags
hostId
public static java.lang.String getRack();
descriptor: ()Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=0
0: ldc "SELECT rack FROM system.%s WHERE key='%s'"
astore 0
start local 0 1: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 4
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "rack"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 4
3: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "rack"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
areturn
4: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 5 0 req Ljava/lang/String;
2 5 1 result Lorg/apache/cassandra/cql3/UntypedResultSet;
public static java.lang.String getDatacenter();
descriptor: ()Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=0
0: ldc "SELECT data_center FROM system.%s WHERE key='%s'"
astore 0
start local 0 1: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 4
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "data_center"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 4
3: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "data_center"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
areturn
4: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 5 0 req Ljava/lang/String;
2 5 1 result Lorg/apache/cassandra/cql3/UntypedResultSet;
public static org.apache.cassandra.service.paxos.PaxosState loadPaxosState(org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.config.CFMetaData, int);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/config/CFMetaData;I)Lorg/apache/cassandra/service/paxos/PaxosState;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=9, locals=11, args_size=3
start local 0 start local 1 start local 2 0: ldc "SELECT * FROM system.%s WHERE row_key = ? AND cf_id = ?"
astore 3
start local 3 1: iload 2
invokestatic java.lang.System.nanoTime:()J
aload 3
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "paxos"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aastore
dup
iconst_1
aload 1
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternalWithNow:(IJLjava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 4
start local 4 2: aload 4
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifeq 4
3: new org.apache.cassandra.service.paxos.PaxosState
dup
aload 0
aload 1
invokespecial org.apache.cassandra.service.paxos.PaxosState.<init>:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/config/CFMetaData;)V
areturn
4: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 5
start local 5 5: aload 5
ldc "in_progress_ballot"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 7
6: new org.apache.cassandra.service.paxos.Commit
dup
aload 5
ldc "in_progress_ballot"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
new org.apache.cassandra.db.partitions.PartitionUpdate
dup
aload 1
aload 0
aload 1
invokevirtual org.apache.cassandra.config.CFMetaData.partitionColumns:()Lorg/apache/cassandra/db/PartitionColumns;
iconst_1
invokespecial org.apache.cassandra.db.partitions.PartitionUpdate.<init>:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;I)V
invokespecial org.apache.cassandra.service.paxos.Commit.<init>:(Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
goto 8
7: StackMap locals: org.apache.cassandra.cql3.UntypedResultSet$Row
StackMap stack:
aload 0
aload 1
invokestatic org.apache.cassandra.service.paxos.Commit.emptyCommit:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/service/paxos/Commit;
8: StackMap locals:
StackMap stack: org.apache.cassandra.service.paxos.Commit
astore 6
start local 6 9: aload 5
ldc "proposal_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 10
aload 5
ldc "proposal_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
goto 11
StackMap locals: org.apache.cassandra.service.paxos.Commit
StackMap stack:
10: bipush 8
StackMap locals:
StackMap stack: int
11: istore 7
start local 7 12: aload 5
ldc "proposal"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 14
13: new org.apache.cassandra.service.paxos.Commit
dup
aload 5
ldc "proposal_ballot"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
aload 5
ldc "proposal"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getBytes:(Ljava/lang/String;)Ljava/nio/ByteBuffer;
iload 7
aload 0
invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.fromBytes:(Ljava/nio/ByteBuffer;ILorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokespecial org.apache.cassandra.service.paxos.Commit.<init>:(Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
goto 15
14: StackMap locals: int
StackMap stack:
aload 0
aload 1
invokestatic org.apache.cassandra.service.paxos.Commit.emptyCommit:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/service/paxos/Commit;
15: StackMap locals:
StackMap stack: org.apache.cassandra.service.paxos.Commit
astore 8
start local 8 16: aload 5
ldc "most_recent_commit_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 17
aload 5
ldc "most_recent_commit_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
goto 18
StackMap locals: org.apache.cassandra.service.paxos.Commit
StackMap stack:
17: bipush 8
StackMap locals:
StackMap stack: int
18: istore 9
start local 9 19: aload 5
ldc "most_recent_commit"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 21
20: new org.apache.cassandra.service.paxos.Commit
dup
aload 5
ldc "most_recent_commit_at"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
aload 5
ldc "most_recent_commit"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getBytes:(Ljava/lang/String;)Ljava/nio/ByteBuffer;
iload 9
aload 0
invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.fromBytes:(Ljava/nio/ByteBuffer;ILorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokespecial org.apache.cassandra.service.paxos.Commit.<init>:(Ljava/util/UUID;Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
goto 22
21: StackMap locals: int
StackMap stack:
aload 0
aload 1
invokestatic org.apache.cassandra.service.paxos.Commit.emptyCommit:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/service/paxos/Commit;
22: StackMap locals:
StackMap stack: org.apache.cassandra.service.paxos.Commit
astore 10
start local 10 23: new org.apache.cassandra.service.paxos.PaxosState
dup
aload 6
aload 8
aload 10
invokespecial org.apache.cassandra.service.paxos.PaxosState.<init>:(Lorg/apache/cassandra/service/paxos/Commit;Lorg/apache/cassandra/service/paxos/Commit;Lorg/apache/cassandra/service/paxos/Commit;)V
areturn
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 24 0 key Lorg/apache/cassandra/db/DecoratedKey;
0 24 1 metadata Lorg/apache/cassandra/config/CFMetaData;
0 24 2 nowInSec I
1 24 3 req Ljava/lang/String;
2 24 4 results Lorg/apache/cassandra/cql3/UntypedResultSet;
5 24 5 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
9 24 6 promised Lorg/apache/cassandra/service/paxos/Commit;
12 24 7 proposalVersion I
16 24 8 accepted Lorg/apache/cassandra/service/paxos/Commit;
19 24 9 mostRecentVersion I
23 24 10 mostRecent Lorg/apache/cassandra/service/paxos/Commit;
MethodParameters:
Name Flags
key
metadata
nowInSec
public static void savePaxosPromise(org.apache.cassandra.service.paxos.Commit);
descriptor: (Lorg/apache/cassandra/service/paxos/Commit;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=2, args_size=1
start local 0 0: ldc "UPDATE system.%s USING TIMESTAMP ? AND TTL ? SET in_progress_ballot = ? WHERE row_key = ? AND cf_id = ?"
astore 1
start local 1 1: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "paxos"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_5
anewarray java.lang.Object
dup
iconst_0
2: aload 0
getfield org.apache.cassandra.service.paxos.Commit.ballot:Ljava/util/UUID;
invokestatic org.apache.cassandra.utils.UUIDGen.microsTimestamp:(Ljava/util/UUID;)J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
3: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokestatic org.apache.cassandra.db.SystemKeyspace.paxosTtlSec:(Lorg/apache/cassandra/config/CFMetaData;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
4: aload 0
getfield org.apache.cassandra.service.paxos.Commit.ballot:Ljava/util/UUID;
aastore
dup
iconst_3
5: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aastore
dup
iconst_4
6: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aastore
7: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 promise Lorg/apache/cassandra/service/paxos/Commit;
1 9 1 req Ljava/lang/String;
MethodParameters:
Name Flags
promise
public static void savePaxosProposal(org.apache.cassandra.service.paxos.Commit);
descriptor: (Lorg/apache/cassandra/service/paxos/Commit;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=1, args_size=1
start local 0 0: ldc "UPDATE system.%s USING TIMESTAMP ? AND TTL ? SET proposal_ballot = ?, proposal = ?, proposal_version = ? WHERE row_key = ? AND cf_id = ?"
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "paxos"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
bipush 7
anewarray java.lang.Object
dup
iconst_0
1: aload 0
getfield org.apache.cassandra.service.paxos.Commit.ballot:Ljava/util/UUID;
invokestatic org.apache.cassandra.utils.UUIDGen.microsTimestamp:(Ljava/util/UUID;)J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
2: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokestatic org.apache.cassandra.db.SystemKeyspace.paxosTtlSec:(Lorg/apache/cassandra/config/CFMetaData;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
3: aload 0
getfield org.apache.cassandra.service.paxos.Commit.ballot:Ljava/util/UUID;
aastore
dup
iconst_3
4: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
getstatic org.apache.cassandra.net.MessagingService.current_version:I
invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.toBytes:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;I)Ljava/nio/ByteBuffer;
aastore
dup
iconst_4
5: getstatic org.apache.cassandra.net.MessagingService.current_version:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_5
6: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aastore
dup
bipush 6
7: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aastore
8: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
9: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 proposal Lorg/apache/cassandra/service/paxos/Commit;
MethodParameters:
Name Flags
proposal
public static int paxosTtlSec(org.apache.cassandra.config.CFMetaData);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;)I
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: sipush 10800
aload 0
getfield org.apache.cassandra.config.CFMetaData.params:Lorg/apache/cassandra/schema/TableParams;
getfield org.apache.cassandra.schema.TableParams.gcGraceSeconds:I
invokestatic java.lang.Math.max:(II)I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 metadata Lorg/apache/cassandra/config/CFMetaData;
MethodParameters:
Name Flags
metadata
public static void savePaxosCommit(org.apache.cassandra.service.paxos.Commit);
descriptor: (Lorg/apache/cassandra/service/paxos/Commit;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=2, args_size=1
start local 0 0: ldc "UPDATE system.%s USING TIMESTAMP ? AND TTL ? SET proposal_ballot = null, proposal = null, most_recent_commit_at = ?, most_recent_commit = ?, most_recent_commit_version = ? WHERE row_key = ? AND cf_id = ?"
astore 1
start local 1 1: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "paxos"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
bipush 7
anewarray java.lang.Object
dup
iconst_0
2: aload 0
getfield org.apache.cassandra.service.paxos.Commit.ballot:Ljava/util/UUID;
invokestatic org.apache.cassandra.utils.UUIDGen.microsTimestamp:(Ljava/util/UUID;)J
invokestatic java.lang.Long.valueOf:(J)Ljava/lang/Long;
aastore
dup
iconst_1
3: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
invokestatic org.apache.cassandra.db.SystemKeyspace.paxosTtlSec:(Lorg/apache/cassandra/config/CFMetaData;)I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_2
4: aload 0
getfield org.apache.cassandra.service.paxos.Commit.ballot:Ljava/util/UUID;
aastore
dup
iconst_3
5: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
getstatic org.apache.cassandra.net.MessagingService.current_version:I
invokestatic org.apache.cassandra.db.partitions.PartitionUpdate.toBytes:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;I)Ljava/nio/ByteBuffer;
aastore
dup
iconst_4
6: getstatic org.apache.cassandra.net.MessagingService.current_version:I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_5
7: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
aastore
dup
bipush 6
8: aload 0
getfield org.apache.cassandra.service.paxos.Commit.update:Lorg/apache/cassandra/db/partitions/PartitionUpdate;
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.metadata:()Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
aastore
9: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
10: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 commit Lorg/apache/cassandra/service/paxos/Commit;
1 11 1 cql Ljava/lang/String;
MethodParameters:
Name Flags
commit
public static org.apache.cassandra.metrics.RestorableMeter getSSTableReadMeter(java.lang.String, java.lang.String, int);
descriptor: (Ljava/lang/String;Ljava/lang/String;I)Lorg/apache/cassandra/metrics/RestorableMeter;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=10, args_size=3
start local 0 start local 1 start local 2 0: ldc "SELECT * FROM system.%s WHERE keyspace_name=? and columnfamily_name=? and generation=?"
astore 3
start local 3 1: aload 3
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "sstable_activity"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 4
start local 4 2: aload 4
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifeq 4
3: new org.apache.cassandra.metrics.RestorableMeter
dup
invokespecial org.apache.cassandra.metrics.RestorableMeter.<init>:()V
areturn
4: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aload 4
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 5
start local 5 5: aload 5
ldc "rate_15m"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getDouble:(Ljava/lang/String;)D
dstore 6
start local 6 6: aload 5
ldc "rate_120m"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getDouble:(Ljava/lang/String;)D
dstore 8
start local 8 7: new org.apache.cassandra.metrics.RestorableMeter
dup
dload 6
dload 8
invokespecial org.apache.cassandra.metrics.RestorableMeter.<init>:(DD)V
areturn
end local 8 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 8 0 keyspace Ljava/lang/String;
0 8 1 table Ljava/lang/String;
0 8 2 generation I
1 8 3 cql Ljava/lang/String;
2 8 4 results Lorg/apache/cassandra/cql3/UntypedResultSet;
5 8 5 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
6 8 6 m15rate D
7 8 8 m120rate D
MethodParameters:
Name Flags
keyspace
table
generation
public static void persistSSTableReadMeter(java.lang.String, java.lang.String, int, org.apache.cassandra.metrics.RestorableMeter);
descriptor: (Ljava/lang/String;Ljava/lang/String;ILorg/apache/cassandra/metrics/RestorableMeter;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=6, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: ldc "INSERT INTO system.%s (keyspace_name, columnfamily_name, generation, rate_15m, rate_120m) VALUES (?, ?, ?, ?, ?) USING TTL 864000"
astore 4
start local 4 1: aload 4
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "sstable_activity"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_5
anewarray java.lang.Object
dup
iconst_0
2: aload 0
aastore
dup
iconst_1
3: aload 1
aastore
dup
iconst_2
4: iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_3
5: aload 3
invokevirtual org.apache.cassandra.metrics.RestorableMeter.fifteenMinuteRate:()D
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_4
6: aload 3
invokevirtual org.apache.cassandra.metrics.RestorableMeter.twoHourRate:()D
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
7: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
8: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 keyspace Ljava/lang/String;
0 9 1 table Ljava/lang/String;
0 9 2 generation I
0 9 3 meter Lorg/apache/cassandra/metrics/RestorableMeter;
1 9 4 cql Ljava/lang/String;
MethodParameters:
Name Flags
keyspace
table
generation
meter
public static void clearSSTableReadMeter(java.lang.String, java.lang.String, int);
descriptor: (Ljava/lang/String;Ljava/lang/String;I)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: ldc "DELETE FROM system.%s WHERE keyspace_name=? AND columnfamily_name=? and generation=?"
astore 3
start local 3 1: aload 3
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "sstable_activity"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
iload 2
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 keyspace Ljava/lang/String;
0 3 1 table Ljava/lang/String;
0 3 2 generation I
1 3 3 cql Ljava/lang/String;
MethodParameters:
Name Flags
keyspace
table
generation
public static void updateSizeEstimates(java.lang.String, java.lang.String, java.util.Map<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>, org.apache.cassandra.utils.Pair<java.lang.Long, java.lang.Long>>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/Map;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=10, locals=12, args_size=3
start local 0 start local 1 start local 2 0: invokestatic org.apache.cassandra.utils.FBUtilities.timestampMicros:()J
lstore 3
start local 3 1: new org.apache.cassandra.db.partitions.PartitionUpdate
dup
getstatic org.apache.cassandra.db.SystemKeyspace.SizeEstimates:Lorg/apache/cassandra/config/CFMetaData;
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
aload 0
invokevirtual org.apache.cassandra.db.marshal.UTF8Type.decompose:(Ljava/lang/Object;)Ljava/nio/ByteBuffer;
getstatic org.apache.cassandra.db.SystemKeyspace.SizeEstimates:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.partitionColumns:()Lorg/apache/cassandra/db/PartitionColumns;
aload 2
invokeinterface java.util.Map.size:()I
invokespecial org.apache.cassandra.db.partitions.PartitionUpdate.<init>:(Lorg/apache/cassandra/config/CFMetaData;Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/PartitionColumns;I)V
astore 5
start local 5 2: new org.apache.cassandra.db.Mutation
dup
aload 5
invokespecial org.apache.cassandra.db.Mutation.<init>:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
astore 6
start local 6 3: invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
istore 7
start local 7 4: aload 5
new org.apache.cassandra.db.RangeTombstone
dup
getstatic org.apache.cassandra.db.SystemKeyspace.SizeEstimates:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
invokestatic org.apache.cassandra.db.Slice.make:(Lorg/apache/cassandra/db/ClusteringComparator;[Ljava/lang/Object;)Lorg/apache/cassandra/db/Slice;
new org.apache.cassandra.db.DeletionTime
dup
lload 3
lconst_1
lsub
iload 7
invokespecial org.apache.cassandra.db.DeletionTime.<init>:(JI)V
invokespecial org.apache.cassandra.db.RangeTombstone.<init>:(Lorg/apache/cassandra/db/Slice;Lorg/apache/cassandra/db/DeletionTime;)V
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.add:(Lorg/apache/cassandra/db/RangeTombstone;)V
5: aload 2
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 9
goto 15
StackMap locals: java.lang.String java.lang.String java.util.Map long org.apache.cassandra.db.partitions.PartitionUpdate org.apache.cassandra.db.Mutation int top java.util.Iterator
StackMap stack:
6: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 8
start local 8 7: aload 8
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Range
astore 10
start local 10 8: aload 8
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.cassandra.utils.Pair
astore 11
start local 11 9: aload 5
getstatic org.apache.cassandra.db.SystemKeyspace.SizeEstimates:Lorg/apache/cassandra/config/CFMetaData;
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 10
getfield org.apache.cassandra.dht.Range.left:Lorg/apache/cassandra/dht/RingPosition;
checkcast org.apache.cassandra.dht.Token
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
aastore
dup
iconst_2
aload 10
getfield org.apache.cassandra.dht.Range.right:Lorg/apache/cassandra/dht/RingPosition;
checkcast org.apache.cassandra.dht.Token
invokevirtual java.lang.Object.toString:()Ljava/lang/String;
aastore
invokestatic org.apache.cassandra.db.rows.Rows.simpleBuilder:(Lorg/apache/cassandra/config/CFMetaData;[Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
10: lload 3
invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.timestamp:(J)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
11: ldc "partitions_count"
aload 11
getfield org.apache.cassandra.utils.Pair.left:Ljava/lang/Object;
invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
12: ldc "mean_partition_size"
aload 11
getfield org.apache.cassandra.utils.Pair.right:Ljava/lang/Object;
invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.add:(Ljava/lang/String;Ljava/lang/Object;)Lorg/apache/cassandra/db/rows/Row$SimpleBuilder;
13: invokeinterface org.apache.cassandra.db.rows.Row$SimpleBuilder.build:()Lorg/apache/cassandra/db/rows/Row;
14: invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.add:(Lorg/apache/cassandra/db/rows/Row;)V
end local 11 end local 10 end local 8 15: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
16: aload 6
invokevirtual org.apache.cassandra.db.Mutation.apply:()V
17: return
end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 keyspace Ljava/lang/String;
0 18 1 table Ljava/lang/String;
0 18 2 estimates Ljava/util/Map<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;Lorg/apache/cassandra/utils/Pair<Ljava/lang/Long;Ljava/lang/Long;>;>;
1 18 3 timestamp J
2 18 5 update Lorg/apache/cassandra/db/partitions/PartitionUpdate;
3 18 6 mutation Lorg/apache/cassandra/db/Mutation;
4 18 7 nowInSec I
7 15 8 entry Ljava/util/Map$Entry<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;Lorg/apache/cassandra/utils/Pair<Ljava/lang/Long;Ljava/lang/Long;>;>;
8 15 10 range Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
9 15 11 values Lorg/apache/cassandra/utils/Pair<Ljava/lang/Long;Ljava/lang/Long;>;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/Map<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;Lorg/apache/cassandra/utils/Pair<Ljava/lang/Long;Ljava/lang/Long;>;>;)V
MethodParameters:
Name Flags
keyspace
table
estimates
public static void clearSizeEstimates(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: ldc "DELETE FROM %s.%s WHERE keyspace_name = ? AND table_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "size_estimates"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 2
start local 2 1: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 keyspace Ljava/lang/String;
0 3 1 table Ljava/lang/String;
1 3 2 cql Ljava/lang/String;
MethodParameters:
Name Flags
keyspace
table
public static void clearSizeEstimates(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: ldc "DELETE FROM %s.%s WHERE keyspace_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "size_estimates"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 1
start local 1 1: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 keyspace Ljava/lang/String;
1 3 1 cql Ljava/lang/String;
MethodParameters:
Name Flags
keyspace
public static synchronized com.google.common.collect.SetMultimap<java.lang.String, java.lang.String> getTablesWithSizeEstimates();
descriptor: ()Lcom/google/common/collect/SetMultimap;
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=5, args_size=0
0: invokestatic com.google.common.collect.HashMultimap.create:()Lcom/google/common/collect/HashMultimap;
astore 0
start local 0 1: ldc "SELECT keyspace_name, table_name FROM %s.%s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "size_estimates"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 1
start local 1 2: aload 1
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 2
start local 2 3: aload 2
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 4
goto 6
StackMap locals: com.google.common.collect.SetMultimap java.lang.String org.apache.cassandra.cql3.UntypedResultSet top java.util.Iterator
StackMap stack:
4: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 3
start local 3 5: aload 0
aload 3
ldc "keyspace_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
aload 3
ldc "table_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokeinterface com.google.common.collect.SetMultimap.put:(Ljava/lang/Object;Ljava/lang/Object;)Z
pop
end local 3 6: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
7: aload 0
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 8 0 keyspaceTableMap Lcom/google/common/collect/SetMultimap<Ljava/lang/String;Ljava/lang/String;>;
2 8 1 cql Ljava/lang/String;
3 8 2 rs Lorg/apache/cassandra/cql3/UntypedResultSet;
5 6 3 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
Signature: ()Lcom/google/common/collect/SetMultimap<Ljava/lang/String;Ljava/lang/String;>;
public static synchronized void updateAvailableRanges(java.lang.String, java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>);
descriptor: (Ljava/lang/String;Ljava/util/Collection;)V
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=6, args_size=2
start local 0 start local 1 0: ldc "UPDATE system.%s SET ranges = ranges + ? WHERE keyspace_name = ?"
astore 2
start local 2 1: new java.util.HashSet
dup
aload 1
invokeinterface java.util.Collection.size:()I
invokespecial java.util.HashSet.<init>:(I)V
astore 3
start local 3 2: aload 1
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 5
goto 5
StackMap locals: java.lang.String java.util.Collection java.lang.String java.util.Set top java.util.Iterator
StackMap stack:
3: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Range
astore 4
start local 4 4: aload 3
aload 4
invokestatic org.apache.cassandra.db.SystemKeyspace.rangeToBytes:(Lorg/apache/cassandra/dht/Range;)Ljava/nio/ByteBuffer;
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 4 5: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "available_ranges"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 3
aastore
dup
iconst_1
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
7: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 keyspace Ljava/lang/String;
0 8 1 completedRanges Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
1 8 2 cql Ljava/lang/String;
2 8 3 rangesToUpdate Ljava/util/Set<Ljava/nio/ByteBuffer;>;
4 5 4 range Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
Signature: (Ljava/lang/String;Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;)V
MethodParameters:
Name Flags
keyspace
completedRanges
public static synchronized java.util.Set<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>> getAvailableRanges(java.lang.String, org.apache.cassandra.dht.IPartitioner);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/dht/IPartitioner;)Ljava/util/Set;
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=10, args_size=2
start local 0 start local 1 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 1: ldc "SELECT * FROM system.%s WHERE keyspace_name=?"
astore 3
start local 3 2: aload 3
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "available_ranges"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 4
start local 4 3: aload 4
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 6
goto 10
StackMap locals: java.lang.String org.apache.cassandra.dht.IPartitioner java.util.Set java.lang.String org.apache.cassandra.cql3.UntypedResultSet top java.util.Iterator
StackMap stack:
4: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 5
start local 5 5: aload 5
ldc "ranges"
getstatic org.apache.cassandra.db.marshal.BytesType.instance:Lorg/apache/cassandra/db/marshal/BytesType;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getSet:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/Set;
astore 7
start local 7 6: aload 7
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 9
goto 9
StackMap locals: java.lang.String org.apache.cassandra.dht.IPartitioner java.util.Set java.lang.String org.apache.cassandra.cql3.UntypedResultSet org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator java.util.Set top java.util.Iterator
StackMap stack:
7: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 8
start local 8 8: aload 2
aload 8
aload 1
invokestatic org.apache.cassandra.db.SystemKeyspace.byteBufferToRange:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/dht/Range;
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 8 9: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
end local 7 end local 5 10: StackMap locals: java.lang.String org.apache.cassandra.dht.IPartitioner java.util.Set java.lang.String org.apache.cassandra.cql3.UntypedResultSet top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
11: aload 2
invokestatic com.google.common.collect.ImmutableSet.copyOf:(Ljava/util/Collection;)Lcom/google/common/collect/ImmutableSet;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 keyspace Ljava/lang/String;
0 12 1 partitioner Lorg/apache/cassandra/dht/IPartitioner;
1 12 2 result Ljava/util/Set<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
2 12 3 query Ljava/lang/String;
3 12 4 rs Lorg/apache/cassandra/cql3/UntypedResultSet;
5 10 5 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
6 10 7 rawRanges Ljava/util/Set<Ljava/nio/ByteBuffer;>;
8 9 8 rawRange Ljava/nio/ByteBuffer;
Signature: (Ljava/lang/String;Lorg/apache/cassandra/dht/IPartitioner;)Ljava/util/Set<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
MethodParameters:
Name Flags
keyspace
partitioner
public static void resetAvailableRanges();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=0
0: ldc "system"
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
ldc "available_ranges"
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
astore 0
start local 0 1: aload 0
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.truncateBlocking:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 3 0 availableRanges Lorg/apache/cassandra/db/ColumnFamilyStore;
public static synchronized void updateTransferredRanges(java.lang.String, java.net.InetAddress, java.lang.String, java.util.Collection<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>);
descriptor: (Ljava/lang/String;Ljava/net/InetAddress;Ljava/lang/String;Ljava/util/Collection;)V
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: ldc "UPDATE system.%s SET ranges = ranges + ? WHERE operation = ? AND peer = ? AND keyspace_name = ?"
astore 4
start local 4 1: new java.util.HashSet
dup
aload 3
invokeinterface java.util.Collection.size:()I
invokespecial java.util.HashSet.<init>:(I)V
astore 5
start local 5 2: aload 3
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 7
goto 5
StackMap locals: java.lang.String java.net.InetAddress java.lang.String java.util.Collection java.lang.String java.util.Set top java.util.Iterator
StackMap stack:
3: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Range
astore 6
start local 6 4: aload 5
aload 6
invokestatic org.apache.cassandra.db.SystemKeyspace.rangeToBytes:(Lorg/apache/cassandra/dht/Range;)Ljava/nio/ByteBuffer;
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 6 5: StackMap locals:
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 4
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "transferred_ranges"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_4
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
dup
iconst_1
aload 0
aastore
dup
iconst_2
aload 1
aastore
dup
iconst_3
aload 2
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
7: return
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 8 0 description Ljava/lang/String;
0 8 1 peer Ljava/net/InetAddress;
0 8 2 keyspace Ljava/lang/String;
0 8 3 streamedRanges Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
1 8 4 cql Ljava/lang/String;
2 8 5 rangesToUpdate Ljava/util/Set<Ljava/nio/ByteBuffer;>;
4 5 6 range Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
Signature: (Ljava/lang/String;Ljava/net/InetAddress;Ljava/lang/String;Ljava/util/Collection<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;)V
MethodParameters:
Name Flags
description
peer
keyspace
streamedRanges
public static synchronized java.util.Map<java.net.InetAddress, java.util.Set<org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>>> getTransferredRanges(java.lang.String, java.lang.String, org.apache.cassandra.dht.IPartitioner);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/dht/IPartitioner;)Ljava/util/Map;
flags: (0x0029) ACC_PUBLIC, ACC_STATIC, ACC_SYNCHRONIZED
Code:
stack=5, locals=13, args_size=3
start local 0 start local 1 start local 2 0: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 3
start local 3 1: ldc "SELECT * FROM system.%s WHERE operation = ? AND keyspace_name = ?"
astore 4
start local 4 2: aload 4
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "transferred_ranges"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 5
start local 5 3: aload 5
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 7
goto 13
StackMap locals: java.lang.String java.lang.String org.apache.cassandra.dht.IPartitioner java.util.Map java.lang.String org.apache.cassandra.cql3.UntypedResultSet top java.util.Iterator
StackMap stack:
4: aload 7
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 6
start local 6 5: aload 6
ldc "peer"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInetAddress:(Ljava/lang/String;)Ljava/net/InetAddress;
astore 8
start local 8 6: aload 6
ldc "ranges"
getstatic org.apache.cassandra.db.marshal.BytesType.instance:Lorg/apache/cassandra/db/marshal/BytesType;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getSet:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/Set;
astore 9
start local 9 7: aload 9
invokeinterface java.util.Set.size:()I
invokestatic com.google.common.collect.Sets.newHashSetWithExpectedSize:(I)Ljava/util/HashSet;
astore 10
start local 10 8: aload 9
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 12
goto 11
StackMap locals: java.lang.String java.lang.String org.apache.cassandra.dht.IPartitioner java.util.Map java.lang.String org.apache.cassandra.cql3.UntypedResultSet org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator java.net.InetAddress java.util.Set java.util.Set top java.util.Iterator
StackMap stack:
9: aload 12
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
astore 11
start local 11 10: aload 10
aload 11
aload 2
invokestatic org.apache.cassandra.db.SystemKeyspace.byteBufferToRange:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/dht/Range;
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 11 11: StackMap locals:
StackMap stack:
aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
12: aload 3
aload 8
aload 10
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 10 end local 9 end local 8 end local 6 13: StackMap locals: java.lang.String java.lang.String org.apache.cassandra.dht.IPartitioner java.util.Map java.lang.String org.apache.cassandra.cql3.UntypedResultSet top java.util.Iterator
StackMap stack:
aload 7
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
14: aload 3
invokestatic com.google.common.collect.ImmutableMap.copyOf:(Ljava/util/Map;)Lcom/google/common/collect/ImmutableMap;
areturn
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 15 0 description Ljava/lang/String;
0 15 1 keyspace Ljava/lang/String;
0 15 2 partitioner Lorg/apache/cassandra/dht/IPartitioner;
1 15 3 result Ljava/util/Map<Ljava/net/InetAddress;Ljava/util/Set<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;>;
2 15 4 query Ljava/lang/String;
3 15 5 rs Lorg/apache/cassandra/cql3/UntypedResultSet;
5 13 6 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
6 13 8 peer Ljava/net/InetAddress;
7 13 9 rawRanges Ljava/util/Set<Ljava/nio/ByteBuffer;>;
8 13 10 ranges Ljava/util/Set<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;
10 11 11 rawRange Ljava/nio/ByteBuffer;
Signature: (Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/dht/IPartitioner;)Ljava/util/Map<Ljava/net/InetAddress;Ljava/util/Set<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;>;>;
MethodParameters:
Name Flags
description
keyspace
partitioner
public static boolean snapshotOnVersionChange();
descriptor: ()Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=4, args_size=0
0: invokestatic org.apache.cassandra.db.SystemKeyspace.getPreviousVersionString:()Ljava/lang/String;
astore 0
start local 0 1: invokestatic org.apache.cassandra.utils.FBUtilities.getReleaseVersionString:()Ljava/lang/String;
astore 1
start local 1 2: aload 0
getstatic org.apache.cassandra.db.SystemKeyspace.NULL_VERSION:Lorg/apache/cassandra/utils/CassandraVersion;
invokevirtual org.apache.cassandra.utils.CassandraVersion.toString:()Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
aload 0
aload 1
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 11
3: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "Detected version upgrade from {} to {}, snapshotting system keyspace"
aload 0
aload 1
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
4: ldc "upgrade-%s-%s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
5: aload 0
aastore
dup
iconst_1
6: aload 1
aastore
7: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
invokestatic org.apache.cassandra.db.Keyspace.getTimestampedSnapshotName:(Ljava/lang/String;)Ljava/lang/String;
astore 2
start local 2 8: ldc "system"
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
astore 3
start local 3 9: aload 3
aload 2
aconst_null
invokevirtual org.apache.cassandra.db.Keyspace.snapshot:(Ljava/lang/String;Ljava/lang/String;)V
10: iconst_1
ireturn
end local 3 end local 2 11: StackMap locals: java.lang.String java.lang.String
StackMap stack:
iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 12 0 previous Ljava/lang/String;
2 12 1 next Ljava/lang/String;
8 11 2 snapshotName Ljava/lang/String;
9 11 3 systemKs Lorg/apache/cassandra/db/Keyspace;
Exceptions:
throws java.io.IOException
private static java.lang.String getPreviousVersionString();
descriptor: ()Ljava/lang/String;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=4, args_size=0
0: ldc "SELECT release_version FROM system.%s WHERE key='%s'"
astore 0
start local 0 1: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "local"
aastore
dup
iconst_1
ldc "local"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 1
start local 1 2: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.isEmpty:()Z
ifne 3
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "release_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifne 10
3: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
ldc "system"
invokestatic org.apache.cassandra.db.Directories.getKSChildDirectories:(Ljava/lang/String;)Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 8
StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet top java.util.Iterator
StackMap stack:
4: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.io.File
astore 2
start local 2 5: aload 2
invokevirtual java.io.File.getName:()Ljava/lang/String;
ldc "Versions"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 8
aload 2
invokevirtual java.io.File.listFiles:()[Ljava/io/File;
arraylength
ifle 8
6: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "Found unreadable versions info in pre 1.2 system.Versions table"
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;)V
7: getstatic org.apache.cassandra.db.SystemKeyspace.UNREADABLE_VERSION:Lorg/apache/cassandra/utils/CassandraVersion;
invokevirtual org.apache.cassandra.utils.CassandraVersion.toString:()Ljava/lang/String;
areturn
end local 2 8: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
9: getstatic org.apache.cassandra.db.SystemKeyspace.NULL_VERSION:Lorg/apache/cassandra/utils/CassandraVersion;
invokevirtual org.apache.cassandra.utils.CassandraVersion.toString:()Ljava/lang/String;
areturn
10: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "release_version"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 11 0 req Ljava/lang/String;
2 11 1 result Lorg/apache/cassandra/cql3/UntypedResultSet;
5 8 2 dataDirectory Ljava/io/File;
public static void migrateDataDirs();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=0
0: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getAllDataFileLocations:()[Ljava/lang/String;
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
astore 0
start local 0 1: aload 0
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 2
goto 10
StackMap locals: java.lang.Iterable top java.util.Iterator
StackMap stack:
2: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 1
start local 1 3: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "Checking {} for legacy files"
aload 1
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;)V
4: new java.io.File
dup
aload 1
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
astore 3
start local 3 5: getstatic org.apache.cassandra.db.SystemKeyspace.$assertionsDisabled:Z
ifne 6
aload 3
invokevirtual java.io.File.exists:()Z
ifne 6
new java.lang.AssertionError
dup
new java.lang.StringBuilder
dup
invokespecial java.lang.StringBuilder.<init>:()V
aload 3
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
ldc " should have been created by startup checks"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
athrow
6: StackMap locals: java.lang.Iterable java.lang.String java.util.Iterator java.io.File
StackMap stack:
aload 3
invokevirtual java.io.File.toPath:()Ljava/nio/file/Path;
7: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
java/io/File.isDirectory()Z (5)
(Ljava/io/File;)Z
8: invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/SystemKeyspace.lambda$5(Ljava/io/File;)V (6)
(Ljava/io/File;)V
9: invokestatic org.apache.cassandra.io.util.FileUtils.visitDirectory:(Ljava/nio/file/Path;Ljava/util/function/Predicate;Ljava/util/function/Consumer;)V
end local 3 end local 1 10: StackMap locals: java.lang.Iterable top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
11: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 12 0 dirs Ljava/lang/Iterable<Ljava/lang/String;>;
3 10 1 dataDir Ljava/lang/String;
5 10 3 dir Ljava/io/File;
private static java.nio.ByteBuffer rangeToBytes(org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token>);
descriptor: (Lorg/apache/cassandra/dht/Range;)Ljava/nio/ByteBuffer;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=4, args_size=1
start local 0 0: aconst_null
astore 1
aconst_null
astore 2
1: new org.apache.cassandra.io.util.DataOutputBuffer
dup
invokespecial org.apache.cassandra.io.util.DataOutputBuffer.<init>:()V
astore 3
start local 3 2: getstatic org.apache.cassandra.dht.Range.tokenSerializer:Lorg/apache/cassandra/dht/IPartitionerDependentSerializer;
aload 0
aload 3
bipush 9
invokeinterface org.apache.cassandra.dht.IPartitionerDependentSerializer.serialize:(Ljava/lang/Object;Lorg/apache/cassandra/io/util/DataOutputPlus;I)V
3: aload 3
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.buffer:()Ljava/nio/ByteBuffer;
4: aload 3
ifnull 5
aload 3
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.close:()V
5: StackMap locals: org.apache.cassandra.dht.Range java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.util.DataOutputBuffer
StackMap stack: java.nio.ByteBuffer
areturn
StackMap locals:
StackMap stack: java.lang.Throwable
6: astore 1
7: aload 3
ifnull 8
aload 3
invokevirtual org.apache.cassandra.io.util.DataOutputBuffer.close:()V
end local 3 StackMap locals:
StackMap stack:
8: aload 1
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
9: astore 2
aload 1
ifnonnull 10
aload 2
astore 1
goto 11
StackMap locals:
StackMap stack:
10: aload 1
aload 2
if_acmpeq 11
aload 1
aload 2
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
11: aload 1
athrow
12: StackMap locals: org.apache.cassandra.dht.Range
StackMap stack: java.io.IOException
astore 1
start local 1 13: new java.io.IOError
dup
aload 1
invokespecial java.io.IOError.<init>:(Ljava/lang/Throwable;)V
athrow
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 range Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
2 8 3 out Lorg/apache/cassandra/io/util/DataOutputBuffer;
13 14 1 e Ljava/io/IOException;
Exception table:
from to target type
2 4 6 any
1 5 9 any
6 9 9 any
0 5 12 Class java.io.IOException
6 12 12 Class java.io.IOException
Signature: (Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;)Ljava/nio/ByteBuffer;
MethodParameters:
Name Flags
range
private static org.apache.cassandra.dht.Range<org.apache.cassandra.dht.Token> byteBufferToRange(java.nio.ByteBuffer, org.apache.cassandra.dht.IPartitioner);
descriptor: (Ljava/nio/ByteBuffer;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/dht/Range;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.dht.Range.tokenSerializer:Lorg/apache/cassandra/dht/IPartitionerDependentSerializer;
aload 0
invokestatic org.apache.cassandra.utils.ByteBufferUtil.getArray:(Ljava/nio/ByteBuffer;)[B
invokestatic com.google.common.io.ByteStreams.newDataInput:([B)Lcom/google/common/io/ByteArrayDataInput;
1: aload 1
2: bipush 9
3: invokeinterface org.apache.cassandra.dht.IPartitionerDependentSerializer.deserialize:(Ljava/io/DataInput;Lorg/apache/cassandra/dht/IPartitioner;I)Ljava/lang/Object;
checkcast org.apache.cassandra.dht.Range
4: areturn
5: StackMap locals:
StackMap stack: java.io.IOException
astore 2
start local 2 6: new java.io.IOError
dup
aload 2
invokespecial java.io.IOError.<init>:(Ljava/lang/Throwable;)V
athrow
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 rawRange Ljava/nio/ByteBuffer;
0 7 1 partitioner Lorg/apache/cassandra/dht/IPartitioner;
6 7 2 e Ljava/io/IOException;
Exception table:
from to target type
0 4 5 Class java.io.IOException
Signature: (Ljava/nio/ByteBuffer;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
MethodParameters:
Name Flags
rawRange
partitioner
public static void writePreparedStatement(java.lang.String, org.apache.cassandra.utils.MD5Digest, java.lang.String);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/utils/MD5Digest;Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=3, args_size=3
start local 0 start local 1 start local 2 0: ldc "INSERT INTO %s.%s (logged_keyspace, prepared_id, query_string) VALUES (?, ?, ?)"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
ldc "prepared_statements"
aastore
2: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_3
anewarray java.lang.Object
dup
iconst_0
3: aload 0
aastore
dup
iconst_1
aload 1
invokevirtual org.apache.cassandra.utils.MD5Digest.byteBuffer:()Ljava/nio/ByteBuffer;
aastore
dup
iconst_2
aload 2
aastore
4: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
5: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "stored prepared statement for logged keyspace '{}': '{}'"
aload 0
aload 2
invokeinterface org.slf4j.Logger.debug:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 loggedKeyspace Ljava/lang/String;
0 7 1 key Lorg/apache/cassandra/utils/MD5Digest;
0 7 2 cql Ljava/lang/String;
MethodParameters:
Name Flags
loggedKeyspace
key
cql
public static void removePreparedStatement(org.apache.cassandra.utils.MD5Digest);
descriptor: (Lorg/apache/cassandra/utils/MD5Digest;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=1, args_size=1
start local 0 0: ldc "DELETE FROM %s.%s WHERE prepared_id = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
ldc "prepared_statements"
aastore
2: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_1
anewarray java.lang.Object
dup
iconst_0
3: aload 0
invokevirtual org.apache.cassandra.utils.MD5Digest.byteBuffer:()Ljava/nio/ByteBuffer;
aastore
4: invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 key Lorg/apache/cassandra/utils/MD5Digest;
MethodParameters:
Name Flags
key
public static void resetPreparedStatements();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=0
0: ldc "system"
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
ldc "prepared_statements"
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
astore 0
start local 0 1: aload 0
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.truncateBlocking:()V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 3 0 availableRanges Lorg/apache/cassandra/db/ColumnFamilyStore;
public static java.util.List<org.apache.cassandra.utils.Pair<java.lang.String, java.lang.String>> loadPreparedStatements();
descriptor: ()Ljava/util/List;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=5, args_size=0
0: ldc "SELECT logged_keyspace, query_string FROM %s.%s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "prepared_statements"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 0
start local 0 1: aload 0
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeOnceInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 1
start local 1 2: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 3: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 4
goto 9
StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet java.util.List top java.util.Iterator
StackMap stack:
4: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 3
start local 3 5: aload 2
aload 3
ldc "logged_keyspace"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 6
aload 3
ldc "logged_keyspace"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
goto 7
StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet java.util.List org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator
StackMap stack: java.util.List
6: aconst_null
7: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet java.util.List org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator
StackMap stack: java.util.List java.lang.String
aload 3
ldc "query_string"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
8: invokestatic org.apache.cassandra.utils.Pair.create:(Ljava/lang/Object;Ljava/lang/Object;)Lorg/apache/cassandra/utils/Pair;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 3 9: StackMap locals: java.lang.String org.apache.cassandra.cql3.UntypedResultSet java.util.List top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
10: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 11 0 query Ljava/lang/String;
2 11 1 resultSet Lorg/apache/cassandra/cql3/UntypedResultSet;
3 11 2 r Ljava/util/List<Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/String;>;>;
5 9 3 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
Signature: ()Ljava/util/List<Lorg/apache/cassandra/utils/Pair<Ljava/lang/String;Ljava/lang/String;>;>;
private static void lambda$0(java.lang.String, java.net.InetAddress, java.util.Collection);
descriptor: (Ljava/lang/String;Ljava/net/InetAddress;Ljava/util/Collection;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=3, args_size=3
0: aload 0
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "peers"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 2
invokestatic org.apache.cassandra.db.SystemKeyspace.tokensAsSet:(Ljava/util/Collection;)Ljava/util/Set;
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
return
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$1(java.lang.String, java.lang.String, java.net.InetAddress, java.lang.Object);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/net/InetAddress;Ljava/lang/Object;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=4
0: aload 0
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "peers"
aastore
dup
iconst_1
aload 1
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 2
aastore
dup
iconst_1
aload 3
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
return
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$2(java.lang.String, java.net.InetAddress, java.lang.Object, java.lang.Runnable);
descriptor: (Ljava/lang/String;Ljava/net/InetAddress;Ljava/lang/Object;Ljava/lang/Runnable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=4
0: aload 0
iconst_1
anewarray java.lang.Object
dup
iconst_0
ldc "peers"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 2
aastore
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
pop
1: aload 3
invokeinterface java.lang.Runnable.run:()V
2: return
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.String lambda$3(org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Ljava/lang/String;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
ldc "index_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 r Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
private static void lambda$5(java.io.File);
descriptor: (Ljava/io/File;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "Checking {} for legacy files"
aload 0
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
1: aload 0
invokevirtual java.io.File.toPath:()Ljava/nio/file/Path;
2: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
java/io/File.isDirectory()Z (5)
(Ljava/io/File;)Z
3: invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/SystemKeyspace.lambda$7(Ljava/io/File;)V (6)
(Ljava/io/File;)V
4: invokestatic org.apache.cassandra.io.util.FileUtils.visitDirectory:(Ljava/nio/file/Path;Ljava/util/function/Predicate;Ljava/util/function/Consumer;)V
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 ksdir Ljava/io/File;
private static void lambda$7(java.io.File);
descriptor: (Ljava/io/File;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.db.SystemKeyspace.logger:Lorg/slf4j/Logger;
ldc "Checking {} for legacy files"
aload 0
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
1: aload 0
invokestatic org.apache.cassandra.io.sstable.Descriptor.isLegacyFile:(Ljava/io/File;)Z
ifeq 4
2: aload 0
invokestatic org.apache.cassandra.io.util.FileUtils.deleteRecursive:(Ljava/io/File;)V
3: goto 7
4: StackMap locals:
StackMap stack:
aload 0
invokevirtual java.io.File.toPath:()Ljava/nio/file/Path;
5: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/io/sstable/Descriptor.isLegacyFile(Ljava/io/File;)Z (6)
(Ljava/io/File;)Z
invokedynamic accept()Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/db/SystemKeyspace.lambda$10(Ljava/io/File;)V (6)
(Ljava/io/File;)V
6: invokestatic org.apache.cassandra.io.util.FileUtils.visitDirectory:(Ljava/nio/file/Path;Ljava/util/function/Predicate;Ljava/util/function/Consumer;)V
7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 cfdir Ljava/io/File;
private static void lambda$10(java.io.File);
descriptor: (Ljava/io/File;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: iconst_1
anewarray java.io.File
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.io.util.FileUtils.delete:([Ljava/io/File;)V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 arg0 Ljava/io/File;
}
SourceFile: "SystemKeyspace.java"
NestMembers:
org.apache.cassandra.db.SystemKeyspace$BootstrapState
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map
public Row = org.apache.cassandra.cql3.UntypedResultSet$Row of org.apache.cassandra.cql3.UntypedResultSet
public final BootstrapState = org.apache.cassandra.db.SystemKeyspace$BootstrapState of org.apache.cassandra.db.SystemKeyspace
public CommitLogPositionSerializer = org.apache.cassandra.db.commitlog.CommitLogPosition$CommitLogPositionSerializer of org.apache.cassandra.db.commitlog.CommitLogPosition
public abstract SimpleBuilder = org.apache.cassandra.db.rows.Row$SimpleBuilder of org.apache.cassandra.db.rows.Row
public abstract TokenFactory = org.apache.cassandra.dht.Token$TokenFactory of org.apache.cassandra.dht.Token
public final Builder = org.apache.cassandra.schema.Functions$Builder of org.apache.cassandra.schema.Functions
SystemKeyspace
logger: Logger
$assertionsDisabled: boolean
