public final class org.apache.cassandra.schema.LegacySchemaMigrator
minor version: 0
major version: 59
flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
this_class: org.apache.cassandra.schema.LegacySchemaMigrator
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
static final java.util.List<org.apache.cassandra.config.CFMetaData> LegacySchemaTables;
descriptor: Ljava/util/List;
flags: (0x0018) ACC_STATIC, ACC_FINAL
Signature: Ljava/util/List<Lorg/apache/cassandra/config/CFMetaData;>;
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=7, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/schema/LegacySchemaMigrator;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.schema.LegacySchemaMigrator.logger:Lorg/slf4j/Logger;
1: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyKeyspaces:Lorg/apache/cassandra/config/CFMetaData;
2: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyColumnfamilies:Lorg/apache/cassandra/config/CFMetaData;
3: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyColumns:Lorg/apache/cassandra/config/CFMetaData;
4: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyTriggers:Lorg/apache/cassandra/config/CFMetaData;
5: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyUsertypes:Lorg/apache/cassandra/config/CFMetaData;
6: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyFunctions:Lorg/apache/cassandra/config/CFMetaData;
7: getstatic org.apache.cassandra.db.SystemKeyspace.LegacyAggregates:Lorg/apache/cassandra/config/CFMetaData;
8: invokestatic com.google.common.collect.ImmutableList.of:(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)Lcom/google/common/collect/ImmutableList;
9: putstatic org.apache.cassandra.schema.LegacySchemaMigrator.LegacySchemaTables:Ljava/util/List;
10: 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/schema/LegacySchemaMigrator;
public static void migrate();
descriptor: ()V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=1, args_size=0
0: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readSchema:()Ljava/util/Collection;
astore 0
start local 0 1: aload 0
invokeinterface java.util.Collection.isEmpty:()Z
ifeq 4
2: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.unloadLegacySchemaTables:()V
3: return
4: StackMap locals: java.util.Collection
StackMap stack:
getstatic org.apache.cassandra.schema.LegacySchemaMigrator.logger:Lorg/slf4j/Logger;
ldc "Moving {} keyspaces from legacy schema tables to the new schema keyspace ({})"
5: aload 0
invokeinterface java.util.Collection.size:()I
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
6: ldc "system_schema"
7: invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
8: aload 0
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/schema/LegacySchemaMigrator.storeKeyspaceInNewSchemaTables(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;)V (6)
(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
9: aload 0
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/schema/LegacySchemaMigrator.migrateBuiltIndexesForKeyspace(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;)V (6)
(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
10: invokestatic org.apache.cassandra.schema.SchemaKeyspace.flush:()V
11: getstatic org.apache.cassandra.schema.LegacySchemaMigrator.logger:Lorg/slf4j/Logger;
ldc "Truncating legacy schema tables"
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
12: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.truncateLegacySchemaTables:()V
13: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.unloadLegacySchemaTables:()V
14: getstatic org.apache.cassandra.schema.LegacySchemaMigrator.logger:Lorg/slf4j/Logger;
ldc "Completed migration of legacy schema tables"
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;)V
15: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
1 16 0 keyspaces Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;>;
private static void migrateBuiltIndexesForKeyspace(org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace);
descriptor: (Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.tables:Ljava/util/Collection;
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/schema/LegacySchemaMigrator.migrateBuiltIndexesForTable(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;)V (6)
(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 keyspace Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;
MethodParameters:
Name Flags
keyspace
private static void migrateBuiltIndexesForTable(org.apache.cassandra.schema.LegacySchemaMigrator$Table);
descriptor: (Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Table.metadata:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.getIndexes:()Lorg/apache/cassandra/schema/Indexes;
aload 0
invokedynamic accept(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;)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/schema/LegacySchemaMigrator.lambda$3(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;Lorg/apache/cassandra/schema/IndexMetadata;)V (6)
(Lorg/apache/cassandra/schema/IndexMetadata;)V
invokevirtual org.apache.cassandra.schema.Indexes.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 table Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;
MethodParameters:
Name Flags
table
private static void migrateIndexBuildStatus(java.lang.String, java.lang.String, org.apache.cassandra.schema.IndexMetadata);
descriptor: (Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/schema/IndexMetadata;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
new java.lang.StringBuilder
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
bipush 46
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
aload 2
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.SystemKeyspace.isIndexBuilt:(Ljava/lang/String;Ljava/lang/String;)Z
ifeq 3
1: aload 0
aload 2
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokestatic org.apache.cassandra.db.SystemKeyspace.setIndexBuilt:(Ljava/lang/String;Ljava/lang/String;)V
2: aload 0
new java.lang.StringBuilder
dup
aload 1
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
bipush 46
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
aload 2
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokestatic org.apache.cassandra.db.SystemKeyspace.setIndexRemoved:(Ljava/lang/String;Ljava/lang/String;)V
3: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 keyspace Ljava/lang/String;
0 4 1 table Ljava/lang/String;
0 4 2 index Lorg/apache/cassandra/schema/IndexMetadata;
MethodParameters:
Name Flags
keyspace
table
index
static void unloadLegacySchemaTables();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=3, locals=4, args_size=0
0: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
ldc "system"
invokevirtual org.apache.cassandra.config.Schema.getKSMetaData:(Ljava/lang/String;)Lorg/apache/cassandra/schema/KeyspaceMetadata;
astore 0
start local 0 1: aload 0
getfield org.apache.cassandra.schema.KeyspaceMetadata.tables:Lorg/apache/cassandra/schema/Tables;
astore 1
start local 1 2: getstatic org.apache.cassandra.schema.LegacySchemaMigrator.LegacySchemaTables:Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 3
goto 5
StackMap locals: org.apache.cassandra.schema.KeyspaceMetadata org.apache.cassandra.schema.Tables top java.util.Iterator
StackMap stack:
3: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.config.CFMetaData
astore 2
start local 2 4: aload 1
aload 2
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
invokevirtual org.apache.cassandra.schema.Tables.without:(Ljava/lang/String;)Lorg/apache/cassandra/schema/Tables;
astore 1
end local 2 5: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: getstatic org.apache.cassandra.schema.LegacySchemaMigrator.LegacySchemaTables:Ljava/util/List;
getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Lorg/apache/cassandra/config/Schema;)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/config/Schema.unload(Lorg/apache/cassandra/config/CFMetaData;)V (5)
(Lorg/apache/cassandra/config/CFMetaData;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
7: getstatic org.apache.cassandra.schema.LegacySchemaMigrator.LegacySchemaTables:Ljava/util/List;
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/schema/LegacySchemaMigrator.lambda$5(Lorg/apache/cassandra/config/CFMetaData;)V (6)
(Lorg/apache/cassandra/config/CFMetaData;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
8: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
aload 0
aload 1
invokevirtual org.apache.cassandra.schema.KeyspaceMetadata.withSwapped:(Lorg/apache/cassandra/schema/Tables;)Lorg/apache/cassandra/schema/KeyspaceMetadata;
invokevirtual org.apache.cassandra.config.Schema.setKeyspaceMetadata:(Lorg/apache/cassandra/schema/KeyspaceMetadata;)V
9: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 10 0 systemKeyspace Lorg/apache/cassandra/schema/KeyspaceMetadata;
2 10 1 systemTables Lorg/apache/cassandra/schema/Tables;
4 5 2 table Lorg/apache/cassandra/config/CFMetaData;
private static void truncateLegacySchemaTables();
descriptor: ()V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=0, args_size=0
0: getstatic org.apache.cassandra.schema.LegacySchemaMigrator.LegacySchemaTables:Ljava/util/List;
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/schema/LegacySchemaMigrator.lambda$6(Lorg/apache/cassandra/config/CFMetaData;)V (6)
(Lorg/apache/cassandra/config/CFMetaData;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
1: return
LocalVariableTable:
Start End Slot Name Signature
private static void storeKeyspaceInNewSchemaTables(org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace);
descriptor: (Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=4, args_size=1
start local 0 0: getstatic org.apache.cassandra.schema.LegacySchemaMigrator.logger:Lorg/slf4j/Logger;
ldc "Migrating keyspace {}"
aload 0
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
1: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.name:Ljava/lang/String;
aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.params:Lorg/apache/cassandra/schema/KeyspaceParams;
aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.timestamp:J
invokestatic org.apache.cassandra.schema.SchemaKeyspace.makeCreateKeyspaceMutation:(Ljava/lang/String;Lorg/apache/cassandra/schema/KeyspaceParams;J)Lorg/apache/cassandra/db/Mutation$SimpleBuilder;
astore 1
start local 1 2: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.tables:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 5
StackMap locals: org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace org.apache.cassandra.db.Mutation$SimpleBuilder top java.util.Iterator
StackMap stack:
3: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.schema.LegacySchemaMigrator$Table
astore 2
start local 2 4: aload 2
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Table.metadata:Lorg/apache/cassandra/config/CFMetaData;
iconst_1
aload 1
aload 2
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Table.timestamp:J
invokeinterface org.apache.cassandra.db.Mutation$SimpleBuilder.timestamp:(J)Lorg/apache/cassandra/db/Mutation$SimpleBuilder;
invokestatic org.apache.cassandra.schema.SchemaKeyspace.addTableToSchemaMutation:(Lorg/apache/cassandra/config/CFMetaData;ZLorg/apache/cassandra/db/Mutation$SimpleBuilder;)V
end local 2 5: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 3
6: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.types:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 9
StackMap locals:
StackMap stack:
7: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.schema.LegacySchemaMigrator$Type
astore 2
start local 2 8: aload 2
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Type.metadata:Lorg/apache/cassandra/db/marshal/UserType;
aload 1
aload 2
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Type.timestamp:J
invokeinterface org.apache.cassandra.db.Mutation$SimpleBuilder.timestamp:(J)Lorg/apache/cassandra/db/Mutation$SimpleBuilder;
invokestatic org.apache.cassandra.schema.SchemaKeyspace.addTypeToSchemaMutation:(Lorg/apache/cassandra/db/marshal/UserType;Lorg/apache/cassandra/db/Mutation$SimpleBuilder;)V
end local 2 9: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 7
10: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.functions:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 13
StackMap locals:
StackMap stack:
11: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.schema.LegacySchemaMigrator$Function
astore 2
start local 2 12: aload 2
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Function.metadata:Lorg/apache/cassandra/cql3/functions/UDFunction;
aload 1
aload 2
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Function.timestamp:J
invokeinterface org.apache.cassandra.db.Mutation$SimpleBuilder.timestamp:(J)Lorg/apache/cassandra/db/Mutation$SimpleBuilder;
invokestatic org.apache.cassandra.schema.SchemaKeyspace.addFunctionToSchemaMutation:(Lorg/apache/cassandra/cql3/functions/UDFunction;Lorg/apache/cassandra/db/Mutation$SimpleBuilder;)V
end local 2 13: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
14: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.aggregates:Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 17
StackMap locals:
StackMap stack:
15: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate
astore 2
start local 2 16: aload 2
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate.metadata:Lorg/apache/cassandra/cql3/functions/UDAggregate;
aload 1
aload 2
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate.timestamp:J
invokeinterface org.apache.cassandra.db.Mutation$SimpleBuilder.timestamp:(J)Lorg/apache/cassandra/db/Mutation$SimpleBuilder;
invokestatic org.apache.cassandra.schema.SchemaKeyspace.addAggregateToSchemaMutation:(Lorg/apache/cassandra/cql3/functions/UDAggregate;Lorg/apache/cassandra/db/Mutation$SimpleBuilder;)V
end local 2 17: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 15
18: aload 1
invokeinterface org.apache.cassandra.db.Mutation$SimpleBuilder.build:()Lorg/apache/cassandra/db/Mutation;
invokevirtual org.apache.cassandra.db.Mutation.apply:()V
19: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 keyspace Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;
2 20 1 builder Lorg/apache/cassandra/db/Mutation$SimpleBuilder;
4 5 2 table Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;
8 9 2 type Lorg/apache/cassandra/schema/LegacySchemaMigrator$Type;
12 13 2 function Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;
16 17 2 aggregate Lorg/apache/cassandra/schema/LegacySchemaMigrator$Aggregate;
MethodParameters:
Name Flags
keyspace
private static java.util.Collection<org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace> readSchema();
descriptor: ()Ljava/util/Collection;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=3, args_size=0
0: ldc "SELECT keyspace_name FROM %s.%s"
iconst_2
anewarray java.lang.Object
dup
iconst_0
ldc "system"
aastore
dup
iconst_1
ldc "schema_keyspaces"
aastore
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 0
start local 0 1: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 1
start local 1 2: aload 0
iconst_0
anewarray java.lang.Object
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
aload 1
invokedynamic accept(Ljava/util/Collection;)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/schema/LegacySchemaMigrator.lambda$7(Ljava/util/Collection;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V (6)
(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.forEach:(Ljava/util/function/Consumer;)V
3: aload 1
getstatic org.apache.cassandra.config.SchemaConstants.LOCAL_SYSTEM_KEYSPACE_NAMES:Ljava/util/Set;
invokeinterface java.util.Collection.removeAll:(Ljava/util/Collection;)Z
pop
4: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 5: aload 1
aload 2
invokedynamic accept(Ljava/util/Collection;)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/schema/LegacySchemaMigrator.lambda$8(Ljava/util/Collection;Ljava/lang/String;)V (6)
(Ljava/lang/String;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
6: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 7 0 query Ljava/lang/String;
2 7 1 keyspaceNames Ljava/util/Collection<Ljava/lang/String;>;
5 7 2 keyspaces Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;>;
Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;>;
private static org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace readKeyspace(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=10, locals=9, args_size=1
start local 0 0: aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readKeyspaceTimestamp:(Ljava/lang/String;)J
lstore 1
start local 1 1: aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readKeyspaceParams:(Ljava/lang/String;)Lorg/apache/cassandra/schema/KeyspaceParams;
astore 3
start local 3 2: aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readTables:(Ljava/lang/String;)Ljava/util/Collection;
astore 4
start local 4 3: aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readTypes:(Ljava/lang/String;)Ljava/util/Collection;
astore 5
start local 5 4: aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readFunctions:(Ljava/lang/String;)Ljava/util/Collection;
astore 6
start local 6 5: invokestatic org.apache.cassandra.schema.Functions.builder:()Lorg/apache/cassandra/schema/Functions$Builder;
astore 7
start local 7 6: aload 6
aload 7
invokedynamic accept(Lorg/apache/cassandra/schema/Functions$Builder;)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/schema/LegacySchemaMigrator.lambda$9(Lorg/apache/cassandra/schema/Functions$Builder;Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;)V (6)
(Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
7: aload 7
invokevirtual org.apache.cassandra.schema.Functions$Builder.build:()Lorg/apache/cassandra/schema/Functions;
aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readAggregates:(Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;)Ljava/util/Collection;
astore 8
start local 8 8: new org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace
dup
lload 1
aload 0
aload 3
aload 4
aload 5
aload 6
aload 8
invokespecial org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace.<init>:(JLjava/lang/String;Lorg/apache/cassandra/schema/KeyspaceParams;Ljava/util/Collection;Ljava/util/Collection;Ljava/util/Collection;Ljava/util/Collection;)V
areturn
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 keyspaceName Ljava/lang/String;
1 9 1 timestamp J
2 9 3 params Lorg/apache/cassandra/schema/KeyspaceParams;
3 9 4 tables Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;>;
4 9 5 types Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Type;>;
5 9 6 functions Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;>;
6 9 7 functionsBuilder Lorg/apache/cassandra/schema/Functions$Builder;
8 9 8 aggregates Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Aggregate;>;
MethodParameters:
Name Flags
keyspaceName
private static long readKeyspaceTimestamp(java.lang.String);
descriptor: (Ljava/lang/String;)J
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=2, args_size=1
start local 0 0: ldc "SELECT writeTime(durable_writes) AS timestamp FROM %s.%s WHERE keyspace_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_keyspaces"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 1
start local 1 4: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "timestamp"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getLong:(Ljava/lang/String;)J
lreturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 keyspaceName Ljava/lang/String;
4 5 1 query Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
private static org.apache.cassandra.schema.KeyspaceParams readKeyspaceParams(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/schema/KeyspaceParams;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=5, args_size=1
start local 0 0: ldc "SELECT * FROM %s.%s WHERE keyspace_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_keyspaces"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 1
start local 1 4: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 2
start local 2 5: aload 2
ldc "durable_writes"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getBoolean:(Ljava/lang/String;)Z
istore 3
start local 3 6: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 4
start local 4 7: aload 4
aload 2
ldc "strategy_options"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.utils.FBUtilities.fromJsonMap:(Ljava/lang/String;)Ljava/util/Map;
invokeinterface java.util.Map.putAll:(Ljava/util/Map;)V
8: aload 4
ldc "class"
aload 2
ldc "strategy_class"
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
9: iload 3
aload 4
invokestatic org.apache.cassandra.schema.KeyspaceParams.create:(ZLjava/util/Map;)Lorg/apache/cassandra/schema/KeyspaceParams;
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 keyspaceName Ljava/lang/String;
4 10 1 query Ljava/lang/String;
5 10 2 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
6 10 3 durableWrites Z
7 10 4 replication Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
MethodParameters:
Name Flags
keyspaceName
private static java.util.Collection<org.apache.cassandra.schema.LegacySchemaMigrator$Table> readTables(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/Collection;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=4, args_size=1
start local 0 0: ldc "SELECT columnfamily_name FROM %s.%s WHERE keyspace_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_columnfamilies"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 1
start local 1 4: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 5: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
aload 2
invokedynamic accept(Ljava/util/Collection;)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/schema/LegacySchemaMigrator.lambda$10(Ljava/util/Collection;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V (6)
(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.forEach:(Ljava/util/function/Consumer;)V
6: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 7: aload 2
aload 3
aload 0
invokedynamic accept(Ljava/util/Collection;Ljava/lang/String;)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/schema/LegacySchemaMigrator.lambda$11(Ljava/util/Collection;Ljava/lang/String;Ljava/lang/String;)V (6)
(Ljava/lang/String;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
8: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 keyspaceName Ljava/lang/String;
4 9 1 query Ljava/lang/String;
5 9 2 tableNames Ljava/util/Collection<Ljava/lang/String;>;
7 9 3 tables Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;>;
Signature: (Ljava/lang/String;)Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;>;
MethodParameters:
Name Flags
keyspaceName
private static org.apache.cassandra.schema.LegacySchemaMigrator$Table readTable(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readTableTimestamp:(Ljava/lang/String;Ljava/lang/String;)J
lstore 2
start local 2 1: aload 0
aload 1
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readTableMetadata:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
astore 4
start local 4 2: new org.apache.cassandra.schema.LegacySchemaMigrator$Table
dup
lload 2
aload 4
invokespecial org.apache.cassandra.schema.LegacySchemaMigrator$Table.<init>:(JLorg/apache/cassandra/config/CFMetaData;)V
areturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 keyspaceName Ljava/lang/String;
0 3 1 tableName Ljava/lang/String;
1 3 2 timestamp J
2 3 4 metadata Lorg/apache/cassandra/config/CFMetaData;
MethodParameters:
Name Flags
keyspaceName
tableName
private static long readTableTimestamp(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)J
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=3, args_size=2
start local 0 start local 1 0: ldc "SELECT writeTime(type) AS timestamp FROM %s.%s WHERE keyspace_name = ? AND columnfamily_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_columnfamilies"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 2
start local 2 4: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "timestamp"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getLong:(Ljava/lang/String;)J
lreturn
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 tableName Ljava/lang/String;
4 5 2 query Ljava/lang/String;
MethodParameters:
Name Flags
keyspaceName
tableName
private static org.apache.cassandra.config.CFMetaData readTableMetadata(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=8, args_size=2
start local 0 start local 1 0: ldc "SELECT * FROM %s.%s WHERE keyspace_name = ? AND columnfamily_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_columnfamilies"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 2
start local 2 4: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 3
start local 3 5: ldc "SELECT * FROM %s.%s WHERE keyspace_name = ? AND columnfamily_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
6: ldc "system"
aastore
dup
iconst_1
7: ldc "schema_columns"
aastore
8: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 4
start local 4 9: aload 4
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 5
start local 5 10: ldc "SELECT * FROM %s.%s WHERE keyspace_name = ? AND columnfamily_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
11: ldc "system"
aastore
dup
iconst_1
12: ldc "schema_triggers"
aastore
13: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 6
start local 6 14: aload 6
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
astore 7
start local 7 15: aload 1
aload 3
aload 5
aload 7
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.decodeTableMetadata:(Ljava/lang/String;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;Lorg/apache/cassandra/cql3/UntypedResultSet;Lorg/apache/cassandra/cql3/UntypedResultSet;)Lorg/apache/cassandra/config/CFMetaData;
areturn
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 16 0 keyspaceName Ljava/lang/String;
0 16 1 tableName Ljava/lang/String;
4 16 2 tableQuery Ljava/lang/String;
5 16 3 tableRow Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
9 16 4 columnsQuery Ljava/lang/String;
10 16 5 columnRows Lorg/apache/cassandra/cql3/UntypedResultSet;
14 16 6 triggersQuery Ljava/lang/String;
15 16 7 triggerRows Lorg/apache/cassandra/cql3/UntypedResultSet;
MethodParameters:
Name Flags
keyspaceName
tableName
private static org.apache.cassandra.config.CFMetaData decodeTableMetadata(java.lang.String, org.apache.cassandra.cql3.UntypedResultSet$Row, org.apache.cassandra.cql3.UntypedResultSet, org.apache.cassandra.cql3.UntypedResultSet);
descriptor: (Ljava/lang/String;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;Lorg/apache/cassandra/cql3/UntypedResultSet;Lorg/apache/cassandra/cql3/UntypedResultSet;)Lorg/apache/cassandra/config/CFMetaData;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=10, locals=22, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
ldc "keyspace_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 4
start local 4 1: aload 1
ldc "columnfamily_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 5
start local 5 2: aload 1
ldc "comparator"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.db.marshal.TypeParser.parse:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
astore 6
start local 6 3: aload 1
ldc "subcomparator"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 4
aload 1
ldc "subcomparator"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.db.marshal.TypeParser.parse:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
goto 5
StackMap locals: java.lang.String java.lang.String org.apache.cassandra.db.marshal.AbstractType
StackMap stack:
4: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.db.marshal.AbstractType
5: astore 7
start local 7 6: ldc "super"
aload 1
ldc "type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
getstatic java.util.Locale.ENGLISH:Ljava/util/Locale;
invokevirtual java.lang.String.toLowerCase:(Ljava/util/Locale;)Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
istore 8
start local 8 7: aload 6
instanceof org.apache.cassandra.db.marshal.CompositeType
ifne 8
iload 8
ifne 8
iconst_0
goto 9
StackMap locals: org.apache.cassandra.db.marshal.AbstractType int
StackMap stack:
8: iconst_1
StackMap locals:
StackMap stack: int
9: istore 9
start local 9 10: aload 1
ldc "is_dense"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 11
aload 1
ldc "is_dense"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getBoolean:(Ljava/lang/String;)Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
goto 12
StackMap locals: int
StackMap stack:
11: aconst_null
StackMap locals:
StackMap stack: java.lang.Boolean
12: astore 10
start local 10 13: aload 10
ifnull 16
aload 10
invokevirtual java.lang.Boolean.booleanValue:()Z
ifne 16
14: iconst_0
istore 11
start local 11 15: goto 17
end local 11 16: StackMap locals: java.lang.Boolean
StackMap stack:
aload 6
aload 2
iload 8
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.calculateIsDense:(Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/cql3/UntypedResultSet;Z)Z
istore 11
start local 11 17: StackMap locals: int
StackMap stack:
iload 11
ifne 19
aload 10
ifnull 18
aload 10
invokevirtual java.lang.Boolean.booleanValue:()Z
ifeq 19
18: StackMap locals:
StackMap stack:
aload 2
iload 8
iload 9
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.filterOutRedundantRowsForSparse:(Lorg/apache/cassandra/cql3/UntypedResultSet;ZZ)Ljava/lang/Iterable;
goto 20
19: StackMap locals:
StackMap stack:
aload 2
20: StackMap locals:
StackMap stack: java.lang.Iterable
astore 12
start local 12 21: aload 1
ldc "default_validator"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.db.marshal.TypeParser.parse:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
astore 13
start local 13 22: aload 13
instanceof org.apache.cassandra.db.marshal.CounterColumnType
istore 14
start local 14 23: aload 1
ldc "cf_id"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 25
24: aload 1
ldc "cf_id"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getUUID:(Ljava/lang/String;)Ljava/util/UUID;
goto 26
25: StackMap locals: java.lang.Iterable org.apache.cassandra.db.marshal.AbstractType int
StackMap stack:
aload 4
aload 5
invokestatic org.apache.cassandra.config.CFMetaData.generateLegacyCfId:(Ljava/lang/String;Ljava/lang/String;)Ljava/util/UUID;
26: StackMap locals:
StackMap stack: java.util.UUID
astore 15
start local 15 27: iload 8
ifne 28
iload 11
ifne 28
iload 9
ifeq 28
iconst_1
goto 29
StackMap locals: java.util.UUID
StackMap stack:
28: iconst_0
StackMap locals:
StackMap stack: int
29: istore 16
start local 16 30: iload 11
ifne 31
iload 9
ifne 31
iconst_1
goto 32
StackMap locals: int
StackMap stack:
31: iconst_0
StackMap locals:
StackMap stack: int
32: istore 17
start local 17 33: iload 16
ifne 34
aload 12
iload 8
iload 17
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.checkNeedsUpgrade:(Ljava/lang/Iterable;ZZ)Z
ifeq 34
iconst_1
goto 35
StackMap locals: int
StackMap stack:
34: iconst_0
StackMap locals:
StackMap stack: int
35: istore 18
start local 18 36: aload 12
37: aload 4
38: aload 5
39: aload 6
40: aload 7
41: iload 8
42: iload 16
43: iload 17
44: iload 18
45: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.createColumnsFromColumnRows:(Ljava/lang/Iterable;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;ZZZZ)Ljava/util/List;
astore 19
start local 19 46: iload 18
ifeq 56
47: aload 19
48: aload 4
49: aload 5
50: iload 17
51: iload 8
52: aload 6
53: aload 7
54: aload 13
55: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.addDefinitionForUpgrade:(Ljava/util/List;Ljava/lang/String;Ljava/lang/String;ZZLorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;)V
56: StackMap locals: int java.util.List
StackMap stack:
aload 4
57: aload 5
58: aload 15
59: iload 11
60: iload 9
61: iload 8
62: iload 14
63: iconst_0
64: aload 19
65: invokestatic org.apache.cassandra.config.DatabaseDescriptor.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
66: invokestatic org.apache.cassandra.config.CFMetaData.create:(Ljava/lang/String;Ljava/lang/String;Ljava/util/UUID;ZZZZZLjava/util/List;Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/config/CFMetaData;
astore 20
start local 20 67: aload 20
68: aload 12
69: aload 4
70: aload 5
71: aload 6
72: aload 7
73: iload 8
74: iload 16
75: iload 17
76: iload 18
77: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.createIndexesFromColumnRows:(Lorg/apache/cassandra/config/CFMetaData;Ljava/lang/Iterable;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;ZZZZ)Lorg/apache/cassandra/schema/Indexes;
astore 21
start local 21 78: aload 20
aload 21
invokevirtual org.apache.cassandra.config.CFMetaData.indexes:(Lorg/apache/cassandra/schema/Indexes;)Lorg/apache/cassandra/config/CFMetaData;
pop
79: aload 1
ldc "dropped_columns"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 81
80: aload 20
aload 6
aload 1
ldc "dropped_columns"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
getstatic org.apache.cassandra.db.marshal.LongType.instance:Lorg/apache/cassandra/db/marshal/LongType;
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;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.addDroppedColumns:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/marshal/AbstractType;Ljava/util/Map;)V
81: StackMap locals: org.apache.cassandra.config.CFMetaData org.apache.cassandra.schema.Indexes
StackMap stack:
aload 20
aload 1
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.decodeTableParams:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/schema/TableParams;
invokevirtual org.apache.cassandra.config.CFMetaData.params:(Lorg/apache/cassandra/schema/TableParams;)Lorg/apache/cassandra/config/CFMetaData;
82: aload 3
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.createTriggersFromTriggerRows:(Lorg/apache/cassandra/cql3/UntypedResultSet;)Lorg/apache/cassandra/schema/Triggers;
invokevirtual org.apache.cassandra.config.CFMetaData.triggers:(Lorg/apache/cassandra/schema/Triggers;)Lorg/apache/cassandra/config/CFMetaData;
83: areturn
end local 21 end local 20 end local 19 end local 18 end local 17 end local 16 end local 15 end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 84 0 tableName Ljava/lang/String;
0 84 1 tableRow Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
0 84 2 columnRows Lorg/apache/cassandra/cql3/UntypedResultSet;
0 84 3 triggerRows Lorg/apache/cassandra/cql3/UntypedResultSet;
1 84 4 ksName Ljava/lang/String;
2 84 5 cfName Ljava/lang/String;
3 84 6 rawComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
6 84 7 subComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
7 84 8 isSuper Z
10 84 9 isCompound Z
13 84 10 rawIsDense Ljava/lang/Boolean;
15 16 11 isDense Z
17 84 11 isDense Z
21 84 12 filteredColumnRows Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
22 84 13 defaultValidator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
23 84 14 isCounter Z
27 84 15 cfId Ljava/util/UUID;
30 84 16 isCQLTable Z
33 84 17 isStaticCompactTable Z
36 84 18 needsUpgrade Z
46 84 19 columnDefs Ljava/util/List<Lorg/apache/cassandra/config/ColumnDefinition;>;
67 84 20 cfm Lorg/apache/cassandra/config/CFMetaData;
78 84 21 indexes Lorg/apache/cassandra/schema/Indexes;
MethodParameters:
Name Flags
tableName
tableRow
columnRows
triggerRows
private static boolean calculateIsDense(org.apache.cassandra.db.marshal.AbstractType<?>, org.apache.cassandra.cql3.UntypedResultSet, );
descriptor: (Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/cql3/UntypedResultSet;Z)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 4
goto 4
StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.UntypedResultSet int top java.util.Iterator
StackMap stack:
1: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 3
start local 3 2: ldc "regular"
aload 3
ldc "type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 4
3: iconst_0
ireturn
end local 3 4: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
5: iload 2
ifeq 7
6: iconst_1
ireturn
7: StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.UntypedResultSet int
StackMap stack:
iconst_m1
istore 3
start local 3 8: aload 1
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 5
goto 14
StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.UntypedResultSet int int top java.util.Iterator
StackMap stack:
9: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 4
start local 4 10: ldc "clustering_key"
aload 4
ldc "type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 14
11: iload 3
aload 4
ldc "component_index"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 12
aload 4
ldc "component_index"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
goto 13
StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.UntypedResultSet int int org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator
StackMap stack: int
12: iconst_0
StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.UntypedResultSet int int org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator
StackMap stack: int int
13: invokestatic java.lang.Math.max:(II)I
istore 3
end local 4 14: StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.UntypedResultSet int int top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
15: iload 3
iflt 18
16: iload 3
aload 0
invokevirtual org.apache.cassandra.db.marshal.AbstractType.componentsCount:()I
iconst_1
isub
if_icmpne 17
iconst_1
goto 20
StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.UntypedResultSet int int
StackMap stack:
17: iconst_0
goto 20
18: StackMap locals:
StackMap stack:
aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.isCQL3OnlyPKComparator:(Lorg/apache/cassandra/db/marshal/AbstractType;)Z
ifeq 19
iconst_0
goto 20
StackMap locals:
StackMap stack:
19: iconst_1
20: StackMap locals:
StackMap stack: int
ireturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 21 0 comparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 21 1 columnRows Lorg/apache/cassandra/cql3/UntypedResultSet;
0 21 2 isSuper Z
2 4 3 columnRow Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
8 21 3 maxClusteringIdx I
10 14 4 columnRow Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
Signature: (Lorg/apache/cassandra/db/marshal/AbstractType<*>;Lorg/apache/cassandra/cql3/UntypedResultSet;Z)Z
MethodParameters:
Name Flags
comparator
columnRows
isSuper
private static java.lang.Iterable<org.apache.cassandra.cql3.UntypedResultSet$Row> filterOutRedundantRowsForSparse(org.apache.cassandra.cql3.UntypedResultSet, boolean, boolean);
descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet;ZZ)Ljava/lang/Iterable;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=7, args_size=3
start local 0 start local 1 start local 2 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 1: aload 0
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.iterator:()Ljava/util/Iterator;
astore 5
goto 9
StackMap locals: org.apache.cassandra.cql3.UntypedResultSet int int java.util.Collection top java.util.Iterator
StackMap stack:
2: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 4
start local 4 3: aload 4
ldc "type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 6
start local 6 4: iload 1
ifne 6
ldc "compact_value"
aload 6
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 6
5: goto 9
6: StackMap locals: org.apache.cassandra.cql3.UntypedResultSet int int java.util.Collection org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator java.lang.String
StackMap stack:
ldc "clustering_key"
aload 6
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 8
iload 1
ifne 8
iload 2
ifne 8
7: goto 9
8: StackMap locals:
StackMap stack:
aload 3
aload 4
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
pop
end local 6 end local 4 9: StackMap locals: org.apache.cassandra.cql3.UntypedResultSet int int java.util.Collection top java.util.Iterator
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
10: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 columnRows Lorg/apache/cassandra/cql3/UntypedResultSet;
0 11 1 isSuper Z
0 11 2 isCompound Z
1 11 3 filteredRows Ljava/util/Collection<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
3 9 4 columnRow Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
4 9 6 kind Ljava/lang/String;
Signature: (Lorg/apache/cassandra/cql3/UntypedResultSet;ZZ)Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
MethodParameters:
Name Flags
columnRows
isSuper
isCompound
private static boolean isCQL3OnlyPKComparator(org.apache.cassandra.db.marshal.AbstractType<?>);
descriptor: (Lorg/apache/cassandra/db/marshal/AbstractType;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
instanceof org.apache.cassandra.db.marshal.CompositeType
ifne 2
1: iconst_0
ireturn
2: StackMap locals:
StackMap stack:
aload 0
checkcast org.apache.cassandra.db.marshal.CompositeType
astore 1
start local 1 3: aload 1
getfield org.apache.cassandra.db.marshal.CompositeType.types:Ljava/util/List;
invokeinterface java.util.List.size:()I
iconst_1
if_icmpne 4
aload 1
getfield org.apache.cassandra.db.marshal.CompositeType.types:Ljava/util/List;
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
instanceof org.apache.cassandra.db.marshal.UTF8Type
ifeq 4
iconst_1
ireturn
StackMap locals: org.apache.cassandra.db.marshal.CompositeType
StackMap stack:
4: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 comparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
3 5 1 ct Lorg/apache/cassandra/db/marshal/CompositeType;
Signature: (Lorg/apache/cassandra/db/marshal/AbstractType<*>;)Z
MethodParameters:
Name Flags
comparator
private static org.apache.cassandra.schema.TableParams decodeTableParams(org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/schema/TableParams;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=4, args_size=1
start local 0 0: invokestatic org.apache.cassandra.schema.TableParams.builder:()Lorg/apache/cassandra/schema/TableParams$Builder;
astore 1
start local 1 1: aload 1
aload 0
ldc "read_repair_chance"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getDouble:(Ljava/lang/String;)D
invokevirtual org.apache.cassandra.schema.TableParams$Builder.readRepairChance:(D)Lorg/apache/cassandra/schema/TableParams$Builder;
2: aload 0
ldc "local_read_repair_chance"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getDouble:(Ljava/lang/String;)D
invokevirtual org.apache.cassandra.schema.TableParams$Builder.dcLocalReadRepairChance:(D)Lorg/apache/cassandra/schema/TableParams$Builder;
3: aload 0
ldc "gc_grace_seconds"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
invokevirtual org.apache.cassandra.schema.TableParams$Builder.gcGraceSeconds:(I)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
4: aload 0
ldc "comment"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 6
5: aload 1
aload 0
ldc "comment"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual org.apache.cassandra.schema.TableParams$Builder.comment:(Ljava/lang/String;)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
6: StackMap locals: org.apache.cassandra.schema.TableParams$Builder
StackMap stack:
aload 0
ldc "memtable_flush_period_in_ms"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 8
7: aload 1
aload 0
ldc "memtable_flush_period_in_ms"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
invokevirtual org.apache.cassandra.schema.TableParams$Builder.memtableFlushPeriodInMs:(I)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
8: StackMap locals:
StackMap stack:
aload 1
aload 0
ldc "caching"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.cachingFromRow:(Ljava/lang/String;)Lorg/apache/cassandra/schema/CachingParams;
invokevirtual org.apache.cassandra.schema.TableParams$Builder.caching:(Lorg/apache/cassandra/schema/CachingParams;)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
9: aload 0
ldc "default_time_to_live"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 11
10: aload 1
aload 0
ldc "default_time_to_live"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
invokevirtual org.apache.cassandra.schema.TableParams$Builder.defaultTimeToLive:(I)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
11: StackMap locals:
StackMap stack:
aload 0
ldc "speculative_retry"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 13
12: aload 1
aload 0
ldc "speculative_retry"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.SpeculativeRetryParam.fromString:(Ljava/lang/String;)Lorg/apache/cassandra/schema/SpeculativeRetryParam;
invokevirtual org.apache.cassandra.schema.TableParams$Builder.speculativeRetry:(Lorg/apache/cassandra/schema/SpeculativeRetryParam;)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
13: StackMap locals:
StackMap stack:
aload 0
ldc "compression_parameters"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.utils.FBUtilities.fromJsonMap:(Ljava/lang/String;)Ljava/util/Map;
astore 2
start local 2 14: aload 2
ldc "crc_check_chance"
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 3
start local 3 15: aload 3
ifnull 17
16: aload 1
aload 3
invokestatic java.lang.Double.parseDouble:(Ljava/lang/String;)D
invokevirtual org.apache.cassandra.schema.TableParams$Builder.crcCheckChance:(D)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
17: StackMap locals: java.util.Map java.lang.String
StackMap stack:
aload 1
aload 2
invokestatic org.apache.cassandra.schema.CompressionParams.fromMap:(Ljava/util/Map;)Lorg/apache/cassandra/schema/CompressionParams;
invokevirtual org.apache.cassandra.schema.TableParams$Builder.compression:(Lorg/apache/cassandra/schema/CompressionParams;)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
18: aload 1
aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.compactionFromRow:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/schema/CompactionParams;
invokevirtual org.apache.cassandra.schema.TableParams$Builder.compaction:(Lorg/apache/cassandra/schema/CompactionParams;)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
19: aload 0
ldc "min_index_interval"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 21
20: aload 1
aload 0
ldc "min_index_interval"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
invokevirtual org.apache.cassandra.schema.TableParams$Builder.minIndexInterval:(I)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
21: StackMap locals:
StackMap stack:
aload 0
ldc "max_index_interval"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 23
22: aload 1
aload 0
ldc "max_index_interval"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
invokevirtual org.apache.cassandra.schema.TableParams$Builder.maxIndexInterval:(I)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
23: StackMap locals:
StackMap stack:
aload 0
ldc "bloom_filter_fp_chance"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 25
24: aload 1
aload 0
ldc "bloom_filter_fp_chance"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getDouble:(Ljava/lang/String;)D
invokevirtual org.apache.cassandra.schema.TableParams$Builder.bloomFilterFpChance:(D)Lorg/apache/cassandra/schema/TableParams$Builder;
pop
25: StackMap locals:
StackMap stack:
aload 1
invokevirtual org.apache.cassandra.schema.TableParams$Builder.build:()Lorg/apache/cassandra/schema/TableParams;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
1 26 1 params Lorg/apache/cassandra/schema/TableParams$Builder;
14 26 2 compressionParameters Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
15 26 3 crcCheckChance Ljava/lang/String;
MethodParameters:
Name Flags
row
public static org.apache.cassandra.schema.CachingParams cachingFromRow(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/schema/CachingParams;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
dup
astore 1
invokevirtual java.lang.String.hashCode:()I
lookupswitch { // 4
64897: 1
2402104: 2
430478930: 3
1724531479: 4
default: 9
}
StackMap locals: java.lang.String
StackMap stack:
1: aload 1
ldc "ALL"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 8
goto 9
StackMap locals:
StackMap stack:
2: aload 1
ldc "NONE"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 5
goto 9
StackMap locals:
StackMap stack:
3: aload 1
ldc "ROWS_ONLY"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 7
goto 9
StackMap locals:
StackMap stack:
4: aload 1
ldc "KEYS_ONLY"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 6
goto 9
5: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.schema.CachingParams.CACHE_NOTHING:Lorg/apache/cassandra/schema/CachingParams;
areturn
6: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.schema.CachingParams.CACHE_KEYS:Lorg/apache/cassandra/schema/CachingParams;
areturn
7: StackMap locals:
StackMap stack:
new org.apache.cassandra.schema.CachingParams
dup
iconst_0
ldc 2147483647
invokespecial org.apache.cassandra.schema.CachingParams.<init>:(ZI)V
areturn
8: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.schema.CachingParams.CACHE_EVERYTHING:Lorg/apache/cassandra/schema/CachingParams;
areturn
9: StackMap locals:
StackMap stack:
aload 0
invokestatic org.apache.cassandra.utils.FBUtilities.fromJsonMap:(Ljava/lang/String;)Ljava/util/Map;
invokestatic org.apache.cassandra.schema.CachingParams.fromMap:(Ljava/util/Map;)Lorg/apache/cassandra/schema/CachingParams;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 caching Ljava/lang/String;
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
RuntimeInvisibleTypeAnnotations:
METHOD_RETURN
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
caching
private static org.apache.cassandra.schema.CompactionParams compactionFromRow(org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/schema/CompactionParams;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=6, locals=7, args_size=1
start local 0 0: aload 0
ldc "compaction_strategy_class"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.config.CFMetaData.createCompactionStrategy:(Ljava/lang/String;)Ljava/lang/Class;
1: astore 1
start local 1 2: aload 0
ldc "compaction_strategy_options"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.utils.FBUtilities.fromJsonMap:(Ljava/lang/String;)Ljava/util/Map;
astore 2
start local 2 3: aload 0
ldc "min_compaction_threshold"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
istore 3
start local 3 4: aload 0
ldc "max_compaction_threshold"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
istore 4
start local 4 5: new java.util.HashMap
dup
aload 2
invokespecial java.util.HashMap.<init>:(Ljava/util/Map;)V
astore 5
start local 5 6: aload 5
getstatic org.apache.cassandra.schema.CompactionParams$Option.MIN_THRESHOLD:Lorg/apache/cassandra/schema/CompactionParams$Option;
invokevirtual org.apache.cassandra.schema.CompactionParams$Option.toString:()Ljava/lang/String;
iload 3
invokestatic java.lang.Integer.toString:(I)Ljava/lang/String;
invokeinterface java.util.Map.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
7: aload 5
getstatic org.apache.cassandra.schema.CompactionParams$Option.MAX_THRESHOLD:Lorg/apache/cassandra/schema/CompactionParams$Option;
invokevirtual org.apache.cassandra.schema.CompactionParams$Option.toString:()Ljava/lang/String;
iload 4
invokestatic java.lang.Integer.toString:(I)Ljava/lang/String;
invokeinterface java.util.Map.putIfAbsent:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
8: aload 1
ldc "validateOptions"
iconst_1
anewarray java.lang.Class
dup
iconst_0
ldc Ljava/util/Map;
aastore
invokevirtual java.lang.Class.getMethod:(Ljava/lang/String;[Ljava/lang/Class;)Ljava/lang/reflect/Method;
aconst_null
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 5
aastore
invokevirtual java.lang.reflect.Method.invoke:(Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.Map
9: astore 6
start local 6 10: aload 6
invokeinterface java.util.Map.isEmpty:()Z
ifeq 15
11: aload 5
astore 2
end local 6 12: goto 15
13: StackMap locals: org.apache.cassandra.cql3.UntypedResultSet$Row java.lang.Class java.util.Map int int java.util.Map
StackMap stack: java.lang.Exception
astore 6
start local 6 14: new java.lang.RuntimeException
dup
aload 6
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 6 15: StackMap locals:
StackMap stack:
aload 1
aload 2
invokestatic org.apache.cassandra.schema.CompactionParams.create:(Ljava/lang/Class;Ljava/util/Map;)Lorg/apache/cassandra/schema/CompactionParams;
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 16 0 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
2 16 1 klass Ljava/lang/Class<+Lorg/apache/cassandra/db/compaction/AbstractCompactionStrategy;>;
3 16 2 options Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
4 16 3 minThreshold I
5 16 4 maxThreshold I
6 16 5 optionsWithThresholds Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
10 12 6 unrecognizedOptions Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
14 15 6 e Ljava/lang/Exception;
Exception table:
from to target type
8 12 13 Class java.lang.Exception
MethodParameters:
Name Flags
row
private static boolean checkNeedsUpgrade(java.lang.Iterable<org.apache.cassandra.cql3.UntypedResultSet$Row>, boolean, );
descriptor: (Ljava/lang/Iterable;ZZ)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=3, args_size=3
start local 0 start local 1 start local 2 0: iload 1
ifeq 2
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack:
iload 2
ifeq 6
3: aload 0
getstatic org.apache.cassandra.config.ColumnDefinition$Kind.STATIC:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.hasKind:(Ljava/lang/Iterable;Lorg/apache/cassandra/config/ColumnDefinition$Kind;)Z
ifeq 4
iconst_0
goto 5
StackMap locals:
StackMap stack:
4: iconst_1
StackMap locals:
StackMap stack: int
5: ireturn
6: StackMap locals:
StackMap stack:
aload 0
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.hasRegularColumns:(Ljava/lang/Iterable;)Z
ifeq 7
iconst_0
goto 8
StackMap locals:
StackMap stack:
7: iconst_1
StackMap locals:
StackMap stack: int
8: ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 defs Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
0 9 1 isSuper Z
0 9 2 isStaticCompactTable Z
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;ZZ)Z
MethodParameters:
Name Flags
defs
isSuper
isStaticCompactTable
private static boolean hasRegularColumns(java.lang.Iterable<org.apache.cassandra.cql3.UntypedResultSet$Row>);
descriptor: (Ljava/lang/Iterable;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=3, args_size=1
start local 0 0: aload 0
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 2
goto 6
StackMap locals: java.lang.Iterable top java.util.Iterator
StackMap stack:
1: aload 2
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 1
start local 1 2: aload 1
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.isEmptyCompactValueColumn:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Z
ifeq 4
3: iconst_0
ireturn
4: StackMap locals: java.lang.Iterable org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator
StackMap stack:
aload 1
ldc "type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.deserializeKind:(Ljava/lang/String;)Lorg/apache/cassandra/config/ColumnDefinition$Kind;
getstatic org.apache.cassandra.config.ColumnDefinition$Kind.REGULAR:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
if_acmpne 6
5: iconst_1
ireturn
end local 1 6: StackMap locals: java.lang.Iterable top java.util.Iterator
StackMap stack:
aload 2
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
7: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 columnRows Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
2 6 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;)Z
MethodParameters:
Name Flags
columnRows
private static boolean isEmptyCompactValueColumn(org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: ldc "compact_value"
aload 0
ldc "type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifeq 1
aload 0
ldc "column_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual java.lang.String.isEmpty:()Z
ifeq 1
iconst_1
ireturn
StackMap locals:
StackMap stack:
1: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
MethodParameters:
Name Flags
row
private static void addDefinitionForUpgrade(java.util.List<org.apache.cassandra.config.ColumnDefinition>, java.lang.String, java.lang.String, boolean, boolean, org.apache.cassandra.db.marshal.AbstractType<?>, org.apache.cassandra.db.marshal.AbstractType<?>, org.apache.cassandra.db.marshal.AbstractType<?>);
descriptor: (Ljava/util/List;Ljava/lang/String;Ljava/lang/String;ZZLorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=7, locals=9, args_size=8
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 0: aload 0
invokestatic org.apache.cassandra.db.CompactTables.defaultNameGenerator:(Ljava/lang/Iterable;)Lorg/apache/cassandra/db/CompactTables$DefaultNames;
astore 8
start local 8 1: iload 4
ifeq 4
2: aload 0
aload 1
aload 2
getstatic org.apache.cassandra.cql3.SuperColumnCompatibility.SUPER_COLUMN_MAP_COLUMN_STR:Ljava/lang/String;
aload 6
aload 7
iconst_1
invokestatic org.apache.cassandra.db.marshal.MapType.getInstance:(Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;Z)Lorg/apache/cassandra/db/marshal/MapType;
invokestatic org.apache.cassandra.config.ColumnDefinition.regularDef:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/config/ColumnDefinition;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
3: goto 9
4: StackMap locals: org.apache.cassandra.db.CompactTables$DefaultNames
StackMap stack:
iload 3
ifeq 8
5: aload 0
aload 1
aload 2
aload 8
invokevirtual org.apache.cassandra.db.CompactTables$DefaultNames.defaultClusteringName:()Ljava/lang/String;
aload 5
iconst_0
invokestatic org.apache.cassandra.config.ColumnDefinition.clusteringDef:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;I)Lorg/apache/cassandra/config/ColumnDefinition;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
6: aload 0
aload 1
aload 2
aload 8
invokevirtual org.apache.cassandra.db.CompactTables$DefaultNames.defaultCompactValueName:()Ljava/lang/String;
aload 7
invokestatic org.apache.cassandra.config.ColumnDefinition.regularDef:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/config/ColumnDefinition;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
7: goto 9
8: StackMap locals:
StackMap stack:
aload 0
aload 1
aload 2
aload 8
invokevirtual org.apache.cassandra.db.CompactTables$DefaultNames.defaultCompactValueName:()Ljava/lang/String;
getstatic org.apache.cassandra.db.marshal.EmptyType.instance:Lorg/apache/cassandra/db/marshal/EmptyType;
invokestatic org.apache.cassandra.config.ColumnDefinition.regularDef:(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/config/ColumnDefinition;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
9: StackMap locals:
StackMap stack:
return
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 defs Ljava/util/List<Lorg/apache/cassandra/config/ColumnDefinition;>;
0 10 1 ksName Ljava/lang/String;
0 10 2 cfName Ljava/lang/String;
0 10 3 isStaticCompactTable Z
0 10 4 isSuper Z
0 10 5 rawComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 10 6 subComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 10 7 defaultValidator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
1 10 8 names Lorg/apache/cassandra/db/CompactTables$DefaultNames;
Signature: (Ljava/util/List<Lorg/apache/cassandra/config/ColumnDefinition;>;Ljava/lang/String;Ljava/lang/String;ZZLorg/apache/cassandra/db/marshal/AbstractType<*>;Lorg/apache/cassandra/db/marshal/AbstractType<*>;Lorg/apache/cassandra/db/marshal/AbstractType<*>;)V
MethodParameters:
Name Flags
defs
ksName
cfName
isStaticCompactTable
isSuper
rawComparator
subComparator
defaultValidator
private static boolean hasKind(java.lang.Iterable<org.apache.cassandra.cql3.UntypedResultSet$Row>, org.apache.cassandra.config.ColumnDefinition$Kind);
descriptor: (Ljava/lang/Iterable;Lorg/apache/cassandra/config/ColumnDefinition$Kind;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 3
goto 4
StackMap locals: java.lang.Iterable org.apache.cassandra.config.ColumnDefinition$Kind top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 2
start local 2 2: aload 2
ldc "type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.deserializeKind:(Ljava/lang/String;)Lorg/apache/cassandra/config/ColumnDefinition$Kind;
aload 1
if_acmpne 4
3: iconst_1
ireturn
end local 2 4: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
5: iconst_0
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 defs Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
0 6 1 kind Lorg/apache/cassandra/config/ColumnDefinition$Kind;
2 4 2 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;Lorg/apache/cassandra/config/ColumnDefinition$Kind;)Z
MethodParameters:
Name Flags
defs
kind
private static void addDroppedColumns(org.apache.cassandra.config.CFMetaData, org.apache.cassandra.db.marshal.AbstractType<?>, java.util.Map<java.lang.String, java.lang.Long>);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/marshal/AbstractType;Ljava/util/Map;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=9, locals=12, args_size=3
start local 0 start local 1 start local 2 0: aload 1
invokevirtual org.apache.cassandra.db.marshal.AbstractType.getComponents:()Ljava/util/List;
aload 1
invokevirtual org.apache.cassandra.db.marshal.AbstractType.componentsCount:()I
iconst_1
isub
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.marshal.AbstractType
astore 3
start local 3 1: aload 3
instanceof org.apache.cassandra.db.marshal.ColumnToCollectionType
ifeq 3
2: aload 3
checkcast org.apache.cassandra.db.marshal.ColumnToCollectionType
getfield org.apache.cassandra.db.marshal.ColumnToCollectionType.defined:Ljava/util/Map;
goto 4
3: StackMap locals: org.apache.cassandra.db.marshal.AbstractType
StackMap stack:
invokestatic java.util.Collections.emptyMap:()Ljava/util/Map;
4: StackMap locals:
StackMap stack: java.util.Map
astore 4
start local 4 5: aload 2
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 6
goto 15
StackMap locals: org.apache.cassandra.config.CFMetaData org.apache.cassandra.db.marshal.AbstractType java.util.Map org.apache.cassandra.db.marshal.AbstractType java.util.Map top java.util.Iterator
StackMap stack:
6: aload 6
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.util.Map$Entry
astore 5
start local 5 7: aload 5
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
astore 7
start local 7 8: getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
aload 7
invokevirtual org.apache.cassandra.db.marshal.UTF8Type.decompose:(Ljava/lang/Object;)Ljava/nio/ByteBuffer;
astore 8
start local 8 9: aload 5
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.lang.Long
invokevirtual java.lang.Long.longValue:()J
lstore 9
start local 9 10: aload 4
aload 8
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 12
11: aload 4
aload 8
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.marshal.AbstractType
goto 13
12: StackMap locals: org.apache.cassandra.config.CFMetaData org.apache.cassandra.db.marshal.AbstractType java.util.Map org.apache.cassandra.db.marshal.AbstractType java.util.Map java.util.Map$Entry java.util.Iterator java.lang.String java.nio.ByteBuffer long
StackMap stack:
getstatic org.apache.cassandra.db.marshal.BytesType.instance:Lorg/apache/cassandra/db/marshal/BytesType;
13: StackMap locals:
StackMap stack: org.apache.cassandra.db.marshal.AbstractType
astore 11
start local 11 14: aload 0
invokevirtual org.apache.cassandra.config.CFMetaData.getDroppedColumns:()Ljava/util/Map;
aload 8
new org.apache.cassandra.config.CFMetaData$DroppedColumn
dup
aload 7
aconst_null
aload 11
lload 9
invokespecial org.apache.cassandra.config.CFMetaData$DroppedColumn.<init>:(Ljava/lang/String;Lorg/apache/cassandra/config/ColumnDefinition$Kind;Lorg/apache/cassandra/db/marshal/AbstractType;J)V
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
end local 11 end local 9 end local 8 end local 7 end local 5 15: StackMap locals: org.apache.cassandra.config.CFMetaData org.apache.cassandra.db.marshal.AbstractType java.util.Map org.apache.cassandra.db.marshal.AbstractType java.util.Map top java.util.Iterator
StackMap stack:
aload 6
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
16: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 17 0 cfm Lorg/apache/cassandra/config/CFMetaData;
0 17 1 comparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 17 2 droppedTimes Ljava/util/Map<Ljava/lang/String;Ljava/lang/Long;>;
1 17 3 last Lorg/apache/cassandra/db/marshal/AbstractType<*>;
5 17 4 collections Ljava/util/Map<Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/marshal/CollectionType;>;
7 15 5 entry Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Long;>;
8 15 7 name Ljava/lang/String;
9 15 8 nameBytes Ljava/nio/ByteBuffer;
10 15 9 time J
14 15 11 type Lorg/apache/cassandra/db/marshal/AbstractType<*>;
Signature: (Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/marshal/AbstractType<*>;Ljava/util/Map<Ljava/lang/String;Ljava/lang/Long;>;)V
MethodParameters:
Name Flags
cfm
comparator
droppedTimes
private static java.util.List<org.apache.cassandra.config.ColumnDefinition> createColumnsFromColumnRows(java.lang.Iterable<org.apache.cassandra.cql3.UntypedResultSet$Row>, java.lang.String, java.lang.String, org.apache.cassandra.db.marshal.AbstractType<?>, org.apache.cassandra.db.marshal.AbstractType<?>, boolean, boolean, boolean, boolean);
descriptor: (Ljava/lang/Iterable;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;ZZZZ)Ljava/util/List;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=10, locals=12, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 9
start local 9 1: aload 0
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 11
goto 15
StackMap locals: java.lang.Iterable java.lang.String java.lang.String org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.db.marshal.AbstractType int int int int java.util.List top java.util.Iterator
StackMap stack:
2: aload 11
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 10
start local 10 3: aload 10
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.isEmptyCompactValueColumn:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Z
ifeq 5
4: goto 15
5: StackMap locals: java.lang.Iterable java.lang.String java.lang.String org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.db.marshal.AbstractType int int int int java.util.List org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator
StackMap stack:
aload 9
aload 10
6: aload 1
7: aload 2
8: aload 3
9: aload 4
10: iload 5
11: iload 6
12: iload 7
13: iload 8
14: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.createColumnFromColumnRow:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;ZZZZ)Lorg/apache/cassandra/config/ColumnDefinition;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 10 15: StackMap locals: java.lang.Iterable java.lang.String java.lang.String org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.db.marshal.AbstractType int int int int java.util.List top java.util.Iterator
StackMap stack:
aload 11
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
16: aload 9
areturn
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 17 0 rows Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
0 17 1 keyspace Ljava/lang/String;
0 17 2 table Ljava/lang/String;
0 17 3 rawComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 17 4 rawSubComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 17 5 isSuper Z
0 17 6 isCQLTable Z
0 17 7 isStaticCompactTable Z
0 17 8 needsUpgrade Z
1 17 9 columns Ljava/util/List<Lorg/apache/cassandra/config/ColumnDefinition;>;
3 15 10 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
Signature: (Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType<*>;Lorg/apache/cassandra/db/marshal/AbstractType<*>;ZZZZ)Ljava/util/List<Lorg/apache/cassandra/config/ColumnDefinition;>;
MethodParameters:
Name Flags
rows
keyspace
table
rawComparator
rawSubComparator
isSuper
isCQLTable
isStaticCompactTable
needsUpgrade
private static org.apache.cassandra.config.ColumnDefinition createColumnFromColumnRow(org.apache.cassandra.cql3.UntypedResultSet$Row, java.lang.String, java.lang.String, org.apache.cassandra.db.marshal.AbstractType<?>, org.apache.cassandra.db.marshal.AbstractType<?>, boolean, boolean, boolean, boolean);
descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;ZZZZ)Lorg/apache/cassandra/config/ColumnDefinition;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=8, locals=15, args_size=9
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 0: aload 0
ldc "type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 9
start local 9 1: aload 9
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.deserializeKind:(Ljava/lang/String;)Lorg/apache/cassandra/config/ColumnDefinition$Kind;
astore 10
start local 10 2: iload 8
ifeq 4
iload 7
ifeq 4
aload 10
getstatic org.apache.cassandra.config.ColumnDefinition$Kind.REGULAR:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
if_acmpne 4
3: getstatic org.apache.cassandra.config.ColumnDefinition$Kind.STATIC:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
astore 10
4: StackMap locals: java.lang.String org.apache.cassandra.config.ColumnDefinition$Kind
StackMap stack:
iconst_m1
istore 11
start local 11 5: aload 10
invokevirtual org.apache.cassandra.config.ColumnDefinition$Kind.isPrimaryKeyKind:()Z
ifeq 9
6: aload 0
ldc "component_index"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 7
aload 0
ldc "component_index"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getInt:(Ljava/lang/String;)I
goto 8
StackMap locals: int
StackMap stack:
7: iconst_0
StackMap locals:
StackMap stack: int
8: istore 11
9: StackMap locals:
StackMap stack:
iload 6
ifeq 11
10: getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
goto 12
11: StackMap locals:
StackMap stack:
aload 9
iload 5
aload 3
aload 4
invokestatic org.apache.cassandra.db.CompactTables.columnDefinitionComparator:(Ljava/lang/String;ZLorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/db/marshal/AbstractType;
12: StackMap locals:
StackMap stack: org.apache.cassandra.db.marshal.AbstractType
astore 12
start local 12 13: aload 12
aload 0
ldc "column_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.fromString:(Ljava/lang/String;)Ljava/nio/ByteBuffer;
aload 12
invokestatic org.apache.cassandra.cql3.ColumnIdentifier.getInterned:(Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/cql3/ColumnIdentifier;
astore 13
start local 13 14: aload 0
ldc "validator"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.parseType:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
astore 14
start local 14 15: aload 14
invokevirtual org.apache.cassandra.db.marshal.AbstractType.isUDT:()Z
ifeq 17
aload 14
invokevirtual org.apache.cassandra.db.marshal.AbstractType.isMultiCell:()Z
ifeq 17
16: aload 14
invokevirtual org.apache.cassandra.db.marshal.AbstractType.freeze:()Lorg/apache/cassandra/db/marshal/AbstractType;
astore 14
goto 18
17: StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.ColumnIdentifier org.apache.cassandra.db.marshal.AbstractType
StackMap stack:
aload 14
invokevirtual org.apache.cassandra.db.marshal.AbstractType.freezeNestedMulticellTypes:()Lorg/apache/cassandra/db/marshal/AbstractType;
astore 14
18: StackMap locals:
StackMap stack:
new org.apache.cassandra.config.ColumnDefinition
dup
aload 1
aload 2
aload 13
aload 14
iload 11
aload 10
invokespecial org.apache.cassandra.config.ColumnDefinition.<init>:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/cql3/ColumnIdentifier;Lorg/apache/cassandra/db/marshal/AbstractType;ILorg/apache/cassandra/config/ColumnDefinition$Kind;)V
areturn
end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 19 0 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
0 19 1 keyspace Ljava/lang/String;
0 19 2 table Ljava/lang/String;
0 19 3 rawComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 19 4 rawSubComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 19 5 isSuper Z
0 19 6 isCQLTable Z
0 19 7 isStaticCompactTable Z
0 19 8 needsUpgrade Z
1 19 9 rawKind Ljava/lang/String;
2 19 10 kind Lorg/apache/cassandra/config/ColumnDefinition$Kind;
5 19 11 componentIndex I
13 19 12 comparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
14 19 13 name Lorg/apache/cassandra/cql3/ColumnIdentifier;
15 19 14 validator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
Signature: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType<*>;Lorg/apache/cassandra/db/marshal/AbstractType<*>;ZZZZ)Lorg/apache/cassandra/config/ColumnDefinition;
MethodParameters:
Name Flags
row
keyspace
table
rawComparator
rawSubComparator
isSuper
isCQLTable
isStaticCompactTable
needsUpgrade
private static org.apache.cassandra.schema.Indexes createIndexesFromColumnRows(org.apache.cassandra.config.CFMetaData, java.lang.Iterable<org.apache.cassandra.cql3.UntypedResultSet$Row>, java.lang.String, java.lang.String, org.apache.cassandra.db.marshal.AbstractType<?>, org.apache.cassandra.db.marshal.AbstractType<?>, boolean, boolean, boolean, boolean);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;Ljava/lang/Iterable;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;ZZZZ)Lorg/apache/cassandra/schema/Indexes;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=9, locals=17, args_size=10
start local 0 start local 1 start local 2 start local 3 start local 4 start local 5 start local 6 start local 7 start local 8 start local 9 0: invokestatic org.apache.cassandra.schema.Indexes.builder:()Lorg/apache/cassandra/schema/Indexes$Builder;
astore 10
start local 10 1: aload 1
invokeinterface java.lang.Iterable.iterator:()Ljava/util/Iterator;
astore 12
goto 26
StackMap locals: org.apache.cassandra.config.CFMetaData java.lang.Iterable java.lang.String java.lang.String org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.db.marshal.AbstractType int int int int org.apache.cassandra.schema.Indexes$Builder top java.util.Iterator
StackMap stack:
2: aload 12
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.cql3.UntypedResultSet$Row
astore 11
start local 11 3: aconst_null
astore 13
start local 13 4: aload 11
ldc "index_type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 6
5: aload 11
ldc "index_type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.IndexMetadata$Kind.valueOf:(Ljava/lang/String;)Lorg/apache/cassandra/schema/IndexMetadata$Kind;
astore 13
6: StackMap locals: org.apache.cassandra.config.CFMetaData java.lang.Iterable java.lang.String java.lang.String org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.db.marshal.AbstractType int int int int org.apache.cassandra.schema.Indexes$Builder org.apache.cassandra.cql3.UntypedResultSet$Row java.util.Iterator org.apache.cassandra.schema.IndexMetadata$Kind
StackMap stack:
aload 13
ifnonnull 8
7: goto 26
8: StackMap locals:
StackMap stack:
aconst_null
astore 14
start local 14 9: aload 11
ldc "index_options"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 11
10: aload 11
ldc "index_options"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.utils.FBUtilities.fromJsonMap:(Ljava/lang/String;)Ljava/util/Map;
astore 14
11: StackMap locals: java.util.Map
StackMap stack:
aload 11
ldc "index_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 25
12: aload 11
ldc "index_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 15
start local 15 13: aload 11
14: aload 2
15: aload 3
16: aload 4
17: aload 5
18: iload 6
19: iload 7
20: iload 8
21: iload 9
22: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.createColumnFromColumnRow:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/db/marshal/AbstractType;ZZZZ)Lorg/apache/cassandra/config/ColumnDefinition;
astore 16
start local 16 23: aload 10
aload 0
aload 16
aload 15
aload 13
aload 14
invokestatic org.apache.cassandra.schema.IndexMetadata.fromLegacyMetadata:(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/config/ColumnDefinition;Ljava/lang/String;Lorg/apache/cassandra/schema/IndexMetadata$Kind;Ljava/util/Map;)Lorg/apache/cassandra/schema/IndexMetadata;
invokevirtual org.apache.cassandra.schema.Indexes$Builder.add:(Lorg/apache/cassandra/schema/IndexMetadata;)Lorg/apache/cassandra/schema/Indexes$Builder;
pop
end local 16 end local 15 24: goto 26
25: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.schema.LegacySchemaMigrator.logger:Lorg/slf4j/Logger;
ldc "Failed to find index name for legacy migration of index on {}.{}"
aload 2
aload 3
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
end local 14 end local 13 end local 11 26: StackMap locals: org.apache.cassandra.config.CFMetaData java.lang.Iterable java.lang.String java.lang.String org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.db.marshal.AbstractType int int int int org.apache.cassandra.schema.Indexes$Builder top java.util.Iterator
StackMap stack:
aload 12
invokeinterface java.util.Iterator.hasNext:()Z
ifne 2
27: aload 10
invokevirtual org.apache.cassandra.schema.Indexes$Builder.build:()Lorg/apache/cassandra/schema/Indexes;
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 28 0 cfm Lorg/apache/cassandra/config/CFMetaData;
0 28 1 rows Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;
0 28 2 keyspace Ljava/lang/String;
0 28 3 table Ljava/lang/String;
0 28 4 rawComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 28 5 rawSubComparator Lorg/apache/cassandra/db/marshal/AbstractType<*>;
0 28 6 isSuper Z
0 28 7 isCQLTable Z
0 28 8 isStaticCompactTable Z
0 28 9 needsUpgrade Z
1 28 10 indexes Lorg/apache/cassandra/schema/Indexes$Builder;
3 26 11 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
4 26 13 kind Lorg/apache/cassandra/schema/IndexMetadata$Kind;
9 26 14 indexOptions Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
13 24 15 indexName Ljava/lang/String;
23 24 16 column Lorg/apache/cassandra/config/ColumnDefinition;
Signature: (Lorg/apache/cassandra/config/CFMetaData;Ljava/lang/Iterable<Lorg/apache/cassandra/cql3/UntypedResultSet$Row;>;Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType<*>;Lorg/apache/cassandra/db/marshal/AbstractType<*>;ZZZZ)Lorg/apache/cassandra/schema/Indexes;
MethodParameters:
Name Flags
cfm
rows
keyspace
table
rawComparator
rawSubComparator
isSuper
isCQLTable
isStaticCompactTable
needsUpgrade
private static org.apache.cassandra.config.ColumnDefinition$Kind deserializeKind(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/config/ColumnDefinition$Kind;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: ldc "clustering_key"
aload 0
invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
ifeq 2
1: getstatic org.apache.cassandra.config.ColumnDefinition$Kind.CLUSTERING:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
areturn
2: StackMap locals:
StackMap stack:
ldc "compact_value"
aload 0
invokevirtual java.lang.String.equalsIgnoreCase:(Ljava/lang/String;)Z
ifeq 4
3: getstatic org.apache.cassandra.config.ColumnDefinition$Kind.REGULAR:Lorg/apache/cassandra/config/ColumnDefinition$Kind;
areturn
4: StackMap locals:
StackMap stack:
ldc Lorg/apache/cassandra/config/ColumnDefinition$Kind;
aload 0
invokevirtual java.lang.String.toUpperCase:()Ljava/lang/String;
invokestatic java.lang.Enum.valueOf:(Ljava/lang/Class;Ljava/lang/String;)Ljava/lang/Enum;
checkcast org.apache.cassandra.config.ColumnDefinition$Kind
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 kind Ljava/lang/String;
MethodParameters:
Name Flags
kind
private static org.apache.cassandra.schema.Triggers createTriggersFromTriggerRows(org.apache.cassandra.cql3.UntypedResultSet);
descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet;)Lorg/apache/cassandra/schema/Triggers;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: invokestatic org.apache.cassandra.schema.Triggers.builder:()Lorg/apache/cassandra/schema/Triggers$Builder;
astore 1
start local 1 1: aload 0
aload 1
invokedynamic accept(Lorg/apache/cassandra/schema/Triggers$Builder;)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/schema/LegacySchemaMigrator.lambda$12(Lorg/apache/cassandra/schema/Triggers$Builder;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V (6)
(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.forEach:(Ljava/util/function/Consumer;)V
2: aload 1
invokevirtual org.apache.cassandra.schema.Triggers$Builder.build:()Lorg/apache/cassandra/schema/Triggers;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 rows Lorg/apache/cassandra/cql3/UntypedResultSet;
1 3 1 triggers Lorg/apache/cassandra/schema/Triggers$Builder;
MethodParameters:
Name Flags
rows
private static org.apache.cassandra.schema.TriggerMetadata createTriggerFromTriggerRow(org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/schema/TriggerMetadata;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=4, locals=3, args_size=1
start local 0 0: aload 0
ldc "trigger_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 1
start local 1 1: aload 0
ldc "trigger_options"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getTextMap:(Ljava/lang/String;)Ljava/util/Map;
ldc "class"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 2
start local 2 2: new org.apache.cassandra.schema.TriggerMetadata
dup
aload 1
aload 2
invokespecial org.apache.cassandra.schema.TriggerMetadata.<init>:(Ljava/lang/String;Ljava/lang/String;)V
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
1 3 1 name Ljava/lang/String;
2 3 2 classOption Ljava/lang/String;
MethodParameters:
Name Flags
row
private static java.util.Collection<org.apache.cassandra.schema.LegacySchemaMigrator$Type> readTypes(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/Collection;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=4, args_size=1
start local 0 0: ldc "SELECT type_name FROM %s.%s WHERE keyspace_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_usertypes"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 1
start local 1 4: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 5: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
aload 2
invokedynamic accept(Ljava/util/Collection;)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/schema/LegacySchemaMigrator.lambda$13(Ljava/util/Collection;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V (6)
(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.forEach:(Ljava/util/function/Consumer;)V
6: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 7: aload 2
aload 3
aload 0
invokedynamic accept(Ljava/util/Collection;Ljava/lang/String;)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/schema/LegacySchemaMigrator.lambda$14(Ljava/util/Collection;Ljava/lang/String;Ljava/lang/String;)V (6)
(Ljava/lang/String;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
8: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 keyspaceName Ljava/lang/String;
4 9 1 query Ljava/lang/String;
5 9 2 typeNames Ljava/util/Collection<Ljava/lang/String;>;
7 9 3 types Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Type;>;
Signature: (Ljava/lang/String;)Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Type;>;
MethodParameters:
Name Flags
keyspaceName
private static org.apache.cassandra.schema.LegacySchemaMigrator$Type readType(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Type;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readTypeTimestamp:(Ljava/lang/String;Ljava/lang/String;)J
lstore 2
start local 2 1: aload 0
aload 1
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readTypeMetadata:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/UserType;
astore 4
start local 4 2: new org.apache.cassandra.schema.LegacySchemaMigrator$Type
dup
lload 2
aload 4
invokespecial org.apache.cassandra.schema.LegacySchemaMigrator$Type.<init>:(JLorg/apache/cassandra/db/marshal/UserType;)V
areturn
end local 4 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 keyspaceName Ljava/lang/String;
0 3 1 typeName Ljava/lang/String;
1 3 2 timestamp J
2 3 4 metadata Lorg/apache/cassandra/db/marshal/UserType;
MethodParameters:
Name Flags
keyspaceName
typeName
private static long readTypeTimestamp(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)J
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=6, locals=12, args_size=2
start local 0 start local 1 0: ldc "system"
invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
1: ldc "schema_usertypes"
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
2: astore 2
start local 2 3: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.comparator:Lorg/apache/cassandra/db/ClusteringComparator;
astore 3
start local 3 4: aload 3
aload 3
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;
invokestatic org.apache.cassandra.db.Slices.with:(Lorg/apache/cassandra/db/ClusteringComparator;Lorg/apache/cassandra/db/Slice;)Lorg/apache/cassandra/db/Slices;
astore 4
start local 4 5: invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
istore 5
start local 5 6: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getstatic org.apache.cassandra.db.marshal.AsciiType.instance:Lorg/apache/cassandra/db/marshal/AsciiType;
aload 0
invokevirtual org.apache.cassandra.db.marshal.AsciiType.fromString:(Ljava/lang/String;)Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.config.CFMetaData.decorateKey:(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
astore 6
start local 6 7: aload 2
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
iload 5
aload 6
aload 4
invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.create:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/Slices;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
astore 7
start local 7 8: aconst_null
astore 8
aconst_null
astore 9
9: aload 7
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.executionController:()Lorg/apache/cassandra/db/ReadExecutionController;
astore 10
start local 10 10: aload 7
aload 2
aload 10
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.queryMemtableAndDisk:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
iload 5
invokestatic org.apache.cassandra.db.rows.UnfilteredRowIterators.filter:(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)Lorg/apache/cassandra/db/rows/RowIterator;
astore 11
start local 11 11: aload 11
invokeinterface org.apache.cassandra.db.rows.RowIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Row
invokeinterface org.apache.cassandra.db.rows.Row.primaryKeyLivenessInfo:()Lorg/apache/cassandra/db/LivenessInfo;
invokevirtual org.apache.cassandra.db.LivenessInfo.timestamp:()J
12: aload 11
ifnull 13
aload 11
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
StackMap locals: java.lang.String java.lang.String org.apache.cassandra.db.ColumnFamilyStore org.apache.cassandra.db.ClusteringComparator org.apache.cassandra.db.Slices int org.apache.cassandra.db.DecoratedKey org.apache.cassandra.db.SinglePartitionReadCommand java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.db.rows.RowIterator
StackMap stack: long
13: aload 10
ifnull 14
aload 10
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
14: StackMap locals:
StackMap stack: long
lreturn
StackMap locals:
StackMap stack: java.lang.Throwable
15: astore 8
16: aload 11
ifnull 17
aload 11
invokeinterface org.apache.cassandra.db.rows.RowIterator.close:()V
end local 11 StackMap locals:
StackMap stack:
17: aload 8
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
18: astore 9
aload 8
ifnonnull 19
aload 9
astore 8
goto 20
StackMap locals:
StackMap stack:
19: aload 8
aload 9
if_acmpeq 20
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
20: aload 10
ifnull 21
aload 10
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
end local 10 StackMap locals:
StackMap stack:
21: aload 8
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
22: astore 9
aload 8
ifnonnull 23
aload 9
astore 8
goto 24
StackMap locals:
StackMap stack:
23: aload 8
aload 9
if_acmpeq 24
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
24: aload 8
athrow
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 25 0 keyspaceName Ljava/lang/String;
0 25 1 typeName Ljava/lang/String;
3 25 2 store Lorg/apache/cassandra/db/ColumnFamilyStore;
4 25 3 comparator Lorg/apache/cassandra/db/ClusteringComparator;
5 25 4 slices Lorg/apache/cassandra/db/Slices;
6 25 5 nowInSec I
7 25 6 key Lorg/apache/cassandra/db/DecoratedKey;
8 25 7 command Lorg/apache/cassandra/db/SinglePartitionReadCommand;
10 21 10 controller Lorg/apache/cassandra/db/ReadExecutionController;
11 17 11 partition Lorg/apache/cassandra/db/rows/RowIterator;
Exception table:
from to target type
11 12 15 any
10 13 18 any
15 18 18 any
9 14 22 any
15 22 22 any
MethodParameters:
Name Flags
keyspaceName
typeName
private static org.apache.cassandra.db.marshal.UserType readTypeMetadata(java.lang.String, java.lang.String);
descriptor: (Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/UserType;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=7, locals=6, args_size=2
start local 0 start local 1 0: ldc "SELECT * FROM %s.%s WHERE keyspace_name = ? AND type_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_usertypes"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 2
start local 2 4: aload 2
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 3
start local 3 5: aload 3
ldc "field_names"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getList:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/List;
6: invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
7: 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/schema/LegacySchemaMigrator.lambda$15(Ljava/lang/String;)Lorg/apache/cassandra/cql3/FieldIdentifier; (6)
(Ljava/lang/String;)Lorg/apache/cassandra/cql3/FieldIdentifier;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
8: 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
9: astore 4
start local 4 10: aload 3
ldc "field_types"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getList:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/List;
11: invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
12: 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/schema/LegacySchemaMigrator.parseType(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType; (6)
(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
13: 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
14: astore 5
start local 5 15: new org.apache.cassandra.db.marshal.UserType
dup
aload 0
aload 1
invokestatic org.apache.cassandra.utils.ByteBufferUtil.bytes:(Ljava/lang/String;)Ljava/nio/ByteBuffer;
aload 4
aload 5
iconst_1
invokespecial org.apache.cassandra.db.marshal.UserType.<init>:(Ljava/lang/String;Ljava/nio/ByteBuffer;Ljava/util/List;Ljava/util/List;Z)V
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 16 0 keyspaceName Ljava/lang/String;
0 16 1 typeName Ljava/lang/String;
4 16 2 query Ljava/lang/String;
5 16 3 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
10 16 4 names Ljava/util/List<Lorg/apache/cassandra/cql3/FieldIdentifier;>;
15 16 5 types Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
MethodParameters:
Name Flags
keyspaceName
typeName
private static java.util.Collection<org.apache.cassandra.schema.LegacySchemaMigrator$Function> readFunctions(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/util/Collection;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=4, args_size=1
start local 0 0: ldc "SELECT function_name, signature FROM %s.%s WHERE keyspace_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_functions"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 1
start local 1 4: invokestatic com.google.common.collect.HashMultimap.create:()Lcom/google/common/collect/HashMultimap;
astore 2
start local 2 5: aload 1
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
aload 2
invokedynamic accept(Lcom/google/common/collect/HashMultimap;)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/schema/LegacySchemaMigrator.lambda$17(Lcom/google/common/collect/HashMultimap;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V (6)
(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.forEach:(Ljava/util/function/Consumer;)V
6: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 7: aload 2
invokevirtual com.google.common.collect.HashMultimap.entries:()Ljava/util/Set;
aload 3
aload 0
invokedynamic accept(Ljava/util/Collection;Ljava/lang/String;)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/schema/LegacySchemaMigrator.lambda$18(Ljava/util/Collection;Ljava/lang/String;Ljava/util/Map$Entry;)V (6)
(Ljava/util/Map$Entry;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
8: aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 keyspaceName Ljava/lang/String;
4 9 1 query Ljava/lang/String;
5 9 2 functionSignatures Lcom/google/common/collect/HashMultimap<Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;>;
7 9 3 functions Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;>;
Signature: (Ljava/lang/String;)Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;>;
MethodParameters:
Name Flags
keyspaceName
private static org.apache.cassandra.schema.LegacySchemaMigrator$Function readFunction(java.lang.String, java.lang.String, java.util.List<java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=6, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
aload 2
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readFunctionTimestamp:(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)J
lstore 3
start local 3 1: aload 0
aload 1
aload 2
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readFunctionMetadata:(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/apache/cassandra/cql3/functions/UDFunction;
astore 5
start local 5 2: new org.apache.cassandra.schema.LegacySchemaMigrator$Function
dup
lload 3
aload 5
invokespecial org.apache.cassandra.schema.LegacySchemaMigrator$Function.<init>:(JLorg/apache/cassandra/cql3/functions/UDFunction;)V
areturn
end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 keyspaceName Ljava/lang/String;
0 3 1 functionName Ljava/lang/String;
0 3 2 signature Ljava/util/List<Ljava/lang/String;>;
1 3 3 timestamp J
2 3 5 metadata Lorg/apache/cassandra/cql3/functions/UDFunction;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;
MethodParameters:
Name Flags
keyspaceName
functionName
signature
private static long readFunctionTimestamp(java.lang.String, java.lang.String, java.util.List<java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)J
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: ldc "SELECT writeTime(return_type) AS timestamp FROM %s.%s WHERE keyspace_name = ? AND function_name = ? AND signature = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_functions"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 3
start local 3 4: aload 3
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "timestamp"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getLong:(Ljava/lang/String;)J
lreturn
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 functionName Ljava/lang/String;
0 5 2 signature Ljava/util/List<Ljava/lang/String;>;
4 5 3 query Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)J
MethodParameters:
Name Flags
keyspaceName
functionName
signature
private static org.apache.cassandra.cql3.functions.UDFunction readFunctionMetadata(java.lang.String, java.lang.String, java.util.List<java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/apache/cassandra/cql3/functions/UDFunction;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=8, locals=13, args_size=3
start local 0 start local 1 start local 2 0: ldc "SELECT * FROM %s.%s WHERE keyspace_name = ? AND function_name = ? AND signature = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_functions"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 3
start local 3 4: aload 3
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 4
start local 4 5: new org.apache.cassandra.cql3.functions.FunctionName
dup
aload 0
aload 1
invokespecial org.apache.cassandra.cql3.functions.FunctionName.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 5
start local 5 6: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 6
start local 6 7: aload 4
ldc "argument_names"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 12
8: aload 4
ldc "argument_names"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getList:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 8
goto 11
StackMap locals: java.lang.String java.lang.String java.util.List java.lang.String org.apache.cassandra.cql3.UntypedResultSet$Row org.apache.cassandra.cql3.functions.FunctionName java.util.List top java.util.Iterator
StackMap stack:
9: aload 8
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 7
start local 7 10: aload 6
new org.apache.cassandra.cql3.ColumnIdentifier
dup
aload 7
iconst_1
invokespecial org.apache.cassandra.cql3.ColumnIdentifier.<init>:(Ljava/lang/String;Z)V
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 7 11: StackMap locals:
StackMap stack:
aload 8
invokeinterface java.util.Iterator.hasNext:()Z
ifne 9
12: StackMap locals: java.lang.String java.lang.String java.util.List java.lang.String org.apache.cassandra.cql3.UntypedResultSet$Row org.apache.cassandra.cql3.functions.FunctionName java.util.List
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 7
start local 7 13: aload 4
ldc "argument_types"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 18
14: aload 4
ldc "argument_types"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getList:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/List;
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 9
goto 17
StackMap locals: java.lang.String java.lang.String java.util.List java.lang.String org.apache.cassandra.cql3.UntypedResultSet$Row org.apache.cassandra.cql3.functions.FunctionName java.util.List java.util.List top java.util.Iterator
StackMap stack:
15: aload 9
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 8
start local 8 16: aload 7
aload 8
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.parseType:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 8 17: StackMap locals:
StackMap stack:
aload 9
invokeinterface java.util.Iterator.hasNext:()Z
ifne 15
18: StackMap locals: java.lang.String java.lang.String java.util.List java.lang.String org.apache.cassandra.cql3.UntypedResultSet$Row org.apache.cassandra.cql3.functions.FunctionName java.util.List java.util.List
StackMap stack:
aload 4
ldc "return_type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.parseType:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
astore 8
start local 8 19: aload 4
ldc "language"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 9
start local 9 20: aload 4
ldc "body"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
astore 10
start local 10 21: aload 4
ldc "called_on_null_input"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getBoolean:(Ljava/lang/String;)Z
istore 11
start local 11 22: aload 5
aload 6
aload 7
aload 8
iload 11
aload 9
aload 10
invokestatic org.apache.cassandra.cql3.functions.UDFunction.create:(Lorg/apache/cassandra/cql3/functions/FunctionName;Ljava/util/List;Ljava/util/List;Lorg/apache/cassandra/db/marshal/AbstractType;ZLjava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/cql3/functions/UDFunction;
23: areturn
24: StackMap locals: java.lang.String java.lang.String java.util.List java.lang.String org.apache.cassandra.cql3.UntypedResultSet$Row org.apache.cassandra.cql3.functions.FunctionName java.util.List java.util.List org.apache.cassandra.db.marshal.AbstractType java.lang.String java.lang.String int
StackMap stack: org.apache.cassandra.exceptions.InvalidRequestException
astore 12
start local 12 25: aload 5
aload 6
aload 7
aload 8
iload 11
aload 9
aload 10
aload 12
invokestatic org.apache.cassandra.cql3.functions.UDFunction.createBrokenFunction:(Lorg/apache/cassandra/cql3/functions/FunctionName;Ljava/util/List;Ljava/util/List;Lorg/apache/cassandra/db/marshal/AbstractType;ZLjava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/exceptions/InvalidRequestException;)Lorg/apache/cassandra/cql3/functions/UDFunction;
areturn
end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 26 0 keyspaceName Ljava/lang/String;
0 26 1 functionName Ljava/lang/String;
0 26 2 signature Ljava/util/List<Ljava/lang/String;>;
4 26 3 query Ljava/lang/String;
5 26 4 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
6 26 5 name Lorg/apache/cassandra/cql3/functions/FunctionName;
7 26 6 argNames Ljava/util/List<Lorg/apache/cassandra/cql3/ColumnIdentifier;>;
10 11 7 arg Ljava/lang/String;
13 26 7 argTypes Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
16 17 8 type Ljava/lang/String;
19 26 8 returnType Lorg/apache/cassandra/db/marshal/AbstractType<*>;
20 26 9 language Ljava/lang/String;
21 26 10 body Ljava/lang/String;
22 26 11 calledOnNullInput Z
25 26 12 e Lorg/apache/cassandra/exceptions/InvalidRequestException;
Exception table:
from to target type
22 23 24 Class org.apache.cassandra.exceptions.InvalidRequestException
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)Lorg/apache/cassandra/cql3/functions/UDFunction;
MethodParameters:
Name Flags
keyspaceName
functionName
signature
private static java.util.Collection<org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate> readAggregates(org.apache.cassandra.schema.Functions, java.lang.String);
descriptor: (Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;)Ljava/util/Collection;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=5, args_size=2
start local 0 start local 1 0: ldc "SELECT aggregate_name, signature FROM %s.%s WHERE keyspace_name = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_aggregates"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 2
start local 2 4: invokestatic com.google.common.collect.HashMultimap.create:()Lcom/google/common/collect/HashMultimap;
astore 3
start local 3 5: aload 2
iconst_1
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
aload 3
invokedynamic accept(Lcom/google/common/collect/HashMultimap;)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/schema/LegacySchemaMigrator.lambda$19(Lcom/google/common/collect/HashMultimap;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V (6)
(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.forEach:(Ljava/util/function/Consumer;)V
6: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 4
start local 4 7: aload 3
invokevirtual com.google.common.collect.HashMultimap.entries:()Ljava/util/Set;
aload 4
aload 0
aload 1
invokedynamic accept(Ljava/util/Collection;Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;)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/schema/LegacySchemaMigrator.lambda$20(Ljava/util/Collection;Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;Ljava/util/Map$Entry;)V (6)
(Ljava/util/Map$Entry;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
8: aload 4
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 functions Lorg/apache/cassandra/schema/Functions;
0 9 1 keyspaceName Ljava/lang/String;
4 9 2 query Ljava/lang/String;
5 9 3 aggregateSignatures Lcom/google/common/collect/HashMultimap<Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;>;
7 9 4 aggregates Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Aggregate;>;
Signature: (Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;)Ljava/util/Collection<Lorg/apache/cassandra/schema/LegacySchemaMigrator$Aggregate;>;
MethodParameters:
Name Flags
functions
keyspaceName
private static org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate readAggregate(org.apache.cassandra.schema.Functions, java.lang.String, java.lang.String, java.util.List<java.lang.String>);
descriptor: (Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Aggregate;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=7, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
aload 2
aload 3
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readAggregateTimestamp:(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)J
lstore 4
start local 4 1: aload 0
aload 1
aload 2
aload 3
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readAggregateMetadata:(Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/apache/cassandra/cql3/functions/UDAggregate;
astore 6
start local 6 2: new org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate
dup
lload 4
aload 6
invokespecial org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate.<init>:(JLorg/apache/cassandra/cql3/functions/UDAggregate;)V
areturn
end local 6 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 functions Lorg/apache/cassandra/schema/Functions;
0 3 1 keyspaceName Ljava/lang/String;
0 3 2 aggregateName Ljava/lang/String;
0 3 3 signature Ljava/util/List<Ljava/lang/String;>;
1 3 4 timestamp J
2 3 6 metadata Lorg/apache/cassandra/cql3/functions/UDAggregate;
Signature: (Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Aggregate;
MethodParameters:
Name Flags
functions
keyspaceName
aggregateName
signature
private static long readAggregateTimestamp(java.lang.String, java.lang.String, java.util.List<java.lang.String>);
descriptor: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)J
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=4, args_size=3
start local 0 start local 1 start local 2 0: ldc "SELECT writeTime(return_type) AS timestamp FROM %s.%s WHERE keyspace_name = ? AND aggregate_name = ? AND signature = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_aggregates"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 3
start local 3 4: aload 3
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 0
aastore
dup
iconst_1
aload 1
aastore
dup
iconst_2
aload 2
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
ldc "timestamp"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getLong:(Ljava/lang/String;)J
lreturn
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 aggregateName Ljava/lang/String;
0 5 2 signature Ljava/util/List<Ljava/lang/String;>;
4 5 3 query Ljava/lang/String;
Signature: (Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)J
MethodParameters:
Name Flags
keyspaceName
aggregateName
signature
private static org.apache.cassandra.cql3.functions.UDAggregate readAggregateMetadata(org.apache.cassandra.schema.Functions, java.lang.String, java.lang.String, java.util.List<java.lang.String>);
descriptor: (Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/apache/cassandra/cql3/functions/UDAggregate;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=8, locals=15, args_size=4
start local 0 start local 1 start local 2 start local 3 0: ldc "SELECT * FROM %s.%s WHERE keyspace_name = ? AND aggregate_name = ? AND signature = ?"
iconst_2
anewarray java.lang.Object
dup
iconst_0
1: ldc "system"
aastore
dup
iconst_1
2: ldc "schema_aggregates"
aastore
3: invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 4
start local 4 4: aload 4
iconst_3
anewarray java.lang.Object
dup
iconst_0
aload 1
aastore
dup
iconst_1
aload 2
aastore
dup
iconst_2
aload 3
aastore
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.query:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet.one:()Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
astore 5
start local 5 5: new org.apache.cassandra.cql3.functions.FunctionName
dup
aload 1
aload 2
invokespecial org.apache.cassandra.cql3.functions.FunctionName.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 6
start local 6 6: aload 5
ldc "argument_types"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getList:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/List;
astore 7
start local 7 7: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 8
start local 8 8: aload 7
ifnull 14
9: new java.util.ArrayList
dup
aload 7
invokeinterface java.util.List.size:()I
invokespecial java.util.ArrayList.<init>:(I)V
astore 8
10: aload 7
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
astore 10
goto 13
StackMap locals: org.apache.cassandra.schema.Functions java.lang.String java.lang.String java.util.List java.lang.String org.apache.cassandra.cql3.UntypedResultSet$Row org.apache.cassandra.cql3.functions.FunctionName java.util.List java.util.List top java.util.Iterator
StackMap stack:
11: aload 10
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast java.lang.String
astore 9
start local 9 12: aload 8
aload 9
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.parseType:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 9 13: StackMap locals:
StackMap stack:
aload 10
invokeinterface java.util.Iterator.hasNext:()Z
ifne 11
14: StackMap locals: org.apache.cassandra.schema.Functions java.lang.String java.lang.String java.util.List java.lang.String org.apache.cassandra.cql3.UntypedResultSet$Row org.apache.cassandra.cql3.functions.FunctionName java.util.List java.util.List
StackMap stack:
aload 5
ldc "return_type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.parseType:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
astore 9
start local 9 15: new org.apache.cassandra.cql3.functions.FunctionName
dup
aload 1
aload 5
ldc "state_func"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokespecial org.apache.cassandra.cql3.functions.FunctionName.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 10
start local 10 16: aload 5
ldc "state_type"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.parseType:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
astore 11
start local 11 17: aload 5
ldc "final_func"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 18
new org.apache.cassandra.cql3.functions.FunctionName
dup
aload 1
aload 5
ldc "final_func"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokespecial org.apache.cassandra.cql3.functions.FunctionName.<init>:(Ljava/lang/String;Ljava/lang/String;)V
goto 19
StackMap locals: org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.functions.FunctionName org.apache.cassandra.db.marshal.AbstractType
StackMap stack:
18: aconst_null
StackMap locals:
StackMap stack: org.apache.cassandra.cql3.functions.FunctionName
19: astore 12
start local 12 20: aload 5
ldc "initcond"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.has:(Ljava/lang/String;)Z
ifeq 21
aload 5
ldc "initcond"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getBytes:(Ljava/lang/String;)Ljava/nio/ByteBuffer;
goto 22
StackMap locals: org.apache.cassandra.cql3.functions.FunctionName
StackMap stack:
21: aconst_null
StackMap locals:
StackMap stack: java.nio.ByteBuffer
22: astore 13
start local 13 23: aload 0
aload 6
aload 8
aload 9
aload 10
aload 12
aload 11
aload 13
invokestatic org.apache.cassandra.cql3.functions.UDAggregate.create:(Lorg/apache/cassandra/schema/Functions;Lorg/apache/cassandra/cql3/functions/FunctionName;Ljava/util/List;Lorg/apache/cassandra/db/marshal/AbstractType;Lorg/apache/cassandra/cql3/functions/FunctionName;Lorg/apache/cassandra/cql3/functions/FunctionName;Lorg/apache/cassandra/db/marshal/AbstractType;Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/cql3/functions/UDAggregate;
24: areturn
25: StackMap locals: org.apache.cassandra.schema.Functions java.lang.String java.lang.String java.util.List java.lang.String org.apache.cassandra.cql3.UntypedResultSet$Row org.apache.cassandra.cql3.functions.FunctionName java.util.List java.util.List org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.functions.FunctionName org.apache.cassandra.db.marshal.AbstractType org.apache.cassandra.cql3.functions.FunctionName java.nio.ByteBuffer
StackMap stack: org.apache.cassandra.exceptions.InvalidRequestException
astore 14
start local 14 26: aload 6
aload 8
aload 9
aload 13
aload 14
invokestatic org.apache.cassandra.cql3.functions.UDAggregate.createBroken:(Lorg/apache/cassandra/cql3/functions/FunctionName;Ljava/util/List;Lorg/apache/cassandra/db/marshal/AbstractType;Ljava/nio/ByteBuffer;Lorg/apache/cassandra/exceptions/InvalidRequestException;)Lorg/apache/cassandra/cql3/functions/UDAggregate;
areturn
end local 14 end local 13 end local 12 end local 11 end local 10 end local 9 end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 27 0 functions Lorg/apache/cassandra/schema/Functions;
0 27 1 keyspaceName Ljava/lang/String;
0 27 2 functionName Ljava/lang/String;
0 27 3 signature Ljava/util/List<Ljava/lang/String;>;
4 27 4 query Ljava/lang/String;
5 27 5 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
6 27 6 name Lorg/apache/cassandra/cql3/functions/FunctionName;
7 27 7 types Ljava/util/List<Ljava/lang/String;>;
8 27 8 argTypes Ljava/util/List<Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
12 13 9 type Ljava/lang/String;
15 27 9 returnType Lorg/apache/cassandra/db/marshal/AbstractType<*>;
16 27 10 stateFunc Lorg/apache/cassandra/cql3/functions/FunctionName;
17 27 11 stateType Lorg/apache/cassandra/db/marshal/AbstractType<*>;
20 27 12 finalFunc Lorg/apache/cassandra/cql3/functions/FunctionName;
23 27 13 initcond Ljava/nio/ByteBuffer;
26 27 14 reason Lorg/apache/cassandra/exceptions/InvalidRequestException;
Exception table:
from to target type
23 24 25 Class org.apache.cassandra.exceptions.InvalidRequestException
Signature: (Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;)Lorg/apache/cassandra/cql3/functions/UDAggregate;
MethodParameters:
Name Flags
functions
keyspaceName
functionName
signature
private static org.apache.cassandra.cql3.UntypedResultSet query(java.lang.String, java.lang.Object[]);
descriptor: (Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
flags: (0x008a) ACC_PRIVATE, ACC_STATIC, ACC_VARARGS
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokestatic org.apache.cassandra.cql3.QueryProcessor.executeOnceInternal:(Ljava/lang/String;[Ljava/lang/Object;)Lorg/apache/cassandra/cql3/UntypedResultSet;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 query Ljava/lang/String;
0 1 1 values [Ljava/lang/Object;
MethodParameters:
Name Flags
query
values
private static org.apache.cassandra.db.marshal.AbstractType<?> parseType(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic org.apache.cassandra.db.marshal.TypeParser.parse:(Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 str Ljava/lang/String;
Signature: (Ljava/lang/String;)Lorg/apache/cassandra/db/marshal/AbstractType<*>;
MethodParameters:
Name Flags
str
private static void lambda$3(org.apache.cassandra.schema.LegacySchemaMigrator$Table, org.apache.cassandra.schema.IndexMetadata);
descriptor: (Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;Lorg/apache/cassandra/schema/IndexMetadata;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Table.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
1: aload 0
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Table.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
2: aload 1
3: invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.migrateIndexBuildStatus:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/cassandra/schema/IndexMetadata;)V
4: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 5 1 index Lorg/apache/cassandra/schema/IndexMetadata;
private static void lambda$5(org.apache.cassandra.config.CFMetaData);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic org.apache.cassandra.db.Keyspace.openAndGetStore:(Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.invalidate:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cfm Lorg/apache/cassandra/config/CFMetaData;
private static void lambda$6(org.apache.cassandra.config.CFMetaData);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
aload 0
getfield org.apache.cassandra.config.CFMetaData.cfId:Ljava/util/UUID;
invokevirtual org.apache.cassandra.config.Schema.getColumnFamilyStoreInstance:(Ljava/util/UUID;)Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.truncateBlocking:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 table Lorg/apache/cassandra/config/CFMetaData;
private static void lambda$7(java.util.Collection, org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 0
aload 1
ldc "keyspace_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
private static void lambda$8(java.util.Collection, java.lang.String);
descriptor: (Ljava/util/Collection;Ljava/lang/String;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readKeyspace:(Ljava/lang/String;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Keyspace;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 name Ljava/lang/String;
private static void lambda$9(org.apache.cassandra.schema.Functions$Builder, org.apache.cassandra.schema.LegacySchemaMigrator$Function);
descriptor: (Lorg/apache/cassandra/schema/Functions$Builder;Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
getfield org.apache.cassandra.schema.LegacySchemaMigrator$Function.metadata:Lorg/apache/cassandra/cql3/functions/UDFunction;
invokevirtual org.apache.cassandra.schema.Functions$Builder.add:(Lorg/apache/cassandra/cql3/functions/Function;)Lorg/apache/cassandra/schema/Functions$Builder;
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 udf Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;
private static void lambda$10(java.util.Collection, org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 0
aload 1
ldc "columnfamily_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
private static void lambda$11(java.util.Collection, java.lang.String, java.lang.String);
descriptor: (Ljava/util/Collection;Ljava/lang/String;Ljava/lang/String;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 0
aload 1
aload 2
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readTable:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Table;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 name Ljava/lang/String;
private static void lambda$12(org.apache.cassandra.schema.Triggers$Builder, org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Lorg/apache/cassandra/schema/Triggers$Builder;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.createTriggerFromTriggerRow:(Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)Lorg/apache/cassandra/schema/TriggerMetadata;
invokevirtual org.apache.cassandra.schema.Triggers$Builder.add:(Lorg/apache/cassandra/schema/TriggerMetadata;)Lorg/apache/cassandra/schema/Triggers$Builder;
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
private static void lambda$13(java.util.Collection, org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 0
aload 1
ldc "type_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
private static void lambda$14(java.util.Collection, java.lang.String, java.lang.String);
descriptor: (Ljava/util/Collection;Ljava/lang/String;Ljava/lang/String;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 0
aload 1
aload 2
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readType:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Type;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 name Ljava/lang/String;
private static org.apache.cassandra.cql3.FieldIdentifier lambda$15(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/cql3/FieldIdentifier;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokestatic org.apache.cassandra.cql3.FieldIdentifier.forInternalString:(Ljava/lang/String;)Lorg/apache/cassandra/cql3/FieldIdentifier;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 t Ljava/lang/String;
private static void lambda$17(com.google.common.collect.HashMultimap, org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Lcom/google/common/collect/HashMultimap;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
start local 1 0: aload 0
aload 1
ldc "function_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
aload 1
ldc "signature"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getList:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/List;
invokevirtual com.google.common.collect.HashMultimap.put:(Ljava/lang/Object;Ljava/lang/Object;)Z
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
private static void lambda$18(java.util.Collection, java.lang.String, java.util.Map$Entry);
descriptor: (Ljava/util/Collection;Ljava/lang/String;Ljava/util/Map$Entry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 2 0: aload 0
aload 1
aload 2
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 2
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.util.List
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readFunction:(Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Function;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 pair Ljava/util/Map$Entry<Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;>;
private static void lambda$19(com.google.common.collect.HashMultimap, org.apache.cassandra.cql3.UntypedResultSet$Row);
descriptor: (Lcom/google/common/collect/HashMultimap;Lorg/apache/cassandra/cql3/UntypedResultSet$Row;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
start local 1 0: aload 0
aload 1
ldc "aggregate_name"
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getString:(Ljava/lang/String;)Ljava/lang/String;
aload 1
ldc "signature"
getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
invokevirtual org.apache.cassandra.cql3.UntypedResultSet$Row.getList:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Ljava/util/List;
invokevirtual com.google.common.collect.HashMultimap.put:(Ljava/lang/Object;Ljava/lang/Object;)Z
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 row Lorg/apache/cassandra/cql3/UntypedResultSet$Row;
private static void lambda$20(java.util.Collection, org.apache.cassandra.schema.Functions, java.lang.String, java.util.Map$Entry);
descriptor: (Ljava/util/Collection;Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;Ljava/util/Map$Entry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=4
start local 3 0: aload 0
aload 1
aload 2
aload 3
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 3
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.util.List
invokestatic org.apache.cassandra.schema.LegacySchemaMigrator.readAggregate:(Lorg/apache/cassandra/schema/Functions;Ljava/lang/String;Ljava/lang/String;Ljava/util/List;)Lorg/apache/cassandra/schema/LegacySchemaMigrator$Aggregate;
invokeinterface java.util.Collection.add:(Ljava/lang/Object;)Z
return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 1 3 pair Ljava/util/Map$Entry<Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;>;
}
SourceFile: "LegacySchemaMigrator.java"
NestMembers:
org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate org.apache.cassandra.schema.LegacySchemaMigrator$Function org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace org.apache.cassandra.schema.LegacySchemaMigrator$Table org.apache.cassandra.schema.LegacySchemaMigrator$Type
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 DroppedColumn = org.apache.cassandra.config.CFMetaData$DroppedColumn of org.apache.cassandra.config.CFMetaData
public final Kind = org.apache.cassandra.config.ColumnDefinition$Kind of org.apache.cassandra.config.ColumnDefinition
public Row = org.apache.cassandra.cql3.UntypedResultSet$Row of org.apache.cassandra.cql3.UntypedResultSet
public DefaultNames = org.apache.cassandra.db.CompactTables$DefaultNames of org.apache.cassandra.db.CompactTables
public abstract SimpleBuilder = org.apache.cassandra.db.Mutation$SimpleBuilder of org.apache.cassandra.db.Mutation
public final Option = org.apache.cassandra.schema.CompactionParams$Option of org.apache.cassandra.schema.CompactionParams
public final Builder = org.apache.cassandra.schema.Functions$Builder of org.apache.cassandra.schema.Functions
public final Kind = org.apache.cassandra.schema.IndexMetadata$Kind of org.apache.cassandra.schema.IndexMetadata
public final Builder = org.apache.cassandra.schema.Indexes$Builder of org.apache.cassandra.schema.Indexes
private final Aggregate = org.apache.cassandra.schema.LegacySchemaMigrator$Aggregate of org.apache.cassandra.schema.LegacySchemaMigrator
private final Function = org.apache.cassandra.schema.LegacySchemaMigrator$Function of org.apache.cassandra.schema.LegacySchemaMigrator
private final Keyspace = org.apache.cassandra.schema.LegacySchemaMigrator$Keyspace of org.apache.cassandra.schema.LegacySchemaMigrator
private final Table = org.apache.cassandra.schema.LegacySchemaMigrator$Table of org.apache.cassandra.schema.LegacySchemaMigrator
private final Type = org.apache.cassandra.schema.LegacySchemaMigrator$Type of org.apache.cassandra.schema.LegacySchemaMigrator
public final Builder = org.apache.cassandra.schema.TableParams$Builder of org.apache.cassandra.schema.TableParams
public final Builder = org.apache.cassandra.schema.Triggers$Builder of org.apache.cassandra.schema.Triggers