public class org.apache.cassandra.index.SecondaryIndexManager implements org.apache.cassandra.index.IndexRegistry
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.index.SecondaryIndexManager
super_class: java.lang.Object
{
private static final org.slf4j.Logger logger;
descriptor: Lorg/slf4j/Logger;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public static final int DEFAULT_PAGE_SIZE;
descriptor: I
flags: (0x0019) ACC_PUBLIC, ACC_STATIC, ACC_FINAL
ConstantValue: 10000
private java.util.Map<java.lang.String, org.apache.cassandra.index.Index> indexes;
descriptor: Ljava/util/Map;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Map<Ljava/lang/String;Lorg/apache/cassandra/index/Index;>;
private java.util.Set<java.lang.String> builtIndexes;
descriptor: Ljava/util/Set;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/Set<Ljava/lang/String;>;
private static final java.util.concurrent.ExecutorService asyncExecutor;
descriptor: Ljava/util/concurrent/ExecutorService;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static final java.util.concurrent.ExecutorService blockingExecutor;
descriptor: Ljava/util/concurrent/ExecutorService;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
public final org.apache.cassandra.db.ColumnFamilyStore baseCfs;
descriptor: Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x0011) ACC_PUBLIC, ACC_FINAL
static final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=10, locals=0, args_size=0
0: ldc Lorg/apache/cassandra/index/SecondaryIndexManager;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic org.apache.cassandra.index.SecondaryIndexManager.$assertionsDisabled:Z
3: ldc Lorg/apache/cassandra/index/SecondaryIndexManager;
invokestatic org.slf4j.LoggerFactory.getLogger:(Ljava/lang/Class;)Lorg/slf4j/Logger;
putstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
4: new org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor
dup
iconst_1
5: ldc 60
6: getstatic java.util.concurrent.TimeUnit.SECONDS:Ljava/util/concurrent/TimeUnit;
7: new java.util.concurrent.LinkedBlockingQueue
dup
invokespecial java.util.concurrent.LinkedBlockingQueue.<init>:()V
8: new org.apache.cassandra.concurrent.NamedThreadFactory
dup
ldc "SecondaryIndexManagement"
invokespecial org.apache.cassandra.concurrent.NamedThreadFactory.<init>:(Ljava/lang/String;)V
9: ldc "internal"
10: invokespecial org.apache.cassandra.concurrent.JMXEnabledThreadPoolExecutor.<init>:(IJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Lorg/apache/cassandra/concurrent/NamedThreadFactory;Ljava/lang/String;)V
11: putstatic org.apache.cassandra.index.SecondaryIndexManager.asyncExecutor:Ljava/util/concurrent/ExecutorService;
12: invokestatic com.google.common.util.concurrent.MoreExecutors.newDirectExecutorService:()Lcom/google/common/util/concurrent/ListeningExecutorService;
putstatic org.apache.cassandra.index.SecondaryIndexManager.blockingExecutor:Ljava/util/concurrent/ExecutorService;
return
LocalVariableTable:
Start End Slot Name Signature
public void <init>(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
invokestatic com.google.common.collect.Maps.newConcurrentMap:()Ljava/util/concurrent/ConcurrentMap;
putfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
2: aload 0
invokestatic com.google.common.collect.Sets.newConcurrentHashSet:()Ljava/util/Set;
putfield org.apache.cassandra.index.SecondaryIndexManager.builtIndexes:Ljava/util/Set;
3: aload 0
aload 1
putfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 5 1 baseCfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
baseCfs
public void reload();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.getIndexes:()Lorg/apache/cassandra/schema/Indexes;
astore 1
start local 1 1: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.keySet:()Ljava/util/Set;
2: invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
3: aload 1
invokedynamic test(Lorg/apache/cassandra/schema/Indexes;)Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/index/SecondaryIndexManager.lambda$0(Lorg/apache/cassandra/schema/Indexes;Ljava/lang/String;)Z (6)
(Ljava/lang/String;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
4: aload 0
invokedynamic accept(Lorg/apache/cassandra/index/SecondaryIndexManager;)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/index/SecondaryIndexManager.removeIndex(Ljava/lang/String;)V (5)
(Ljava/lang/String;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
5: aload 1
invokevirtual org.apache.cassandra.schema.Indexes.iterator:()Ljava/util/Iterator;
astore 4
goto 8
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.schema.Indexes top top java.util.Iterator
StackMap stack:
6: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.schema.IndexMetadata
astore 3
start local 3 7: aload 0
aload 3
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.addIndex:(Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future;
pop
end local 3 8: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 6
9: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
1 10 1 tableIndexes Lorg/apache/cassandra/schema/Indexes;
7 8 3 tableIndex Lorg/apache/cassandra/schema/IndexMetadata;
private java.util.concurrent.Future<?> reloadIndex(org.apache.cassandra.schema.IndexMetadata);
descriptor: (Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
astore 2
start local 2 1: aload 2
aload 1
invokeinterface org.apache.cassandra.index.Index.getMetadataReloadTask:(Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Callable;
astore 3
start local 3 2: aload 3
ifnonnull 4
3: aconst_null
invokestatic com.google.common.util.concurrent.Futures.immediateFuture:(Ljava/lang/Object;)Lcom/google/common/util/concurrent/ListenableFuture;
goto 5
4: StackMap locals: org.apache.cassandra.index.Index java.util.concurrent.Callable
StackMap stack:
getstatic org.apache.cassandra.index.SecondaryIndexManager.blockingExecutor:Ljava/util/concurrent/ExecutorService;
aload 3
invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
5: StackMap locals:
StackMap stack: java.util.concurrent.Future
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 6 1 indexDef Lorg/apache/cassandra/schema/IndexMetadata;
1 6 2 index Lorg/apache/cassandra/index/Index;
2 6 3 reloadTask Ljava/util/concurrent/Callable<*>;
Signature: (Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future<*>;
MethodParameters:
Name Flags
indexDef
private java.util.concurrent.Future<?> createIndex(org.apache.cassandra.schema.IndexMetadata);
descriptor: (Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future;
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.createInstance:(Lorg/apache/cassandra/schema/IndexMetadata;)Lorg/apache/cassandra/index/Index;
astore 2
start local 2 1: aload 2
aload 0
invokeinterface org.apache.cassandra.index.Index.register:(Lorg/apache/cassandra/index/IndexRegistry;)V
2: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 4
3: aload 2
invokeinterface org.apache.cassandra.index.Index.getInitializationTask:()Ljava/util/concurrent/Callable;
goto 5
4: StackMap locals: org.apache.cassandra.index.Index
StackMap stack:
aconst_null
5: StackMap locals:
StackMap stack: java.util.concurrent.Callable
astore 3
start local 3 6: aload 3
ifnonnull 9
7: aload 0
aload 1
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.markIndexBuilt:(Ljava/lang/String;)V
8: aconst_null
invokestatic com.google.common.util.concurrent.Futures.immediateFuture:(Ljava/lang/Object;)Lcom/google/common/util/concurrent/ListenableFuture;
areturn
9: StackMap locals: java.util.concurrent.Callable
StackMap stack:
getstatic org.apache.cassandra.index.SecondaryIndexManager.asyncExecutor:Ljava/util/concurrent/ExecutorService;
aload 2
invokeinterface org.apache.cassandra.index.Index.getInitializationTask:()Ljava/util/concurrent/Callable;
invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 10 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 10 1 indexDef Lorg/apache/cassandra/schema/IndexMetadata;
1 10 2 index Lorg/apache/cassandra/index/Index;
6 10 3 initialBuildTask Ljava/util/concurrent/Callable<*>;
Signature: (Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future<*>;
MethodParameters:
Name Flags
indexDef
public synchronized java.util.concurrent.Future<?> addIndex(org.apache.cassandra.schema.IndexMetadata);
descriptor: (Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future;
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokeinterface java.util.Map.containsKey:(Ljava/lang/Object;)Z
ifeq 2
1: aload 0
aload 1
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.reloadIndex:(Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future;
areturn
2: StackMap locals:
StackMap stack:
aload 0
aload 1
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.createIndex:(Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 3 1 indexDef Lorg/apache/cassandra/schema/IndexMetadata;
Signature: (Lorg/apache/cassandra/schema/IndexMetadata;)Ljava/util/concurrent/Future<*>;
MethodParameters:
Name Flags
indexDef
public boolean isIndexQueryable(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.builtIndexes:Ljava/util/Set;
aload 1
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 1 1 index Lorg/apache/cassandra/index/Index;
MethodParameters:
Name Flags
index
public synchronized void removeIndex(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0021) ACC_PUBLIC, ACC_SYNCHRONIZED
Code:
stack=2, locals=3, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.unregisterIndex:(Ljava/lang/String;)Lorg/apache/cassandra/index/Index;
astore 2
start local 2 1: aload 2
ifnull 4
2: aload 0
aload 1
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.markIndexRemoved:(Ljava/lang/String;)V
3: aload 2
invokeinterface org.apache.cassandra.index.Index.getInvalidateTask:()Ljava/util/concurrent/Callable;
invokestatic org.apache.cassandra.index.SecondaryIndexManager.executeBlocking:(Ljava/util/concurrent/Callable;)V
4: StackMap locals: org.apache.cassandra.index.Index
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 5 1 indexName Ljava/lang/String;
1 5 2 index Lorg/apache/cassandra/index/Index;
MethodParameters:
Name Flags
indexName
public java.util.Set<org.apache.cassandra.schema.IndexMetadata> getDependentIndexes(org.apache.cassandra.config.ColumnDefinition);
descriptor: (Lorg/apache/cassandra/config/ColumnDefinition;)Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=5, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifeq 2
1: invokestatic java.util.Collections.emptySet:()Ljava/util/Set;
areturn
2: StackMap locals:
StackMap stack:
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 3: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 4
goto 7
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.config.ColumnDefinition java.util.Set top java.util.Iterator
StackMap stack:
4: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
astore 3
start local 3 5: aload 3
aload 1
invokeinterface org.apache.cassandra.index.Index.dependsOn:(Lorg/apache/cassandra/config/ColumnDefinition;)Z
ifeq 7
6: aload 2
aload 3
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 3 7: StackMap locals:
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
8: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 9 1 column Lorg/apache/cassandra/config/ColumnDefinition;
3 9 2 dependentIndexes Ljava/util/Set<Lorg/apache/cassandra/schema/IndexMetadata;>;
5 7 3 index Lorg/apache/cassandra/index/Index;
Signature: (Lorg/apache/cassandra/config/ColumnDefinition;)Ljava/util/Set<Lorg/apache/cassandra/schema/IndexMetadata;>;
MethodParameters:
Name Flags
column
public void markAllIndexesRemoved();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.getBuiltIndexNames:()Ljava/util/List;
aload 0
invokedynamic accept(Lorg/apache/cassandra/index/SecondaryIndexManager;)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/index/SecondaryIndexManager.markIndexRemoved(Ljava/lang/String;)V (5)
(Ljava/lang/String;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
public void rebuildIndexesBlocking(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, java.util.Set<java.lang.String>);
descriptor: (Ljava/util/Collection;Ljava/util/Set;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
1: aload 2
invokedynamic test(Ljava/util/Set;)Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/index/SecondaryIndexManager.lambda$3(Ljava/util/Set;Lorg/apache/cassandra/index/Index;)Z (6)
(Lorg/apache/cassandra/index/Index;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
2: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/index/Index.shouldBuildBlocking()Z (9 itf)
(Lorg/apache/cassandra/index/Index;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
3: invokestatic java.util.stream.Collectors.toSet:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Set
4: astore 3
start local 3 5: aload 3
invokeinterface java.util.Set.isEmpty:()Z
ifeq 8
6: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "No defined indexes with the supplied names: {}"
bipush 44
invokestatic com.google.common.base.Joiner.on:(C)Lcom/google/common/base/Joiner;
aload 2
invokevirtual com.google.common.base.Joiner.join:(Ljava/lang/Iterable;)Ljava/lang/String;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
7: return
8: StackMap locals: java.util.Set
StackMap stack:
aload 3
aload 0
invokedynamic accept(Lorg/apache/cassandra/index/SecondaryIndexManager;)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/index/SecondaryIndexManager.lambda$5(Lorg/apache/cassandra/index/Index;)V (7)
(Lorg/apache/cassandra/index/Index;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
9: aload 0
aload 1
aload 3
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.buildIndexesBlocking:(Ljava/util/Collection;Ljava/util/Set;)V
10: aload 3
aload 0
invokedynamic accept(Lorg/apache/cassandra/index/SecondaryIndexManager;)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/index/SecondaryIndexManager.lambda$6(Lorg/apache/cassandra/index/Index;)V (7)
(Lorg/apache/cassandra/index/Index;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
11: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 12 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 12 2 indexNames Ljava/util/Set<Ljava/lang/String;>;
5 12 3 toRebuild Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/util/Set<Ljava/lang/String;>;)V
MethodParameters:
Name Flags
sstables
indexNames
public void buildAllIndexesBlocking(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>);
descriptor: (Ljava/util/Collection;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
1: invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
2: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/index/Index.shouldBuildBlocking()Z (9 itf)
(Lorg/apache/cassandra/index/Index;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
3: invokestatic java.util.stream.Collectors.toSet:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Set
4: invokevirtual org.apache.cassandra.index.SecondaryIndexManager.buildIndexesBlocking:(Ljava/util/Collection;Ljava/util/Set;)V
5: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 6 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;)V
MethodParameters:
Name Flags
sstables
public void buildIndexBlocking(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface org.apache.cassandra.index.Index.shouldBuildBlocking:()Z
ifeq 17
1: aconst_null
astore 2
aconst_null
astore 3
2: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getstatic org.apache.cassandra.db.lifecycle.SSTableSet.CANONICAL:Lorg/apache/cassandra/db/lifecycle/SSTableSet;
invokestatic org.apache.cassandra.db.lifecycle.View.selectFunction:(Lorg/apache/cassandra/db/lifecycle/SSTableSet;)Lcom/google/common/base/Function;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.selectAndReference:(Lcom/google/common/base/Function;)Lorg/apache/cassandra/db/ColumnFamilyStore$RefViewFragment;
astore 4
start local 4 3: aload 4
getfield org.apache.cassandra.db.ColumnFamilyStore$RefViewFragment.refs:Lorg/apache/cassandra/utils/concurrent/Refs;
astore 5
start local 5 4: aload 0
aload 5
aload 1
invokestatic java.util.Collections.singleton:(Ljava/lang/Object;)Ljava/util/Set;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.buildIndexesBlocking:(Ljava/util/Collection;Ljava/util/Set;)V
5: aload 0
aload 1
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.markIndexBuilt:(Ljava/lang/String;)V
6: aload 5
ifnull 9
aload 5
invokevirtual org.apache.cassandra.utils.concurrent.Refs.close:()V
goto 9
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.index.Index java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ColumnFamilyStore$RefViewFragment org.apache.cassandra.utils.concurrent.Refs
StackMap stack: java.lang.Throwable
7: astore 2
aload 5
ifnull 8
aload 5
invokevirtual org.apache.cassandra.utils.concurrent.Refs.close:()V
end local 5 StackMap locals:
StackMap stack:
8: aload 2
athrow
StackMap locals:
StackMap stack:
9: aload 4
ifnull 17
aload 4
invokevirtual org.apache.cassandra.db.ColumnFamilyStore$RefViewFragment.close:()V
goto 17
StackMap locals:
StackMap stack: java.lang.Throwable
10: astore 3
aload 2
ifnonnull 11
aload 3
astore 2
goto 12
StackMap locals:
StackMap stack:
11: aload 2
aload 3
if_acmpeq 12
aload 2
aload 3
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
12: aload 4
ifnull 13
aload 4
invokevirtual org.apache.cassandra.db.ColumnFamilyStore$RefViewFragment.close:()V
end local 4 StackMap locals:
StackMap stack:
13: aload 2
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
14: astore 3
aload 2
ifnonnull 15
aload 3
astore 2
goto 16
StackMap locals:
StackMap stack:
15: aload 2
aload 3
if_acmpeq 16
aload 2
aload 3
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
16: aload 2
athrow
17: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 18 1 index Lorg/apache/cassandra/index/Index;
3 13 4 viewFragment Lorg/apache/cassandra/db/ColumnFamilyStore$RefViewFragment;
4 8 5 sstables Lorg/apache/cassandra/utils/concurrent/Refs<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
Exception table:
from to target type
4 6 7 any
3 9 10 any
2 14 14 any
MethodParameters:
Name Flags
index
public static boolean isIndexColumnFamilyStore(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
invokestatic org.apache.cassandra.index.SecondaryIndexManager.isIndexColumnFamily:(Ljava/lang/String;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
cfs
public static boolean isIndexColumnFamily(java.lang.String);
descriptor: (Ljava/lang/String;)Z
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
ldc "."
invokevirtual java.lang.String.contains:(Ljava/lang/CharSequence;)Z
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cfName Ljava/lang/String;
MethodParameters:
Name Flags
cfName
public static org.apache.cassandra.db.ColumnFamilyStore getParentCfs(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)Lorg/apache/cassandra/db/ColumnFamilyStore;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
invokestatic org.apache.cassandra.index.SecondaryIndexManager.getParentCfsName:(Ljava/lang/String;)Ljava/lang/String;
astore 1
start local 1 1: aload 0
getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
aload 1
invokevirtual org.apache.cassandra.db.Keyspace.getColumnFamilyStore:(Ljava/lang/String;)Lorg/apache/cassandra/db/ColumnFamilyStore;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
1 2 1 parentCfs Ljava/lang/String;
MethodParameters:
Name Flags
cfs
public static java.lang.String getParentCfsName(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.index.SecondaryIndexManager.$assertionsDisabled:Z
ifne 1
aload 0
invokestatic org.apache.cassandra.index.SecondaryIndexManager.isIndexColumnFamily:(Ljava/lang/String;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
ldc "."
invokestatic org.apache.commons.lang3.StringUtils.substringBefore:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 cfName Ljava/lang/String;
MethodParameters:
Name Flags
cfName
public static java.lang.String getIndexName(org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.db.ColumnFamilyStore.name:Ljava/lang/String;
invokestatic org.apache.cassandra.index.SecondaryIndexManager.getIndexName:(Ljava/lang/String;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
MethodParameters:
Name Flags
cfs
public static java.lang.String getIndexName(java.lang.String);
descriptor: (Ljava/lang/String;)Ljava/lang/String;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: getstatic org.apache.cassandra.index.SecondaryIndexManager.$assertionsDisabled:Z
ifne 1
aload 0
invokestatic org.apache.cassandra.index.SecondaryIndexManager.isIndexColumnFamily:(Ljava/lang/String;)Z
ifne 1
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
1: StackMap locals:
StackMap stack:
aload 0
ldc "."
invokestatic org.apache.commons.lang3.StringUtils.substringAfter:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 cfName Ljava/lang/String;
MethodParameters:
Name Flags
cfName
private void buildIndexesBlocking(java.util.Collection<org.apache.cassandra.io.sstable.format.SSTableReader>, java.util.Set<org.apache.cassandra.index.Index>);
descriptor: (Ljava/util/Collection;Ljava/util/Set;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=7, args_size=3
start local 0 start local 1 start local 2 0: aload 2
invokeinterface java.util.Set.isEmpty:()Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "Submitting index build of {} for data in {}"
3: aload 2
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
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/index/SecondaryIndexManager.lambda$8(Lorg/apache/cassandra/index/Index;)Ljava/lang/String; (6)
(Lorg/apache/cassandra/index/Index;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
ldc ","
invokestatic java.util.stream.Collectors.joining:(Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
4: aload 1
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
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/io/sstable/SSTable.toString()Ljava/lang/String; (5)
(Lorg/apache/cassandra/io/sstable/format/SSTableReader;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
ldc ","
invokestatic java.util.stream.Collectors.joining:(Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
5: invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
6: new java.util.HashMap
dup
invokespecial java.util.HashMap.<init>:()V
astore 3
start local 3 7: aload 2
invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
astore 5
goto 11
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager java.util.Collection java.util.Set java.util.Map top java.util.Iterator
StackMap stack:
8: aload 5
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
astore 4
start local 4 9: aload 3
aload 4
invokeinterface org.apache.cassandra.index.Index.getBuildTaskSupport:()Lorg/apache/cassandra/index/Index$IndexBuildingSupport;
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/index/SecondaryIndexManager.lambda$10(Lorg/apache/cassandra/index/Index$IndexBuildingSupport;)Ljava/util/Set; (6)
(Lorg/apache/cassandra/index/Index$IndexBuildingSupport;)Ljava/util/Set;
invokeinterface java.util.Map.computeIfAbsent:(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object;
checkcast java.util.Set
astore 6
start local 6 10: aload 6
aload 4
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
end local 6 end local 4 11: StackMap locals:
StackMap stack:
aload 5
invokeinterface java.util.Iterator.hasNext:()Z
ifne 8
12: aload 3
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
13: invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
14: aload 0
aload 1
invokedynamic apply(Lorg/apache/cassandra/index/SecondaryIndexManager;Ljava/util/Collection;)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/index/SecondaryIndexManager.lambda$11(Ljava/util/Collection;Ljava/util/Map$Entry;)Lorg/apache/cassandra/index/SecondaryIndexBuilder; (7)
(Ljava/util/Map$Entry;)Lorg/apache/cassandra/index/SecondaryIndexBuilder;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
15: getstatic org.apache.cassandra.db.compaction.CompactionManager.instance:Lorg/apache/cassandra/db/compaction/CompactionManager;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic apply(Lorg/apache/cassandra/db/compaction/CompactionManager;)Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/compaction/CompactionManager.submitIndexBuild(Lorg/apache/cassandra/index/SecondaryIndexBuilder;)Ljava/util/concurrent/Future; (5)
(Lorg/apache/cassandra/index/SecondaryIndexBuilder;)Ljava/util/concurrent/Future;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
16: 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
17: astore 4
start local 4 18: aload 4
invokestatic org.apache.cassandra.utils.FBUtilities.waitOnFutures:(Ljava/lang/Iterable;)Ljava/util/List;
pop
19: aload 0
aload 2
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.flushIndexesBlocking:(Ljava/util/Set;)V
20: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "Index build of {} complete"
21: aload 2
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
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/index/SecondaryIndexManager.lambda$13(Lorg/apache/cassandra/index/Index;)Ljava/lang/String; (6)
(Lorg/apache/cassandra/index/Index;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
ldc ","
invokestatic java.util.stream.Collectors.joining:(Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
22: invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;)V
23: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 24 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 24 1 sstables Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;
0 24 2 indexes Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;
7 24 3 byType Ljava/util/Map<Lorg/apache/cassandra/index/Index$IndexBuildingSupport;Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;>;
9 11 4 index Lorg/apache/cassandra/index/Index;
10 11 6 stored Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;
18 24 4 futures Ljava/util/List<Ljava/util/concurrent/Future<*>;>;
Signature: (Ljava/util/Collection<Lorg/apache/cassandra/io/sstable/format/SSTableReader;>;Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;)V
MethodParameters:
Name Flags
sstables
indexes
public void markIndexBuilt(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.builtIndexes:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.add:(Ljava/lang/Object;)Z
pop
1: invokestatic org.apache.cassandra.config.DatabaseDescriptor.isDaemonInitialized:()Z
ifeq 3
2: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
aload 1
invokestatic org.apache.cassandra.db.SystemKeyspace.setIndexBuilt:(Ljava/lang/String;Ljava/lang/String;)V
3: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 4 1 indexName Ljava/lang/String;
MethodParameters:
Name Flags
indexName
public void markIndexRemoved(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
aload 1
invokestatic org.apache.cassandra.db.SystemKeyspace.setIndexRemoved:(Ljava/lang/String;Ljava/lang/String;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 2 1 indexName Ljava/lang/String;
MethodParameters:
Name Flags
indexName
public org.apache.cassandra.index.Index getIndexByName(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/index/Index;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 1 1 indexName Ljava/lang/String;
MethodParameters:
Name Flags
indexName
private org.apache.cassandra.index.Index createInstance(org.apache.cassandra.schema.IndexMetadata);
descriptor: (Lorg/apache/cassandra/schema/IndexMetadata;)Lorg/apache/cassandra/index/Index;
flags: (0x0002) ACC_PRIVATE
Code:
stack=5, locals=6, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.apache.cassandra.schema.IndexMetadata.isCustom:()Z
ifeq 10
1: getstatic org.apache.cassandra.index.SecondaryIndexManager.$assertionsDisabled:Z
ifne 2
aload 1
getfield org.apache.cassandra.schema.IndexMetadata.options:Ljava/util/Map;
ifnonnull 2
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
2: StackMap locals:
StackMap stack:
aload 1
getfield org.apache.cassandra.schema.IndexMetadata.options:Ljava/util/Map;
ldc "class_name"
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.lang.String
astore 3
start local 3 3: getstatic org.apache.cassandra.index.SecondaryIndexManager.$assertionsDisabled:Z
ifne 4
aload 3
invokestatic com.google.common.base.Strings.isNullOrEmpty:(Ljava/lang/String;)Z
ifeq 4
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
4: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.schema.IndexMetadata top java.lang.String
StackMap stack:
aload 3
ldc "Index"
invokestatic org.apache.cassandra.utils.FBUtilities.classForName:(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/Class;
astore 4
start local 4 5: aload 4
iconst_2
anewarray java.lang.Class
dup
iconst_0
ldc Lorg/apache/cassandra/db/ColumnFamilyStore;
aastore
dup
iconst_1
ldc Lorg/apache/cassandra/schema/IndexMetadata;
aastore
invokevirtual java.lang.Class.getConstructor:([Ljava/lang/Class;)Ljava/lang/reflect/Constructor;
astore 5
start local 5 6: aload 5
iconst_2
anewarray java.lang.Object
dup
iconst_0
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aastore
dup
iconst_1
aload 1
aastore
invokevirtual java.lang.reflect.Constructor.newInstance:([Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
astore 2
end local 5 end local 4 start local 2 7: goto 11
end local 2 8: StackMap locals:
StackMap stack: java.lang.Exception
astore 4
start local 4 9: new java.lang.RuntimeException
dup
aload 4
invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
athrow
end local 4 end local 3 10: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.schema.IndexMetadata
StackMap stack:
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 1
invokestatic org.apache.cassandra.index.internal.CassandraIndex.newIndex:(Lorg/apache/cassandra/db/ColumnFamilyStore;Lorg/apache/cassandra/schema/IndexMetadata;)Lorg/apache/cassandra/index/internal/CassandraIndex;
astore 2
start local 2 11: StackMap locals: org.apache.cassandra.index.Index
StackMap stack:
aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 12 1 indexDef Lorg/apache/cassandra/schema/IndexMetadata;
7 8 2 newIndex Lorg/apache/cassandra/index/Index;
11 12 2 newIndex Lorg/apache/cassandra/index/Index;
3 10 3 className Ljava/lang/String;
5 7 4 indexClass Ljava/lang/Class<+Lorg/apache/cassandra/index/Index;>;
6 7 5 ctor Ljava/lang/reflect/Constructor<+Lorg/apache/cassandra/index/Index;>;
9 10 4 e Ljava/lang/Exception;
Exception table:
from to target type
4 7 8 Class java.lang.Exception
MethodParameters:
Name Flags
indexDef
public void truncateAllIndexesBlocking(long);
descriptor: (J)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
lload 1
invokedynamic apply(J)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/index/SecondaryIndexManager.lambda$14(JLorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable; (6)
(Lorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable;
invokestatic org.apache.cassandra.index.SecondaryIndexManager.executeAllBlocking:(Ljava/util/stream/Stream;Ljava/util/function/Function;)V
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 2 1 truncatedAt J
MethodParameters:
Name Flags
truncatedAt final
public void invalidateAllIndexesBlocking();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.markAllIndexesRemoved:()V
1: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
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/index/Index.getInvalidateTask()Ljava/util/concurrent/Callable; (9 itf)
(Lorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable;
invokestatic org.apache.cassandra.index.SecondaryIndexManager.executeAllBlocking:(Ljava/util/stream/Stream;Ljava/util/function/Function;)V
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
public void flushAllIndexesBlocking();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokestatic com.google.common.collect.ImmutableSet.copyOf:(Ljava/util/Collection;)Lcom/google/common/collect/ImmutableSet;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.flushIndexesBlocking:(Ljava/util/Set;)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
public void flushIndexesBlocking(java.util.Set<org.apache.cassandra.index.Index>);
descriptor: (Ljava/util/Set;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface java.util.Set.isEmpty:()Z
ifeq 2
1: return
2: StackMap locals:
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 3: new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 3
start local 3 4: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getTracker:()Lorg/apache/cassandra/db/lifecycle/Tracker;
dup
astore 4
monitorenter
5: aload 1
aload 2
aload 3
invokedynamic accept(Ljava/util/List;Ljava/util/List;)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/index/SecondaryIndexManager.lambda$16(Ljava/util/List;Ljava/util/List;Lorg/apache/cassandra/index/Index;)V (6)
(Lorg/apache/cassandra/index/Index;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
6: aload 4
monitorexit
7: goto 10
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager java.util.Set java.util.List java.util.List org.apache.cassandra.db.lifecycle.Tracker
StackMap stack: java.lang.Throwable
8: aload 4
monitorexit
9: athrow
10: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
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/index/Index.getBlockingFlushTask()Ljava/util/concurrent/Callable; (9 itf)
(Lorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable;
invokestatic org.apache.cassandra.index.SecondaryIndexManager.executeAllBlocking:(Ljava/util/stream/Stream;Ljava/util/function/Function;)V
11: aload 2
invokestatic org.apache.cassandra.utils.FBUtilities.waitOnFutures:(Ljava/lang/Iterable;)Ljava/util/List;
pop
12: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 13 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 13 1 indexes Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;
3 13 2 wait Ljava/util/List<Ljava/util/concurrent/Future<*>;>;
4 13 3 nonCfsIndexes Ljava/util/List<Lorg/apache/cassandra/index/Index;>;
Exception table:
from to target type
5 7 8 any
8 9 8 any
Signature: (Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;)V
MethodParameters:
Name Flags
indexes
public void flushAllNonCFSBackedIndexesBlocking();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
1: invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
2: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/index/SecondaryIndexManager.lambda$20(Lorg/apache/cassandra/index/Index;)Z (6)
(Lorg/apache/cassandra/index/Index;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
3: 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/index/Index.getBlockingFlushTask()Ljava/util/concurrent/Callable; (9 itf)
(Lorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable;
4: invokestatic org.apache.cassandra.index.SecondaryIndexManager.executeAllBlocking:(Ljava/util/stream/Stream;Ljava/util/function/Function;)V
5: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
public void executePreJoinTasksBlocking(boolean);
descriptor: (Z)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "Executing pre-join{} tasks for: {}"
iload 1
ifeq 1
ldc " post-bootstrap"
goto 2
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager int
StackMap stack: org.slf4j.Logger java.lang.String
1: ldc ""
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager int
StackMap stack: org.slf4j.Logger java.lang.String java.lang.String
2: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokeinterface org.slf4j.Logger.info:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
3: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
iload 1
invokedynamic apply(Z)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/index/SecondaryIndexManager.lambda$22(ZLorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable; (6)
(Lorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable;
invokestatic org.apache.cassandra.index.SecondaryIndexManager.executeAllBlocking:(Ljava/util/stream/Stream;Ljava/util/function/Function;)V
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 5 1 hadBootstrap Z
MethodParameters:
Name Flags
hadBootstrap
public java.util.List<java.lang.String> getBuiltIndexNames();
descriptor: ()Ljava/util/List;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 1
start local 1 1: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
2: 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/index/SecondaryIndexManager.lambda$23(Lorg/apache/cassandra/index/Index;)Ljava/lang/String; (6)
(Lorg/apache/cassandra/index/Index;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
3: aload 1
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Ljava/util/Set;)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
java/util/Set.add(Ljava/lang/Object;)Z (9 itf)
(Ljava/lang/String;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
4: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.keyspace:Lorg/apache/cassandra/db/Keyspace;
invokevirtual org.apache.cassandra.db.Keyspace.getName:()Ljava/lang/String;
aload 1
invokestatic org.apache.cassandra.db.SystemKeyspace.getBuiltIndexes:(Ljava/lang/String;Ljava/util/Set;)Ljava/util/List;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
1 5 1 allIndexNames Ljava/util/Set<Ljava/lang/String;>;
Signature: ()Ljava/util/List<Ljava/lang/String;>;
public java.util.Set<org.apache.cassandra.db.ColumnFamilyStore> getAllIndexColumnFamilyStores();
descriptor: ()Ljava/util/Set;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 1
start local 1 1: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
aload 1
invokedynamic accept(Ljava/util/Set;)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/index/SecondaryIndexManager.lambda$25(Ljava/util/Set;Lorg/apache/cassandra/index/Index;)V (6)
(Lorg/apache/cassandra/index/Index;)V
invokeinterface java.util.Collection.forEach:(Ljava/util/function/Consumer;)V
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
1 3 1 backingTables Ljava/util/Set<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
Signature: ()Ljava/util/Set<Lorg/apache/cassandra/db/ColumnFamilyStore;>;
public boolean hasIndexes();
descriptor: ()Z
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
public void indexPartition(org.apache.cassandra.db.DecoratedKey, java.util.Set<org.apache.cassandra.index.Index>, );
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Set;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=21, args_size=4
start local 0 start local 1 start local 2 start local 3 0: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
invokeinterface org.slf4j.Logger.isTraceEnabled:()Z
ifeq 2
1: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "Indexing partition {}"
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 1
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
2: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Set.isEmpty:()Z
ifne 81
3: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
4: invokestatic org.apache.cassandra.utils.FBUtilities.nowInSeconds:()I
5: aload 1
6: invokestatic org.apache.cassandra.db.SinglePartitionReadCommand.fullPartitionRead:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/db/SinglePartitionReadCommand;
astore 4
start local 4 7: aload 4
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.nowInSec:()I
istore 5
start local 5 8: iconst_0
istore 6
start local 6 9: new org.apache.cassandra.service.pager.SinglePartitionPager
dup
aload 4
aconst_null
getstatic org.apache.cassandra.transport.ProtocolVersion.CURRENT:Lorg/apache/cassandra/transport/ProtocolVersion;
invokespecial org.apache.cassandra.service.pager.SinglePartitionPager.<init>:(Lorg/apache/cassandra/db/SinglePartitionReadCommand;Lorg/apache/cassandra/service/pager/PagingState;Lorg/apache/cassandra/transport/ProtocolVersion;)V
astore 7
start local 7 10: goto 80
11: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.DecoratedKey java.util.Set int org.apache.cassandra.db.SinglePartitionReadCommand int int org.apache.cassandra.service.pager.SinglePartitionPager
StackMap stack:
aconst_null
astore 8
aconst_null
astore 9
12: aload 4
invokevirtual org.apache.cassandra.db.SinglePartitionReadCommand.executionController:()Lorg/apache/cassandra/db/ReadExecutionController;
astore 10
start local 10 13: getstatic org.apache.cassandra.db.Keyspace.writeOrder:Lorg/apache/cassandra/utils/concurrent/OpOrder;
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder.start:()Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;
astore 11
start local 11 14: aload 7
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
iload 3
aload 10
invokevirtual org.apache.cassandra.service.pager.SinglePartitionPager.fetchPageUnfiltered:(Lorg/apache/cassandra/config/CFMetaData;ILorg/apache/cassandra/db/ReadExecutionController;)Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
astore 12
start local 12 15: aload 12
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.hasNext:()Z
ifne 20
16: aload 12
ifnull 17
aload 12
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.DecoratedKey java.util.Set int org.apache.cassandra.db.SinglePartitionReadCommand int int org.apache.cassandra.service.pager.SinglePartitionPager java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.partitions.UnfilteredPartitionIterator
StackMap stack:
17: aload 11
ifnull 18
aload 11
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder$Group.close:()V
StackMap locals:
StackMap stack:
18: aload 10
ifnull 81
aload 10
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
19: goto 81
20: StackMap locals:
StackMap stack:
aconst_null
astore 13
aconst_null
astore 14
21: aload 12
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.UnfilteredRowIterator
astore 15
start local 15 22: aload 2
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
23: aload 1
aload 15
iload 5
aload 11
invokedynamic apply(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;)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/index/SecondaryIndexManager.lambda$27(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/index/Index;)Lorg/apache/cassandra/index/Index$Indexer; (6)
(Lorg/apache/cassandra/index/Index;)Lorg/apache/cassandra/index/Index$Indexer;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
24: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
java/util/Objects.nonNull(Ljava/lang/Object;)Z (6)
(Lorg/apache/cassandra/index/Index$Indexer;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
25: invokestatic java.util.stream.Collectors.toSet:()Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
checkcast java.util.Set
26: astore 16
start local 16 27: iload 6
ifne 33
aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.isEmpty:()Z
ifeq 33
aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
invokeinterface org.apache.cassandra.db.rows.Row.isEmpty:()Z
ifeq 33
28: aload 15
ifnull 29
aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
29: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.DecoratedKey java.util.Set int org.apache.cassandra.db.SinglePartitionReadCommand int int org.apache.cassandra.service.pager.SinglePartitionPager java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.partitions.UnfilteredPartitionIterator java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator java.util.Set
StackMap stack:
aload 12
ifnull 30
aload 12
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
StackMap locals:
StackMap stack:
30: aload 11
ifnull 31
aload 11
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder$Group.close:()V
StackMap locals:
StackMap stack:
31: aload 10
ifnull 81
aload 10
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
32: goto 81
33: StackMap locals:
StackMap stack:
aload 16
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/index/Index$Indexer.begin()V (9 itf)
(Lorg/apache/cassandra/index/Index$Indexer;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
34: iload 6
ifne 39
35: aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
invokeinterface org.apache.cassandra.db.rows.Row.isEmpty:()Z
ifne 37
36: aload 16
aload 15
invokedynamic accept(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)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/index/SecondaryIndexManager.lambda$30(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/index/Index$Indexer;)V (6)
(Lorg/apache/cassandra/index/Index$Indexer;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
37: StackMap locals:
StackMap stack:
aload 16
aload 15
invokedynamic accept(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)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/index/SecondaryIndexManager.lambda$31(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/index/Index$Indexer;)V (6)
(Lorg/apache/cassandra/index/Index$Indexer;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
38: iconst_1
istore 6
39: StackMap locals:
StackMap stack:
aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getComparator:()Lorg/apache/cassandra/db/ClusteringComparator;
iconst_0
invokestatic org.apache.cassandra.db.MutableDeletionInfo.builder:(Lorg/apache/cassandra/db/DeletionTime;Lorg/apache/cassandra/db/ClusteringComparator;Z)Lorg/apache/cassandra/db/MutableDeletionInfo$Builder;
astore 17
start local 17 40: goto 49
41: StackMap locals: org.apache.cassandra.db.MutableDeletionInfo$Builder
StackMap stack:
aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Unfiltered
astore 18
start local 18 42: aload 18
invokeinterface org.apache.cassandra.db.rows.Unfiltered.isRow:()Z
ifeq 46
43: aload 18
checkcast org.apache.cassandra.db.rows.Row
astore 19
start local 19 44: aload 16
aload 19
invokedynamic accept(Lorg/apache/cassandra/db/rows/Row;)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/index/SecondaryIndexManager.lambda$32(Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/index/Index$Indexer;)V (6)
(Lorg/apache/cassandra/index/Index$Indexer;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
end local 19 45: goto 49
46: StackMap locals: org.apache.cassandra.db.rows.Unfiltered
StackMap stack:
getstatic org.apache.cassandra.index.SecondaryIndexManager.$assertionsDisabled:Z
ifne 47
aload 18
invokeinterface org.apache.cassandra.db.rows.Unfiltered.isRangeTombstoneMarker:()Z
ifne 47
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
47: StackMap locals:
StackMap stack:
aload 18
checkcast org.apache.cassandra.db.rows.RangeTombstoneMarker
astore 19
start local 19 48: aload 17
aload 19
invokevirtual org.apache.cassandra.db.MutableDeletionInfo$Builder.add:(Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;)V
end local 19 end local 18 49: StackMap locals:
StackMap stack:
aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.hasNext:()Z
ifne 41
50: aload 17
invokevirtual org.apache.cassandra.db.MutableDeletionInfo$Builder.build:()Lorg/apache/cassandra/db/MutableDeletionInfo;
astore 18
start local 18 51: aload 18
invokevirtual org.apache.cassandra.db.MutableDeletionInfo.hasRanges:()Z
ifeq 57
52: aload 18
iconst_0
invokevirtual org.apache.cassandra.db.MutableDeletionInfo.rangeIterator:(Z)Ljava/util/Iterator;
astore 19
start local 19 53: goto 56
54: StackMap locals: org.apache.cassandra.db.MutableDeletionInfo java.util.Iterator
StackMap stack:
aload 19
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.RangeTombstone
astore 20
start local 20 55: aload 16
aload 20
invokedynamic accept(Lorg/apache/cassandra/db/RangeTombstone;)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/index/SecondaryIndexManager.lambda$33(Lorg/apache/cassandra/db/RangeTombstone;Lorg/apache/cassandra/index/Index$Indexer;)V (6)
(Lorg/apache/cassandra/index/Index$Indexer;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
end local 20 56: StackMap locals:
StackMap stack:
aload 19
invokeinterface java.util.Iterator.hasNext:()Z
ifne 54
end local 19 57: StackMap locals:
StackMap stack:
aload 16
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/index/Index$Indexer.finish()V (9 itf)
(Lorg/apache/cassandra/index/Index$Indexer;)V
invokeinterface java.util.Set.forEach:(Ljava/util/function/Consumer;)V
end local 18 end local 17 end local 16 58: aload 15
ifnull 64
aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
goto 64
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.DecoratedKey java.util.Set int org.apache.cassandra.db.SinglePartitionReadCommand int int org.apache.cassandra.service.pager.SinglePartitionPager java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.ReadExecutionController org.apache.cassandra.utils.concurrent.OpOrder$Group org.apache.cassandra.db.partitions.UnfilteredPartitionIterator java.lang.Throwable java.lang.Throwable org.apache.cassandra.db.rows.UnfilteredRowIterator
StackMap stack: java.lang.Throwable
59: astore 13
aload 15
ifnull 60
aload 15
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.close:()V
end local 15 StackMap locals:
StackMap stack:
60: aload 13
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
61: astore 14
aload 13
ifnonnull 62
aload 14
astore 13
goto 63
StackMap locals:
StackMap stack:
62: aload 13
aload 14
if_acmpeq 63
aload 13
aload 14
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
63: aload 13
athrow
64: StackMap locals:
StackMap stack:
aload 12
ifnull 67
aload 12
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
goto 67
StackMap locals:
StackMap stack: java.lang.Throwable
65: astore 8
aload 12
ifnull 66
aload 12
invokeinterface org.apache.cassandra.db.partitions.UnfilteredPartitionIterator.close:()V
end local 12 StackMap locals:
StackMap stack:
66: aload 8
athrow
StackMap locals:
StackMap stack:
67: aload 11
ifnull 72
aload 11
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder$Group.close:()V
goto 72
StackMap locals:
StackMap stack: java.lang.Throwable
68: astore 9
aload 8
ifnonnull 69
aload 9
astore 8
goto 70
StackMap locals:
StackMap stack:
69: aload 8
aload 9
if_acmpeq 70
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
70: aload 11
ifnull 71
aload 11
invokevirtual org.apache.cassandra.utils.concurrent.OpOrder$Group.close:()V
end local 11 StackMap locals:
StackMap stack:
71: aload 8
athrow
StackMap locals:
StackMap stack:
72: aload 10
ifnull 80
aload 10
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
goto 80
StackMap locals:
StackMap stack: java.lang.Throwable
73: astore 9
aload 8
ifnonnull 74
aload 9
astore 8
goto 75
StackMap locals:
StackMap stack:
74: aload 8
aload 9
if_acmpeq 75
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
75: aload 10
ifnull 76
aload 10
invokevirtual org.apache.cassandra.db.ReadExecutionController.close:()V
end local 10 StackMap locals:
StackMap stack:
76: aload 8
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
77: astore 9
aload 8
ifnonnull 78
aload 9
astore 8
goto 79
StackMap locals:
StackMap stack:
78: aload 8
aload 9
if_acmpeq 79
aload 8
aload 9
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
79: aload 8
athrow
80: StackMap locals:
StackMap stack:
aload 7
invokevirtual org.apache.cassandra.service.pager.SinglePartitionPager.isExhausted:()Z
ifeq 11
end local 7 end local 6 end local 5 end local 4 81: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.DecoratedKey java.util.Set int
StackMap stack:
return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 82 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 82 1 key Lorg/apache/cassandra/db/DecoratedKey;
0 82 2 indexes Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;
0 82 3 pageSize I
7 81 4 cmd Lorg/apache/cassandra/db/SinglePartitionReadCommand;
8 81 5 nowInSec I
9 81 6 readStatic Z
10 81 7 pager Lorg/apache/cassandra/service/pager/SinglePartitionPager;
13 76 10 controller Lorg/apache/cassandra/db/ReadExecutionController;
14 71 11 writeGroup Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;
15 66 12 page Lorg/apache/cassandra/db/partitions/UnfilteredPartitionIterator;
22 60 15 partition Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
27 58 16 indexers Ljava/util/Set<Lorg/apache/cassandra/index/Index$Indexer;>;
40 58 17 deletionBuilder Lorg/apache/cassandra/db/MutableDeletionInfo$Builder;
42 49 18 unfilteredRow Lorg/apache/cassandra/db/rows/Unfiltered;
44 45 19 row Lorg/apache/cassandra/db/rows/Row;
48 49 19 marker Lorg/apache/cassandra/db/rows/RangeTombstoneMarker;
51 58 18 deletionInfo Lorg/apache/cassandra/db/MutableDeletionInfo;
53 57 19 iter Ljava/util/Iterator<Lorg/apache/cassandra/db/RangeTombstone;>;
55 56 20 rt Lorg/apache/cassandra/db/RangeTombstone;
Exception table:
from to target type
22 28 59 any
33 58 59 any
21 29 61 any
33 61 61 any
15 16 65 any
20 29 65 any
33 64 65 any
14 17 68 any
20 30 68 any
33 67 68 any
13 18 73 any
20 31 73 any
33 72 73 any
12 19 77 any
20 32 77 any
33 77 77 any
Signature: (Lorg/apache/cassandra/db/DecoratedKey;Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;I)V
MethodParameters:
Name Flags
key
indexes
pageSize
public int calculateIndexingPageSize();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=11, args_size=1
start local 0 0: ldc "cassandra.force_default_indexing_page_size"
invokestatic java.lang.Boolean.getBoolean:(Ljava/lang/String;)Z
ifeq 2
1: sipush 10000
ireturn
2: StackMap locals:
StackMap stack:
ldc 3.3554432E7
dstore 1
start local 1 3: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getMeanPartitionSize:()D
dstore 3
start local 3 4: dload 3
dconst_0
dcmpg
ifgt 6
5: sipush 10000
ireturn
6: StackMap locals: double double
StackMap stack:
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.getMeanColumns:()I
istore 5
start local 5 7: iload 5
ifgt 9
8: sipush 10000
ireturn
9: StackMap locals: int
StackMap stack:
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
invokevirtual org.apache.cassandra.config.CFMetaData.partitionColumns:()Lorg/apache/cassandra/db/PartitionColumns;
getfield org.apache.cassandra.db.PartitionColumns.regulars:Lorg/apache/cassandra/db/Columns;
invokevirtual org.apache.cassandra.db.Columns.size:()I
istore 6
start local 6 10: iload 6
ifgt 12
11: sipush 10000
ireturn
12: StackMap locals: int
StackMap stack:
iload 5
iload 6
idiv
istore 7
start local 7 13: dload 3
iload 7
i2d
ddiv
dstore 8
start local 8 14: dconst_1
ldc 10000.0
dload 1
dload 8
ddiv
invokestatic java.lang.Math.min:(DD)D
invokestatic java.lang.Math.max:(DD)D
d2i
istore 10
start local 10 15: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "Calculated page size {} for indexing {}.{} ({}/{}/{}/{})"
bipush 7
anewarray java.lang.Object
dup
iconst_0
16: iload 10
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_1
17: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.ksName:Ljava/lang/String;
aastore
dup
iconst_2
18: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
getfield org.apache.cassandra.db.ColumnFamilyStore.metadata:Lorg/apache/cassandra/config/CFMetaData;
getfield org.apache.cassandra.config.CFMetaData.cfName:Ljava/lang/String;
aastore
dup
iconst_3
19: dload 3
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
dup
iconst_4
20: iload 5
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
iconst_5
21: iload 7
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
aastore
dup
bipush 6
22: dload 8
invokestatic java.lang.Double.valueOf:(D)Ljava/lang/Double;
aastore
23: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;[Ljava/lang/Object;)V
24: iload 10
ireturn
end local 10 end local 8 end local 7 end local 6 end local 5 end local 3 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 25 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
3 25 1 targetPageSizeInBytes D
4 25 3 meanPartitionSize D
7 25 5 meanCellsPerPartition I
10 25 6 columnsPerRow I
13 25 7 meanRowsPerPartition I
14 25 8 meanRowSize D
15 25 10 pageSize I
public void deletePartition(org.apache.cassandra.db.rows.UnfilteredRowIterator, int);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
1: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.columns:()Lorg/apache/cassandra/db/PartitionColumns;
2: iload 2
3: invokevirtual org.apache.cassandra.index.SecondaryIndexManager.newCleanupTransaction:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;I)Lorg/apache/cassandra/index/transactions/CleanupTransaction;
astore 3
start local 3 4: aload 3
invokeinterface org.apache.cassandra.index.transactions.CleanupTransaction.start:()V
5: aload 3
new org.apache.cassandra.db.DeletionTime
dup
invokestatic org.apache.cassandra.utils.FBUtilities.timestampMicros:()J
iload 2
invokespecial org.apache.cassandra.db.DeletionTime.<init>:(JI)V
invokeinterface org.apache.cassandra.index.transactions.CleanupTransaction.onPartitionDeletion:(Lorg/apache/cassandra/db/DeletionTime;)V
6: aload 3
invokeinterface org.apache.cassandra.index.transactions.CleanupTransaction.commit:()V
7: goto 18
8: StackMap locals: org.apache.cassandra.index.transactions.CleanupTransaction
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.rows.Unfiltered
astore 4
start local 4 9: aload 4
invokeinterface org.apache.cassandra.db.rows.Unfiltered.kind:()Lorg/apache/cassandra/db/rows/Unfiltered$Kind;
getstatic org.apache.cassandra.db.rows.Unfiltered$Kind.ROW:Lorg/apache/cassandra/db/rows/Unfiltered$Kind;
if_acmpeq 11
10: goto 18
11: StackMap locals: org.apache.cassandra.db.rows.Unfiltered
StackMap stack:
aload 0
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
12: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.columns:()Lorg/apache/cassandra/db/PartitionColumns;
13: iload 2
14: invokevirtual org.apache.cassandra.index.SecondaryIndexManager.newCleanupTransaction:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;I)Lorg/apache/cassandra/index/transactions/CleanupTransaction;
astore 3
15: aload 3
invokeinterface org.apache.cassandra.index.transactions.CleanupTransaction.start:()V
16: aload 3
aload 4
checkcast org.apache.cassandra.db.rows.Row
invokeinterface org.apache.cassandra.index.transactions.CleanupTransaction.onRowDelete:(Lorg/apache/cassandra/db/rows/Row;)V
17: aload 3
invokeinterface org.apache.cassandra.index.transactions.CleanupTransaction.commit:()V
end local 4 18: StackMap locals:
StackMap stack:
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.hasNext:()Z
ifne 8
19: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 20 1 partition Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
0 20 2 nowInSec I
4 20 3 indexTransaction Lorg/apache/cassandra/index/transactions/CleanupTransaction;
9 18 4 unfiltered Lorg/apache/cassandra/db/rows/Unfiltered;
MethodParameters:
Name Flags
partition
nowInSec
public org.apache.cassandra.index.Index getBestIndexFor(org.apache.cassandra.db.filter.RowFilter);
descriptor: (Lorg/apache/cassandra/db/filter/RowFilter;)Lorg/apache/cassandra/index/Index;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=6, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.isEmpty:()Z
ifne 1
aload 1
invokevirtual org.apache.cassandra.db.filter.RowFilter.isEmpty:()Z
ifeq 2
1: StackMap locals:
StackMap stack:
aconst_null
areturn
2: StackMap locals:
StackMap stack:
new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
astore 2
start local 2 3: aload 1
invokevirtual org.apache.cassandra.db.filter.RowFilter.iterator:()Ljava/util/Iterator;
astore 4
goto 14
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.filter.RowFilter java.util.Set top java.util.Iterator
StackMap stack:
4: aload 4
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.filter.RowFilter$Expression
astore 3
start local 3 5: aload 3
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.isCustom:()Z
ifeq 10
6: aload 3
checkcast org.apache.cassandra.db.filter.RowFilter$CustomExpression
astore 5
start local 5 7: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "Command contains a custom index expression, using target index {}"
aload 5
invokevirtual org.apache.cassandra.db.filter.RowFilter$CustomExpression.getTargetIndex:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
8: ldc "Command contains a custom index expression, using target index {}"
aload 5
invokevirtual org.apache.cassandra.db.filter.RowFilter$CustomExpression.getTargetIndex:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;Ljava/lang/Object;)V
9: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
aload 5
invokevirtual org.apache.cassandra.db.filter.RowFilter$CustomExpression.getTargetIndex:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
areturn
end local 5 10: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.filter.RowFilter java.util.Set org.apache.cassandra.db.filter.RowFilter$Expression java.util.Iterator
StackMap stack:
aload 3
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.isUserDefined:()Z
ifne 14
11: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
12: aload 3
invokedynamic test(Lorg/apache/cassandra/db/filter/RowFilter$Expression;)Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/index/SecondaryIndexManager.lambda$35(Lorg/apache/cassandra/db/filter/RowFilter$Expression;Lorg/apache/cassandra/index/Index;)Z (6)
(Lorg/apache/cassandra/index/Index;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
13: aload 2
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Ljava/util/Set;)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
java/util/Set.add(Ljava/lang/Object;)Z (9 itf)
(Lorg/apache/cassandra/index/Index;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
end local 3 14: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.filter.RowFilter java.util.Set top java.util.Iterator
StackMap stack:
aload 4
invokeinterface java.util.Iterator.hasNext:()Z
ifne 4
15: aload 2
invokeinterface java.util.Set.isEmpty:()Z
ifeq 19
16: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "No applicable indexes found"
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;)V
17: ldc "No applicable indexes found"
invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;)V
18: aconst_null
areturn
19: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.filter.RowFilter java.util.Set
StackMap stack:
aload 2
invokeinterface java.util.Set.size:()I
iconst_1
if_icmpne 21
20: aload 2
invokestatic com.google.common.collect.Iterables.getOnlyElement:(Ljava/lang/Iterable;)Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
goto 24
21: StackMap locals:
StackMap stack:
aload 2
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
22: invokedynamic compare()Ljava/util/Comparator;
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;)I
org/apache/cassandra/index/SecondaryIndexManager.lambda$37(Lorg/apache/cassandra/index/Index;Lorg/apache/cassandra/index/Index;)I (6)
(Lorg/apache/cassandra/index/Index;Lorg/apache/cassandra/index/Index;)I
invokeinterface java.util.stream.Stream.min:(Ljava/util/Comparator;)Ljava/util/Optional;
23: invokedynamic get()Ljava/util/function/Supplier;
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;
org/apache/cassandra/index/SecondaryIndexManager.lambda$38()Ljava/lang/AssertionError; (6)
()Ljava/lang/AssertionError;
invokevirtual java.util.Optional.orElseThrow:(Ljava/util/function/Supplier;)Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
24: StackMap locals:
StackMap stack: org.apache.cassandra.index.Index
astore 3
start local 3 25: invokestatic org.apache.cassandra.tracing.Tracing.isTracing:()Z
ifeq 31
26: ldc "Index mean cardinalities are {}. Scanning with {}."
27: aload 2
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
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/index/SecondaryIndexManager.lambda$39(Lorg/apache/cassandra/index/Index;)Ljava/lang/String; (6)
(Lorg/apache/cassandra/index/Index;)Ljava/lang/String;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
28: ldc ","
invokestatic java.util.stream.Collectors.joining:(Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
invokeinterface java.util.stream.Stream.collect:(Ljava/util/stream/Collector;)Ljava/lang/Object;
29: aload 3
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
30: invokestatic org.apache.cassandra.tracing.Tracing.trace:(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
31: StackMap locals: org.apache.cassandra.index.Index
StackMap stack:
aload 3
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 32 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 32 1 rowFilter Lorg/apache/cassandra/db/filter/RowFilter;
3 32 2 searchableIndexes Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;
5 14 3 expression Lorg/apache/cassandra/db/filter/RowFilter$Expression;
7 10 5 customExpression Lorg/apache/cassandra/db/filter/RowFilter$CustomExpression;
25 32 3 selected Lorg/apache/cassandra/index/Index;
MethodParameters:
Name Flags
rowFilter
public java.util.Optional<org.apache.cassandra.index.Index> getBestIndexFor(org.apache.cassandra.db.filter.RowFilter$Expression);
descriptor: (Lorg/apache/cassandra/db/filter/RowFilter$Expression;)Ljava/util/Optional;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
aload 1
invokedynamic test(Lorg/apache/cassandra/db/filter/RowFilter$Expression;)Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
org/apache/cassandra/index/SecondaryIndexManager.lambda$40(Lorg/apache/cassandra/db/filter/RowFilter$Expression;Lorg/apache/cassandra/index/Index;)Z (6)
(Lorg/apache/cassandra/index/Index;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
invokeinterface java.util.stream.Stream.findFirst:()Ljava/util/Optional;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 1 1 expression Lorg/apache/cassandra/db/filter/RowFilter$Expression;
Signature: (Lorg/apache/cassandra/db/filter/RowFilter$Expression;)Ljava/util/Optional<Lorg/apache/cassandra/index/Index;>;
MethodParameters:
Name Flags
expression
public void validate(org.apache.cassandra.db.partitions.PartitionUpdate);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=4, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.iterator:()Ljava/util/Iterator;
astore 3
goto 3
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager org.apache.cassandra.db.partitions.PartitionUpdate top java.util.Iterator
StackMap stack:
1: aload 3
invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
astore 2
start local 2 2: aload 2
aload 1
invokeinterface org.apache.cassandra.index.Index.validate:(Lorg/apache/cassandra/db/partitions/PartitionUpdate;)V
end local 2 3: StackMap locals:
StackMap stack:
aload 3
invokeinterface java.util.Iterator.hasNext:()Z
ifne 1
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 5 1 update Lorg/apache/cassandra/db/partitions/PartitionUpdate;
2 3 2 index Lorg/apache/cassandra/index/Index;
Exceptions:
throws org.apache.cassandra.exceptions.InvalidRequestException
MethodParameters:
Name Flags
update
public void registerIndex(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
aload 2
aload 1
invokeinterface java.util.Map.put:(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
pop
2: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "Registered index {}"
aload 2
invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 4 1 index Lorg/apache/cassandra/index/Index;
1 4 2 name Ljava/lang/String;
MethodParameters:
Name Flags
index
public void unregisterIndex(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.unregisterIndex:(Ljava/lang/String;)Lorg/apache/cassandra/index/Index;
pop
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 2 1 index Lorg/apache/cassandra/index/Index;
MethodParameters:
Name Flags
index
private org.apache.cassandra.index.Index unregisterIndex(java.lang.String);
descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/index/Index;
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
aload 1
invokeinterface java.util.Map.remove:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
astore 2
start local 2 1: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.builtIndexes:Ljava/util/Set;
aload 1
invokeinterface java.util.Set.remove:(Ljava/lang/Object;)Z
pop
2: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
aload 2
ifnonnull 3
ldc "Index {} was not registered"
goto 4
StackMap locals: org.apache.cassandra.index.SecondaryIndexManager java.lang.String org.apache.cassandra.index.Index
StackMap stack: org.slf4j.Logger
3: ldc "Removed index {} from registry"
4: StackMap locals: org.apache.cassandra.index.SecondaryIndexManager java.lang.String org.apache.cassandra.index.Index
StackMap stack: org.slf4j.Logger java.lang.String
aload 1
5: invokeinterface org.slf4j.Logger.trace:(Ljava/lang/String;Ljava/lang/Object;)V
6: aload 2
areturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 7 1 name Ljava/lang/String;
1 7 2 removed Lorg/apache/cassandra/index/Index;
MethodParameters:
Name Flags
name
public org.apache.cassandra.index.Index getIndex(org.apache.cassandra.schema.IndexMetadata);
descriptor: (Lorg/apache/cassandra/schema/IndexMetadata;)Lorg/apache/cassandra/index/Index;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
aload 1
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 1 1 metadata Lorg/apache/cassandra/schema/IndexMetadata;
MethodParameters:
Name Flags
metadata
public java.util.Collection<org.apache.cassandra.index.Index> listIndexes();
descriptor: ()Ljava/util/Collection;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokestatic com.google.common.collect.ImmutableSet.copyOf:(Ljava/util/Collection;)Lcom/google/common/collect/ImmutableSet;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
Signature: ()Ljava/util/Collection<Lorg/apache/cassandra/index/Index;>;
public org.apache.cassandra.index.transactions.UpdateTransaction newUpdateTransaction(org.apache.cassandra.db.partitions.PartitionUpdate, org.apache.cassandra.utils.concurrent.OpOrder$Group, int);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionUpdate;Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;I)Lorg/apache/cassandra/index/transactions/UpdateTransaction;
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=5, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.hasIndexes:()Z
ifne 2
1: getstatic org.apache.cassandra.index.transactions.UpdateTransaction.NO_OP:Lorg/apache/cassandra/index/transactions/UpdateTransaction;
areturn
2: StackMap locals:
StackMap stack:
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.indexes:Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
3: aload 1
iload 3
aload 2
invokedynamic apply(Lorg/apache/cassandra/db/partitions/PartitionUpdate;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;)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/index/SecondaryIndexManager.lambda$41(Lorg/apache/cassandra/db/partitions/PartitionUpdate;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/index/Index;)Lorg/apache/cassandra/index/Index$Indexer; (6)
(Lorg/apache/cassandra/index/Index;)Lorg/apache/cassandra/index/Index$Indexer;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
4: invokedynamic test()Ljava/util/function/Predicate;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Z
java/util/Objects.nonNull(Ljava/lang/Object;)Z (6)
(Lorg/apache/cassandra/index/Index$Indexer;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
5: invokedynamic apply()Ljava/util/function/IntFunction;
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:
(I)Ljava/lang/Object;
org/apache/cassandra/index/SecondaryIndexManager.lambda$43(I)[Lorg/apache/cassandra/index/Index$Indexer; (6)
(I)[Lorg/apache/cassandra/index/Index$Indexer;
invokeinterface java.util.stream.Stream.toArray:(Ljava/util/function/IntFunction;)[Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index$Indexer[]
6: astore 4
start local 4 7: aload 4
arraylength
ifne 8
getstatic org.apache.cassandra.index.transactions.UpdateTransaction.NO_OP:Lorg/apache/cassandra/index/transactions/UpdateTransaction;
goto 9
StackMap locals: org.apache.cassandra.index.Index$Indexer[]
StackMap stack:
8: new org.apache.cassandra.index.SecondaryIndexManager$WriteTimeTransaction
dup
aload 4
invokespecial org.apache.cassandra.index.SecondaryIndexManager$WriteTimeTransaction.<init>:([Lorg/apache/cassandra/index/Index$Indexer;)V
StackMap locals:
StackMap stack: org.apache.cassandra.index.transactions.UpdateTransaction
9: 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 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 10 1 update Lorg/apache/cassandra/db/partitions/PartitionUpdate;
0 10 2 opGroup Lorg/apache/cassandra/utils/concurrent/OpOrder$Group;
0 10 3 nowInSec I
7 10 4 indexers [Lorg/apache/cassandra/index/Index$Indexer;
MethodParameters:
Name Flags
update
opGroup
nowInSec
public org.apache.cassandra.index.transactions.CompactionTransaction newCompactionTransaction(org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.PartitionColumns, int, int);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;II)Lorg/apache/cassandra/index/transactions/CompactionTransaction;
flags: (0x0001) ACC_PUBLIC
Code:
stack=7, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 0: new org.apache.cassandra.index.SecondaryIndexManager$IndexGCTransaction
dup
aload 1
aload 2
iload 3
iload 4
aload 0
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.listIndexes:()Ljava/util/Collection;
invokespecial org.apache.cassandra.index.SecondaryIndexManager$IndexGCTransaction.<init>:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;IILjava/util/Collection;)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 1 1 key Lorg/apache/cassandra/db/DecoratedKey;
0 1 2 partitionColumns Lorg/apache/cassandra/db/PartitionColumns;
0 1 3 versions I
0 1 4 nowInSec I
MethodParameters:
Name Flags
key
partitionColumns
versions
nowInSec
public org.apache.cassandra.index.transactions.CleanupTransaction newCleanupTransaction(org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.PartitionColumns, int);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;I)Lorg/apache/cassandra/index/transactions/CleanupTransaction;
flags: (0x0001) ACC_PUBLIC
Code:
stack=6, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.hasIndexes:()Z
ifne 2
1: getstatic org.apache.cassandra.index.transactions.CleanupTransaction.NO_OP:Lorg/apache/cassandra/index/transactions/CleanupTransaction;
areturn
2: StackMap locals:
StackMap stack:
new org.apache.cassandra.index.SecondaryIndexManager$CleanupGCTransaction
dup
aload 1
aload 2
iload 3
aload 0
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.listIndexes:()Ljava/util/Collection;
invokespecial org.apache.cassandra.index.SecondaryIndexManager$CleanupGCTransaction.<init>:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;ILjava/util/Collection;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 3 1 key Lorg/apache/cassandra/db/DecoratedKey;
0 3 2 partitionColumns Lorg/apache/cassandra/db/PartitionColumns;
0 3 3 nowInSec I
MethodParameters:
Name Flags
key
partitionColumns
nowInSec
private static void executeBlocking(java.util.concurrent.Callable<?>);
descriptor: (Ljava/util/concurrent/Callable;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
ifnull 2
1: getstatic org.apache.cassandra.index.SecondaryIndexManager.blockingExecutor:Ljava/util/concurrent/ExecutorService;
aload 0
invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
invokestatic org.apache.cassandra.utils.FBUtilities.waitOnFuture:(Ljava/util/concurrent/Future;)Ljava/lang/Object;
pop
2: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 task Ljava/util/concurrent/Callable<*>;
Signature: (Ljava/util/concurrent/Callable<*>;)V
MethodParameters:
Name Flags
task
private static void executeAllBlocking(java.util.stream.Stream<org.apache.cassandra.index.Index>, java.util.function.Function<org.apache.cassandra.index.Index, java.util.concurrent.Callable<?>>);
descriptor: (Ljava/util/stream/Stream;Ljava/util/function/Function;)V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 1
ifnonnull 3
1: getstatic org.apache.cassandra.index.SecondaryIndexManager.logger:Lorg/slf4j/Logger;
ldc "failed to flush indexes: {} because flush task is missing."
aload 0
invokeinterface org.slf4j.Logger.error:(Ljava/lang/String;Ljava/lang/Object;)V
2: return
3: StackMap locals:
StackMap stack:
new java.util.ArrayList
dup
invokespecial java.util.ArrayList.<init>:()V
astore 2
start local 2 4: aload 0
aload 1
aload 2
invokedynamic accept(Ljava/util/function/Function;Ljava/util/List;)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/index/SecondaryIndexManager.lambda$44(Ljava/util/function/Function;Ljava/util/List;Lorg/apache/cassandra/index/Index;)V (6)
(Lorg/apache/cassandra/index/Index;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
5: aload 2
invokestatic org.apache.cassandra.utils.FBUtilities.waitOnFutures:(Ljava/lang/Iterable;)Ljava/util/List;
pop
6: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 7 0 indexers Ljava/util/stream/Stream<Lorg/apache/cassandra/index/Index;>;
0 7 1 function Ljava/util/function/Function<Lorg/apache/cassandra/index/Index;Ljava/util/concurrent/Callable<*>;>;
4 7 2 waitFor Ljava/util/List<Ljava/util/concurrent/Future<*>;>;
Signature: (Ljava/util/stream/Stream<Lorg/apache/cassandra/index/Index;>;Ljava/util/function/Function<Lorg/apache/cassandra/index/Index;Ljava/util/concurrent/Callable<*>;>;)V
MethodParameters:
Name Flags
indexers
function
public static void shutdownAndWait(long, java.util.concurrent.TimeUnit);
descriptor: (JLjava/util/concurrent/TimeUnit;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 2 0: iconst_2
anewarray java.util.concurrent.ExecutorService
dup
iconst_0
getstatic org.apache.cassandra.index.SecondaryIndexManager.asyncExecutor:Ljava/util/concurrent/ExecutorService;
aastore
dup
iconst_1
getstatic org.apache.cassandra.index.SecondaryIndexManager.blockingExecutor:Ljava/util/concurrent/ExecutorService;
aastore
astore 3
start local 3 1: aload 3
invokestatic org.apache.cassandra.utils.ExecutorUtils.shutdown:([Ljava/util/concurrent/ExecutorService;)V
2: lload 0
aload 2
aload 3
invokestatic org.apache.cassandra.utils.ExecutorUtils.awaitTermination:(JLjava/util/concurrent/TimeUnit;[Ljava/util/concurrent/ExecutorService;)V
3: return
end local 3 end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 timeout J
0 4 2 unit Ljava/util/concurrent/TimeUnit;
1 4 3 executors [Ljava/util/concurrent/ExecutorService;
Exceptions:
throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
RuntimeInvisibleAnnotations:
com.google.common.annotations.VisibleForTesting()
MethodParameters:
Name Flags
timeout
unit
private static boolean lambda$0(org.apache.cassandra.schema.Indexes, java.lang.String);
descriptor: (Lorg/apache/cassandra/schema/Indexes;Ljava/lang/String;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.schema.Indexes.has:(Ljava/lang/String;)Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 indexName Ljava/lang/String;
private static boolean lambda$3(java.util.Set, org.apache.cassandra.index.Index);
descriptor: (Ljava/util/Set;Lorg/apache/cassandra/index/Index;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokeinterface java.util.Set.contains:(Ljava/lang/Object;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 index Lorg/apache/cassandra/index/Index;
private void lambda$5(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.markIndexRemoved:(Ljava/lang/String;)V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 1 1 indexer Lorg/apache/cassandra/index/Index;
private void lambda$6(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
aload 1
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokevirtual org.apache.cassandra.index.SecondaryIndexManager.markIndexBuilt:(Ljava/lang/String;)V
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 1 1 indexer Lorg/apache/cassandra/index/Index;
private static java.lang.String lambda$8(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)Ljava/lang/String;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 i Lorg/apache/cassandra/index/Index;
private static java.util.Set lambda$10(org.apache.cassandra.index.Index$IndexBuildingSupport);
descriptor: (Lorg/apache/cassandra/index/Index$IndexBuildingSupport;)Ljava/util/Set;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: new java.util.HashSet
dup
invokespecial java.util.HashSet.<init>:()V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 i Lorg/apache/cassandra/index/Index$IndexBuildingSupport;
private org.apache.cassandra.index.SecondaryIndexBuilder lambda$11(java.util.Collection, java.util.Map$Entry);
descriptor: (Ljava/util/Collection;Ljava/util/Map$Entry;)Lorg/apache/cassandra/index/SecondaryIndexBuilder;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=4, locals=3, args_size=3
start local 0 start local 2 0: aload 2
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast org.apache.cassandra.index.Index$IndexBuildingSupport
aload 0
getfield org.apache.cassandra.index.SecondaryIndexManager.baseCfs:Lorg/apache/cassandra/db/ColumnFamilyStore;
aload 2
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.util.Set
aload 1
invokeinterface org.apache.cassandra.index.Index$IndexBuildingSupport.getIndexBuildTask:(Lorg/apache/cassandra/db/ColumnFamilyStore;Ljava/util/Set;Ljava/util/Collection;)Lorg/apache/cassandra/index/SecondaryIndexBuilder;
areturn
end local 2 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/index/SecondaryIndexManager;
0 1 2 e Ljava/util/Map$Entry<Lorg/apache/cassandra/index/Index$IndexBuildingSupport;Ljava/util/Set<Lorg/apache/cassandra/index/Index;>;>;
private static java.lang.String lambda$13(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)Ljava/lang/String;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 i Lorg/apache/cassandra/index/Index;
private static java.util.concurrent.Callable lambda$14(long, org.apache.cassandra.index.Index);
descriptor: (JLorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
start local 2 0: aload 2
lload 0
invokeinterface org.apache.cassandra.index.Index.getTruncateTask:(J)Ljava/util/concurrent/Callable;
areturn
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 1 2 index Lorg/apache/cassandra/index/Index;
private static void lambda$16(java.util.List, java.util.List, org.apache.cassandra.index.Index);
descriptor: (Ljava/util/List;Ljava/util/List;Lorg/apache/cassandra/index/Index;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 2
invokeinterface org.apache.cassandra.index.Index.getBackingTable:()Ljava/util/Optional;
1: aload 0
invokedynamic apply(Ljava/util/List;)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/index/SecondaryIndexManager.lambda$17(Ljava/util/List;Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/lang/Boolean; (6)
(Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/lang/Boolean;
invokevirtual java.util.Optional.map:(Ljava/util/function/Function;)Ljava/util/Optional;
2: aload 1
aload 2
invokedynamic get(Ljava/util/List;Lorg/apache/cassandra/index/Index;)Ljava/util/function/Supplier;
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;
org/apache/cassandra/index/SecondaryIndexManager.lambda$18(Ljava/util/List;Lorg/apache/cassandra/index/Index;)Ljava/lang/Boolean; (6)
()Ljava/lang/Boolean;
invokevirtual java.util.Optional.orElseGet:(Ljava/util/function/Supplier;)Ljava/lang/Object;
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 index Lorg/apache/cassandra/index/Index;
private static boolean lambda$20(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface org.apache.cassandra.index.Index.getBackingTable:()Ljava/util/Optional;
invokevirtual java.util.Optional.isPresent:()Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 index Lorg/apache/cassandra/index/Index;
private static java.util.concurrent.Callable lambda$22(boolean, org.apache.cassandra.index.Index);
descriptor: (ZLorg/apache/cassandra/index/Index;)Ljava/util/concurrent/Callable;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
iload 0
invokeinterface org.apache.cassandra.index.Index.getPreJoinTask:(Z)Ljava/util/concurrent/Callable;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 index Lorg/apache/cassandra/index/Index;
private static java.lang.String lambda$23(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)Ljava/lang/String;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 i Lorg/apache/cassandra/index/Index;
private static void lambda$25(java.util.Set, org.apache.cassandra.index.Index);
descriptor: (Ljava/util/Set;Lorg/apache/cassandra/index/Index;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 1
invokeinterface org.apache.cassandra.index.Index.getBackingTable:()Ljava/util/Optional;
aload 0
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic accept(Ljava/util/Set;)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
java/util/Set.add(Ljava/lang/Object;)Z (9 itf)
(Lorg/apache/cassandra/db/ColumnFamilyStore;)V
invokevirtual java.util.Optional.ifPresent:(Ljava/util/function/Consumer;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 index Lorg/apache/cassandra/index/Index;
private static org.apache.cassandra.index.Index$Indexer lambda$27(org.apache.cassandra.db.DecoratedKey, org.apache.cassandra.db.rows.UnfilteredRowIterator, int, org.apache.cassandra.utils.concurrent.OpOrder$Group, org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/index/Index;)Lorg/apache/cassandra/index/Index$Indexer;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=6, locals=5, args_size=5
start local 4 0: aload 4
aload 0
1: aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.columns:()Lorg/apache/cassandra/db/PartitionColumns;
2: iload 2
3: aload 3
4: getstatic org.apache.cassandra.index.transactions.IndexTransaction$Type.UPDATE:Lorg/apache/cassandra/index/transactions/IndexTransaction$Type;
5: invokeinterface org.apache.cassandra.index.Index.indexerFor:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/index/transactions/IndexTransaction$Type;)Lorg/apache/cassandra/index/Index$Indexer;
6: areturn
end local 4 LocalVariableTable:
Start End Slot Name Signature
0 7 4 index Lorg/apache/cassandra/index/Index;
private static void lambda$30(org.apache.cassandra.db.rows.UnfilteredRowIterator, org.apache.cassandra.index.Index$Indexer);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/index/Index$Indexer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
invokeinterface org.apache.cassandra.index.Index$Indexer.insertRow:(Lorg/apache/cassandra/db/rows/Row;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 indexer Lorg/apache/cassandra/index/Index$Indexer;
private static void lambda$31(org.apache.cassandra.db.rows.UnfilteredRowIterator, org.apache.cassandra.index.Index$Indexer);
descriptor: (Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Lorg/apache/cassandra/index/Index$Indexer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokeinterface org.apache.cassandra.index.Index$Indexer.partitionDelete:(Lorg/apache/cassandra/db/DeletionTime;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 i Lorg/apache/cassandra/index/Index$Indexer;
private static void lambda$32(org.apache.cassandra.db.rows.Row, org.apache.cassandra.index.Index$Indexer);
descriptor: (Lorg/apache/cassandra/db/rows/Row;Lorg/apache/cassandra/index/Index$Indexer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface org.apache.cassandra.index.Index$Indexer.insertRow:(Lorg/apache/cassandra/db/rows/Row;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 indexer Lorg/apache/cassandra/index/Index$Indexer;
private static void lambda$33(org.apache.cassandra.db.RangeTombstone, org.apache.cassandra.index.Index$Indexer);
descriptor: (Lorg/apache/cassandra/db/RangeTombstone;Lorg/apache/cassandra/index/Index$Indexer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokeinterface org.apache.cassandra.index.Index$Indexer.rangeTombstone:(Lorg/apache/cassandra/db/RangeTombstone;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 indexer Lorg/apache/cassandra/index/Index$Indexer;
private static boolean lambda$35(org.apache.cassandra.db.filter.RowFilter$Expression, org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/db/filter/RowFilter$Expression;Lorg/apache/cassandra/index/Index;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.column:()Lorg/apache/cassandra/config/ColumnDefinition;
aload 0
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.operator:()Lorg/apache/cassandra/cql3/Operator;
invokeinterface org.apache.cassandra.index.Index.supportsExpression:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/cql3/Operator;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 index Lorg/apache/cassandra/index/Index;
private static int lambda$37(org.apache.cassandra.index.Index, org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;Lorg/apache/cassandra/index/Index;)I
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokeinterface org.apache.cassandra.index.Index.getEstimatedResultRows:()J
1: aload 1
invokeinterface org.apache.cassandra.index.Index.getEstimatedResultRows:()J
2: invokestatic com.google.common.primitives.Longs.compare:(JJ)I
3: ireturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 a Lorg/apache/cassandra/index/Index;
0 4 1 b Lorg/apache/cassandra/index/Index;
private static java.lang.AssertionError lambda$38();
descriptor: ()Ljava/lang/AssertionError;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=0, args_size=0
0: new java.lang.AssertionError
dup
ldc "Could not select most selective index"
invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
areturn
LocalVariableTable:
Start End Slot Name Signature
private static java.lang.String lambda$39(org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/index/Index;)Ljava/lang/String;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
aload 0
invokeinterface org.apache.cassandra.index.Index.getIndexMetadata:()Lorg/apache/cassandra/schema/IndexMetadata;
getfield org.apache.cassandra.schema.IndexMetadata.name:Ljava/lang/String;
invokestatic java.lang.String.valueOf:(Ljava/lang/Object;)Ljava/lang/String;
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
bipush 58
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
aload 0
invokeinterface org.apache.cassandra.index.Index.getEstimatedResultRows:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 i Lorg/apache/cassandra/index/Index;
private static boolean lambda$40(org.apache.cassandra.db.filter.RowFilter$Expression, org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/db/filter/RowFilter$Expression;Lorg/apache/cassandra/index/Index;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 1
aload 0
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.column:()Lorg/apache/cassandra/config/ColumnDefinition;
aload 0
invokevirtual org.apache.cassandra.db.filter.RowFilter$Expression.operator:()Lorg/apache/cassandra/cql3/Operator;
invokeinterface org.apache.cassandra.index.Index.supportsExpression:(Lorg/apache/cassandra/config/ColumnDefinition;Lorg/apache/cassandra/cql3/Operator;)Z
ireturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 i Lorg/apache/cassandra/index/Index;
private static org.apache.cassandra.index.Index$Indexer lambda$41(org.apache.cassandra.db.partitions.PartitionUpdate, int, org.apache.cassandra.utils.concurrent.OpOrder$Group, org.apache.cassandra.index.Index);
descriptor: (Lorg/apache/cassandra/db/partitions/PartitionUpdate;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/index/Index;)Lorg/apache/cassandra/index/Index$Indexer;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=6, locals=4, args_size=4
start local 3 0: aload 3
aload 0
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
1: aload 0
invokevirtual org.apache.cassandra.db.partitions.PartitionUpdate.columns:()Lorg/apache/cassandra/db/PartitionColumns;
2: iload 1
3: aload 2
4: getstatic org.apache.cassandra.index.transactions.IndexTransaction$Type.UPDATE:Lorg/apache/cassandra/index/transactions/IndexTransaction$Type;
5: invokeinterface org.apache.cassandra.index.Index.indexerFor:(Lorg/apache/cassandra/db/DecoratedKey;Lorg/apache/cassandra/db/PartitionColumns;ILorg/apache/cassandra/utils/concurrent/OpOrder$Group;Lorg/apache/cassandra/index/transactions/IndexTransaction$Type;)Lorg/apache/cassandra/index/Index$Indexer;
6: areturn
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 7 3 i Lorg/apache/cassandra/index/Index;
private static org.apache.cassandra.index.Index$Indexer[] lambda$43(int);
descriptor: (I)[Lorg/apache/cassandra/index/Index$Indexer;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: iload 0
anewarray org.apache.cassandra.index.Index$Indexer
areturn
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$44(java.util.function.Function, java.util.List, org.apache.cassandra.index.Index);
descriptor: (Ljava/util/function/Function;Ljava/util/List;Lorg/apache/cassandra/index/Index;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=3
start local 2 0: aload 0
aload 2
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.util.concurrent.Callable
astore 3
start local 3 1: aload 3
ifnull 3
2: aload 1
getstatic org.apache.cassandra.index.SecondaryIndexManager.blockingExecutor:Ljava/util/concurrent/ExecutorService;
aload 3
invokeinterface java.util.concurrent.ExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
end local 3 3: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 4 2 indexer Lorg/apache/cassandra/index/Index;
1 3 3 task Ljava/util/concurrent/Callable<*>;
private static java.lang.Boolean lambda$17(java.util.List, org.apache.cassandra.db.ColumnFamilyStore);
descriptor: (Ljava/util/List;Lorg/apache/cassandra/db/ColumnFamilyStore;)Ljava/lang/Boolean;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokevirtual org.apache.cassandra.db.ColumnFamilyStore.forceFlush:()Lcom/google/common/util/concurrent/ListenableFuture;
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 cfs Lorg/apache/cassandra/db/ColumnFamilyStore;
private static java.lang.Boolean lambda$18(java.util.List, org.apache.cassandra.index.Index);
descriptor: (Ljava/util/List;Lorg/apache/cassandra/index/Index;)Ljava/lang/Boolean;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
invokestatic java.lang.Boolean.valueOf:(Z)Ljava/lang/Boolean;
areturn
LocalVariableTable:
Start End Slot Name Signature
}
SourceFile: "SecondaryIndexManager.java"
NestMembers:
org.apache.cassandra.index.SecondaryIndexManager$CleanupGCTransaction org.apache.cassandra.index.SecondaryIndexManager$IndexGCTransaction org.apache.cassandra.index.SecondaryIndexManager$IndexGCTransaction$1 org.apache.cassandra.index.SecondaryIndexManager$WriteTimeTransaction org.apache.cassandra.index.SecondaryIndexManager$WriteTimeTransaction$1
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 RefViewFragment = org.apache.cassandra.db.ColumnFamilyStore$RefViewFragment of org.apache.cassandra.db.ColumnFamilyStore
public Builder = org.apache.cassandra.db.MutableDeletionInfo$Builder of org.apache.cassandra.db.MutableDeletionInfo
public final CustomExpression = org.apache.cassandra.db.filter.RowFilter$CustomExpression of org.apache.cassandra.db.filter.RowFilter
public abstract Expression = org.apache.cassandra.db.filter.RowFilter$Expression of org.apache.cassandra.db.filter.RowFilter
public final Kind = org.apache.cassandra.db.rows.Unfiltered$Kind of org.apache.cassandra.db.rows.Unfiltered
public abstract IndexBuildingSupport = org.apache.cassandra.index.Index$IndexBuildingSupport of org.apache.cassandra.index.Index
public abstract Indexer = org.apache.cassandra.index.Index$Indexer of org.apache.cassandra.index.Index
private final CleanupGCTransaction = org.apache.cassandra.index.SecondaryIndexManager$CleanupGCTransaction of org.apache.cassandra.index.SecondaryIndexManager
private final IndexGCTransaction = org.apache.cassandra.index.SecondaryIndexManager$IndexGCTransaction of org.apache.cassandra.index.SecondaryIndexManager
private final WriteTimeTransaction = org.apache.cassandra.index.SecondaryIndexManager$WriteTimeTransaction of org.apache.cassandra.index.SecondaryIndexManager
public final Type = org.apache.cassandra.index.transactions.IndexTransaction$Type of org.apache.cassandra.index.transactions.IndexTransaction
public final Group = org.apache.cassandra.utils.concurrent.OpOrder$Group of org.apache.cassandra.utils.concurrent.OpOrder
SecondaryIndexManager
logger: Logger
$assertionsDisabled: boolean
