public class org.apache.cassandra.tools.SSTableExport
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.apache.cassandra.tools.SSTableExport
super_class: java.lang.Object
{
private static final java.lang.String KEY_OPTION;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "k"
private static final java.lang.String DEBUG_OUTPUT_OPTION;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "d"
private static final java.lang.String EXCLUDE_KEY_OPTION;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "x"
private static final java.lang.String ENUMERATE_KEYS_OPTION;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "e"
private static final java.lang.String RAW_TIMESTAMPS;
descriptor: Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: "t"
private static final org.apache.commons.cli.Options options;
descriptor: Lorg/apache/commons/cli/Options;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private static org.apache.commons.cli.CommandLine cmd;
descriptor: Lorg/apache/commons/cli/CommandLine;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=5, locals=5, args_size=0
0: new org.apache.commons.cli.Options
dup
invokespecial org.apache.commons.cli.Options.<init>:()V
putstatic org.apache.cassandra.tools.SSTableExport.options:Lorg/apache/commons/cli/Options;
1: invokestatic org.apache.cassandra.config.DatabaseDescriptor.toolInitialization:()V
2: new org.apache.commons.cli.Option
dup
ldc "k"
iconst_1
ldc "Partition key"
invokespecial org.apache.commons.cli.Option.<init>:(Ljava/lang/String;ZLjava/lang/String;)V
astore 0
start local 0 3: aload 0
sipush 500
invokevirtual org.apache.commons.cli.Option.setArgs:(I)V
4: getstatic org.apache.cassandra.tools.SSTableExport.options:Lorg/apache/commons/cli/Options;
aload 0
invokevirtual org.apache.commons.cli.Options.addOption:(Lorg/apache/commons/cli/Option;)Lorg/apache/commons/cli/Options;
pop
5: new org.apache.commons.cli.Option
dup
ldc "x"
iconst_1
ldc "Excluded partition key"
invokespecial org.apache.commons.cli.Option.<init>:(Ljava/lang/String;ZLjava/lang/String;)V
astore 1
start local 1 6: aload 1
sipush 500
invokevirtual org.apache.commons.cli.Option.setArgs:(I)V
7: getstatic org.apache.cassandra.tools.SSTableExport.options:Lorg/apache/commons/cli/Options;
aload 1
invokevirtual org.apache.commons.cli.Options.addOption:(Lorg/apache/commons/cli/Option;)Lorg/apache/commons/cli/Options;
pop
8: new org.apache.commons.cli.Option
dup
ldc "e"
iconst_0
ldc "enumerate partition keys only"
invokespecial org.apache.commons.cli.Option.<init>:(Ljava/lang/String;ZLjava/lang/String;)V
astore 2
start local 2 9: getstatic org.apache.cassandra.tools.SSTableExport.options:Lorg/apache/commons/cli/Options;
aload 2
invokevirtual org.apache.commons.cli.Options.addOption:(Lorg/apache/commons/cli/Option;)Lorg/apache/commons/cli/Options;
pop
10: new org.apache.commons.cli.Option
dup
ldc "d"
iconst_0
ldc "CQL row per line internal representation"
invokespecial org.apache.commons.cli.Option.<init>:(Ljava/lang/String;ZLjava/lang/String;)V
astore 3
start local 3 11: getstatic org.apache.cassandra.tools.SSTableExport.options:Lorg/apache/commons/cli/Options;
aload 3
invokevirtual org.apache.commons.cli.Options.addOption:(Lorg/apache/commons/cli/Option;)Lorg/apache/commons/cli/Options;
pop
12: new org.apache.commons.cli.Option
dup
ldc "t"
iconst_0
ldc "Print raw timestamps instead of iso8601 date strings"
invokespecial org.apache.commons.cli.Option.<init>:(Ljava/lang/String;ZLjava/lang/String;)V
astore 4
start local 4 13: getstatic org.apache.cassandra.tools.SSTableExport.options:Lorg/apache/commons/cli/Options;
aload 4
invokevirtual org.apache.commons.cli.Options.addOption:(Lorg/apache/commons/cli/Option;)Lorg/apache/commons/cli/Options;
pop
end local 4 end local 3 end local 2 end local 1 end local 0 14: return
LocalVariableTable:
Start End Slot Name Signature
3 14 0 optKey Lorg/apache/commons/cli/Option;
6 14 1 excludeKey Lorg/apache/commons/cli/Option;
9 14 2 optEnumerate Lorg/apache/commons/cli/Option;
11 14 3 debugOutput Lorg/apache/commons/cli/Option;
13 14 4 rawTimestamps Lorg/apache/commons/cli/Option;
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/apache/cassandra/tools/SSTableExport;
public static org.apache.cassandra.config.CFMetaData metadataFromSSTable(org.apache.cassandra.io.sstable.Descriptor);
descriptor: (Lorg/apache/cassandra/io/sstable/Descriptor;)Lorg/apache/cassandra/config/CFMetaData;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=4, locals=7, args_size=1
start local 0 0: aload 0
getfield org.apache.cassandra.io.sstable.Descriptor.version:Lorg/apache/cassandra/io/sstable/format/Version;
invokevirtual org.apache.cassandra.io.sstable.format.Version.storeRows:()Z
ifne 2
1: new java.io.IOException
dup
ldc "pre-3.0 SSTable is not supported."
invokespecial java.io.IOException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.STATS:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.HEADER:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokestatic java.util.EnumSet.of:(Ljava/lang/Enum;Ljava/lang/Enum;)Ljava/util/EnumSet;
astore 1
start local 1 3: aload 0
invokevirtual org.apache.cassandra.io.sstable.Descriptor.getMetadataSerializer:()Lorg/apache/cassandra/io/sstable/metadata/IMetadataSerializer;
aload 0
aload 1
invokeinterface org.apache.cassandra.io.sstable.metadata.IMetadataSerializer.deserialize:(Lorg/apache/cassandra/io/sstable/Descriptor;Ljava/util/EnumSet;)Ljava/util/Map;
astore 2
start local 2 4: aload 2
getstatic org.apache.cassandra.io.sstable.metadata.MetadataType.HEADER:Lorg/apache/cassandra/io/sstable/metadata/MetadataType;
invokeinterface java.util.Map.get:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast org.apache.cassandra.db.SerializationHeader$Component
astore 3
start local 3 5: aload 0
invokestatic org.apache.cassandra.utils.FBUtilities.newPartitioner:(Lorg/apache/cassandra/io/sstable/Descriptor;)Lorg/apache/cassandra/dht/IPartitioner;
astore 4
start local 4 6: ldc "keyspace"
ldc "table"
invokestatic org.apache.cassandra.config.CFMetaData$Builder.create:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData$Builder;
aload 4
invokevirtual org.apache.cassandra.config.CFMetaData$Builder.withPartitioner:(Lorg/apache/cassandra/dht/IPartitioner;)Lorg/apache/cassandra/config/CFMetaData$Builder;
astore 5
start local 5 7: aload 3
invokevirtual org.apache.cassandra.db.SerializationHeader$Component.getStaticColumns:()Ljava/util/Map;
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
8: aload 5
invokedynamic accept(Lorg/apache/cassandra/config/CFMetaData$Builder;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/tools/SSTableExport.lambda$0(Lorg/apache/cassandra/config/CFMetaData$Builder;Ljava/util/Map$Entry;)V (6)
(Ljava/util/Map$Entry;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
9: aload 3
invokevirtual org.apache.cassandra.db.SerializationHeader$Component.getRegularColumns:()Ljava/util/Map;
invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
invokeinterface java.util.Set.stream:()Ljava/util/stream/Stream;
10: aload 5
invokedynamic accept(Lorg/apache/cassandra/config/CFMetaData$Builder;)Ljava/util/function/Consumer;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)V
org/apache/cassandra/tools/SSTableExport.lambda$1(Lorg/apache/cassandra/config/CFMetaData$Builder;Ljava/util/Map$Entry;)V (6)
(Ljava/util/Map$Entry;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
11: aload 5
ldc "PartitionKey"
aload 3
invokevirtual org.apache.cassandra.db.SerializationHeader$Component.getKeyType:()Lorg/apache/cassandra/db/marshal/AbstractType;
invokevirtual org.apache.cassandra.config.CFMetaData$Builder.addPartitionKey:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/config/CFMetaData$Builder;
pop
12: iconst_0
istore 6
start local 6 13: goto 18
14: StackMap locals: org.apache.cassandra.io.sstable.Descriptor java.util.EnumSet java.util.Map org.apache.cassandra.db.SerializationHeader$Component org.apache.cassandra.dht.IPartitioner org.apache.cassandra.config.CFMetaData$Builder int
StackMap stack:
aload 5
new java.lang.StringBuilder
dup
ldc "clustering"
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
iload 6
ifle 15
iload 6
invokestatic java.lang.Integer.valueOf:(I)Ljava/lang/Integer;
goto 16
StackMap locals: org.apache.cassandra.io.sstable.Descriptor java.util.EnumSet java.util.Map org.apache.cassandra.db.SerializationHeader$Component org.apache.cassandra.dht.IPartitioner org.apache.cassandra.config.CFMetaData$Builder int
StackMap stack: org.apache.cassandra.config.CFMetaData$Builder java.lang.StringBuilder
15: ldc ""
StackMap locals: org.apache.cassandra.io.sstable.Descriptor java.util.EnumSet java.util.Map org.apache.cassandra.db.SerializationHeader$Component org.apache.cassandra.dht.IPartitioner org.apache.cassandra.config.CFMetaData$Builder int
StackMap stack: org.apache.cassandra.config.CFMetaData$Builder java.lang.StringBuilder java.lang.Comparable
16: invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
aload 3
invokevirtual org.apache.cassandra.db.SerializationHeader$Component.getClusteringTypes:()Ljava/util/List;
iload 6
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast org.apache.cassandra.db.marshal.AbstractType
invokevirtual org.apache.cassandra.config.CFMetaData$Builder.addClusteringColumn:(Ljava/lang/String;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/config/CFMetaData$Builder;
pop
17: iinc 6 1
StackMap locals:
StackMap stack:
18: iload 6
aload 3
invokevirtual org.apache.cassandra.db.SerializationHeader$Component.getClusteringTypes:()Ljava/util/List;
invokeinterface java.util.List.size:()I
if_icmplt 14
end local 6 19: aload 5
invokevirtual org.apache.cassandra.config.CFMetaData$Builder.build:()Lorg/apache/cassandra/config/CFMetaData;
areturn
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 desc Lorg/apache/cassandra/io/sstable/Descriptor;
3 20 1 types Ljava/util/EnumSet<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;>;
4 20 2 sstableMetadata Ljava/util/Map<Lorg/apache/cassandra/io/sstable/metadata/MetadataType;Lorg/apache/cassandra/io/sstable/metadata/MetadataComponent;>;
5 20 3 header Lorg/apache/cassandra/db/SerializationHeader$Component;
6 20 4 partitioner Lorg/apache/cassandra/dht/IPartitioner;
7 20 5 builder Lorg/apache/cassandra/config/CFMetaData$Builder;
13 19 6 i I
Exceptions:
throws java.io.IOException
MethodParameters:
Name Flags
desc
private static <T> java.util.stream.Stream<T> iterToStream(java.util.Iterator<T>);
descriptor: (Ljava/util/Iterator;)Ljava/util/stream/Stream;
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
sipush 1024
invokestatic java.util.Spliterators.spliteratorUnknownSize:(Ljava/util/Iterator;I)Ljava/util/Spliterator;
astore 1
start local 1 1: aload 1
iconst_0
invokestatic java.util.stream.StreamSupport.stream:(Ljava/util/Spliterator;Z)Ljava/util/stream/Stream;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 iter Ljava/util/Iterator<TT;>;
1 2 1 splititer Ljava/util/Spliterator<TT;>;
Signature: <T:Ljava/lang/Object;>(Ljava/util/Iterator<TT;>;)Ljava/util/stream/Stream<TT;>;
MethodParameters:
Name Flags
iter
public static void main(java.lang.String[]);
descriptor: ([Ljava/lang/String;)V
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=5, locals=12, args_size=1
start local 0 0: new org.apache.commons.cli.PosixParser
dup
invokespecial org.apache.commons.cli.PosixParser.<init>:()V
astore 1
start local 1 1: aload 1
getstatic org.apache.cassandra.tools.SSTableExport.options:Lorg/apache/commons/cli/Options;
aload 0
invokeinterface org.apache.commons.cli.CommandLineParser.parse:(Lorg/apache/commons/cli/Options;[Ljava/lang/String;)Lorg/apache/commons/cli/CommandLine;
putstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
2: goto 7
3: StackMap locals: java.lang.String[] org.apache.commons.cli.CommandLineParser
StackMap stack: org.apache.commons.cli.ParseException
astore 2
start local 2 4: getstatic java.lang.System.err:Ljava/io/PrintStream;
aload 2
invokevirtual org.apache.commons.cli.ParseException.getMessage:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: invokestatic org.apache.cassandra.tools.SSTableExport.printUsage:()V
6: iconst_1
invokestatic java.lang.System.exit:(I)V
end local 2 7: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
invokevirtual org.apache.commons.cli.CommandLine.getArgs:()[Ljava/lang/String;
arraylength
iconst_1
if_icmpeq 11
8: getstatic java.lang.System.err:Ljava/io/PrintStream;
ldc "You must supply exactly one sstable"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
9: invokestatic org.apache.cassandra.tools.SSTableExport.printUsage:()V
10: iconst_1
invokestatic java.lang.System.exit:(I)V
11: StackMap locals:
StackMap stack:
getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
ldc "k"
invokevirtual org.apache.commons.cli.CommandLine.getOptionValues:(Ljava/lang/String;)[Ljava/lang/String;
astore 2
start local 2 12: new java.util.HashSet
dup
13: getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
ldc "x"
invokevirtual org.apache.commons.cli.CommandLine.getOptionValues:(Ljava/lang/String;)[Ljava/lang/String;
ifnonnull 15
14: iconst_0
anewarray java.lang.String
goto 16
15: StackMap locals: java.lang.String[] org.apache.commons.cli.CommandLineParser java.lang.String[]
StackMap stack: new 12 new 12
getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
ldc "x"
invokevirtual org.apache.commons.cli.CommandLine.getOptionValues:(Ljava/lang/String;)[Ljava/lang/String;
16: StackMap locals: java.lang.String[] org.apache.commons.cli.CommandLineParser java.lang.String[]
StackMap stack: new 12 new 12 java.lang.String[]
invokestatic java.util.Arrays.asList:([Ljava/lang/Object;)Ljava/util/List;
invokespecial java.util.HashSet.<init>:(Ljava/util/Collection;)V
astore 3
start local 3 17: new java.io.File
dup
getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
invokevirtual org.apache.commons.cli.CommandLine.getArgs:()[Ljava/lang/String;
iconst_0
aaload
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
invokevirtual java.io.File.getAbsolutePath:()Ljava/lang/String;
astore 4
start local 4 18: new java.io.File
dup
aload 4
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
invokestatic org.apache.cassandra.io.sstable.Descriptor.isLegacyFile:(Ljava/io/File;)Z
ifeq 21
19: getstatic java.lang.System.err:Ljava/io/PrintStream;
ldc "Unsupported legacy sstable"
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
20: iconst_1
invokestatic java.lang.System.exit:(I)V
21: StackMap locals: java.util.HashSet java.lang.String
StackMap stack:
new java.io.File
dup
aload 4
invokespecial java.io.File.<init>:(Ljava/lang/String;)V
invokevirtual java.io.File.exists:()Z
ifne 24
22: getstatic java.lang.System.err:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "Cannot find file "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 4
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
23: iconst_1
invokestatic java.lang.System.exit:(I)V
24: StackMap locals:
StackMap stack:
aload 4
invokestatic org.apache.cassandra.io.sstable.Descriptor.fromFilename:(Ljava/lang/String;)Lorg/apache/cassandra/io/sstable/Descriptor;
astore 5
start local 5 25: aload 5
invokestatic org.apache.cassandra.tools.SSTableExport.metadataFromSSTable:(Lorg/apache/cassandra/io/sstable/Descriptor;)Lorg/apache/cassandra/config/CFMetaData;
astore 6
start local 6 26: getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
ldc "e"
invokevirtual org.apache.commons.cli.CommandLine.hasOption:(Ljava/lang/String;)Z
ifeq 40
27: aconst_null
astore 7
aconst_null
astore 8
28: new org.apache.cassandra.io.sstable.KeyIterator
dup
aload 5
aload 6
invokespecial org.apache.cassandra.io.sstable.KeyIterator.<init>:(Lorg/apache/cassandra/io/sstable/Descriptor;Lorg/apache/cassandra/config/CFMetaData;)V
astore 9
start local 9 29: aconst_null
aload 9
invokestatic org.apache.cassandra.tools.SSTableExport.iterToStream:(Ljava/util/Iterator;)Ljava/util/stream/Stream;
30: getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
ldc "t"
invokevirtual org.apache.commons.cli.CommandLine.hasOption:(Ljava/lang/String;)Z
31: aload 6
32: getstatic java.lang.System.out:Ljava/io/PrintStream;
33: invokestatic org.apache.cassandra.tools.JsonTransformer.keysToJson:(Lorg/apache/cassandra/io/sstable/ISSTableScanner;Ljava/util/stream/Stream;ZLorg/apache/cassandra/config/CFMetaData;Ljava/io/OutputStream;)V
34: aload 9
ifnull 63
aload 9
invokevirtual org.apache.cassandra.io.sstable.KeyIterator.close:()V
goto 63
StackMap locals: java.lang.String[] org.apache.commons.cli.CommandLineParser java.lang.String[] java.util.HashSet java.lang.String org.apache.cassandra.io.sstable.Descriptor org.apache.cassandra.config.CFMetaData java.lang.Throwable java.lang.Throwable org.apache.cassandra.io.sstable.KeyIterator
StackMap stack: java.lang.Throwable
35: astore 7
aload 9
ifnull 36
aload 9
invokevirtual org.apache.cassandra.io.sstable.KeyIterator.close:()V
end local 9 StackMap locals:
StackMap stack:
36: aload 7
athrow
StackMap locals:
StackMap stack: java.lang.Throwable
37: astore 8
aload 7
ifnonnull 38
aload 8
astore 7
goto 39
StackMap locals:
StackMap stack:
38: aload 7
aload 8
if_acmpeq 39
aload 7
aload 8
invokevirtual java.lang.Throwable.addSuppressed:(Ljava/lang/Throwable;)V
StackMap locals:
StackMap stack:
39: aload 7
athrow
40: StackMap locals:
StackMap stack:
aload 5
aload 6
invokestatic org.apache.cassandra.io.sstable.format.SSTableReader.openNoValidation:(Lorg/apache/cassandra/io/sstable/Descriptor;Lorg/apache/cassandra/config/CFMetaData;)Lorg/apache/cassandra/io/sstable/format/SSTableReader;
astore 7
start local 7 41: aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getPartitioner:()Lorg/apache/cassandra/dht/IPartitioner;
astore 8
start local 8 42: aload 2
ifnull 53
aload 2
arraylength
ifle 53
43: aload 2
invokestatic java.util.Arrays.stream:([Ljava/lang/Object;)Ljava/util/stream/Stream;
44: aload 3
invokedynamic test(Ljava/util/HashSet;)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/tools/SSTableExport.lambda$2(Ljava/util/HashSet;Ljava/lang/String;)Z (6)
(Ljava/lang/String;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
45: aload 6
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic apply(Lorg/apache/cassandra/db/marshal/AbstractType;)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/marshal/AbstractType.fromString(Ljava/lang/String;)Ljava/nio/ByteBuffer; (5)
(Ljava/lang/String;)Ljava/nio/ByteBuffer;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
46: aload 8
dup
invokevirtual java.lang.Object.getClass:()Ljava/lang/Class;
pop
invokedynamic apply(Lorg/apache/cassandra/dht/IPartitioner;)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/dht/IPartitioner.decorateKey(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey; (9 itf)
(Ljava/nio/ByteBuffer;)Lorg/apache/cassandra/db/DecoratedKey;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
47: invokeinterface java.util.stream.Stream.sorted:()Ljava/util/stream/Stream;
48: invokedynamic apply()Ljava/util/function/Function;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
Method arguments:
(Ljava/lang/Object;)Ljava/lang/Object;
org/apache/cassandra/db/DecoratedKey.getToken()Lorg/apache/cassandra/dht/Token; (5)
(Lorg/apache/cassandra/db/DecoratedKey;)Lorg/apache/cassandra/dht/Token;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
49: 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/tools/SSTableExport.lambda$6(Lorg/apache/cassandra/dht/Token;)Lorg/apache/cassandra/dht/Bounds; (6)
(Lorg/apache/cassandra/dht/Token;)Lorg/apache/cassandra/dht/Bounds;
invokeinterface java.util.stream.Stream.map:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
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
50: astore 10
start local 10 51: aload 7
aload 10
invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getScanner:(Ljava/util/Iterator;)Lorg/apache/cassandra/io/sstable/ISSTableScanner;
astore 9
end local 10 start local 9 52: goto 54
end local 9 53: StackMap locals: org.apache.cassandra.io.sstable.format.SSTableReader org.apache.cassandra.dht.IPartitioner
StackMap stack:
aload 7
invokevirtual org.apache.cassandra.io.sstable.format.SSTableReader.getScanner:()Lorg/apache/cassandra/io/sstable/ISSTableScanner;
astore 9
start local 9 54: StackMap locals: org.apache.cassandra.io.sstable.ISSTableScanner
StackMap stack:
aload 9
invokestatic org.apache.cassandra.tools.SSTableExport.iterToStream:(Ljava/util/Iterator;)Ljava/util/stream/Stream;
aload 3
aload 6
invokedynamic test(Ljava/util/HashSet;Lorg/apache/cassandra/config/CFMetaData;)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/tools/SSTableExport.lambda$7(Ljava/util/HashSet;Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Z (6)
(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Z
invokeinterface java.util.stream.Stream.filter:(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
astore 10
start local 10 55: getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
ldc "d"
invokevirtual org.apache.commons.cli.CommandLine.hasOption:(Ljava/lang/String;)Z
ifeq 59
56: new java.util.concurrent.atomic.AtomicLong
dup
invokespecial java.util.concurrent.atomic.AtomicLong.<init>:()V
astore 11
start local 11 57: aload 10
aload 11
aload 9
aload 6
invokedynamic accept(Ljava/util/concurrent/atomic/AtomicLong;Lorg/apache/cassandra/io/sstable/ISSTableScanner;Lorg/apache/cassandra/config/CFMetaData;)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/tools/SSTableExport.lambda$8(Ljava/util/concurrent/atomic/AtomicLong;Lorg/apache/cassandra/io/sstable/ISSTableScanner;Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)V (6)
(Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
end local 11 58: goto 63
59: StackMap locals: java.util.stream.Stream
StackMap stack:
aload 9
aload 10
getstatic org.apache.cassandra.tools.SSTableExport.cmd:Lorg/apache/commons/cli/CommandLine;
ldc "t"
invokevirtual org.apache.commons.cli.CommandLine.hasOption:(Ljava/lang/String;)Z
aload 6
getstatic java.lang.System.out:Ljava/io/PrintStream;
invokestatic org.apache.cassandra.tools.JsonTransformer.toJson:(Lorg/apache/cassandra/io/sstable/ISSTableScanner;Ljava/util/stream/Stream;ZLorg/apache/cassandra/config/CFMetaData;Ljava/io/OutputStream;)V
end local 10 end local 9 end local 8 end local 7 end local 6 60: goto 63
61: StackMap locals: java.lang.String[] org.apache.commons.cli.CommandLineParser java.lang.String[] java.util.HashSet java.lang.String org.apache.cassandra.io.sstable.Descriptor
StackMap stack: java.io.IOException
astore 6
start local 6 62: aload 6
getstatic java.lang.System.err:Ljava/io/PrintStream;
invokevirtual java.io.IOException.printStackTrace:(Ljava/io/PrintStream;)V
end local 6 63: StackMap locals:
StackMap stack:
iconst_0
invokestatic java.lang.System.exit:(I)V
64: return
end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 65 0 args [Ljava/lang/String;
1 65 1 parser Lorg/apache/commons/cli/CommandLineParser;
4 7 2 e1 Lorg/apache/commons/cli/ParseException;
12 65 2 keys [Ljava/lang/String;
17 65 3 excludes Ljava/util/HashSet<Ljava/lang/String;>;
18 65 4 ssTableFileName Ljava/lang/String;
25 65 5 desc Lorg/apache/cassandra/io/sstable/Descriptor;
26 60 6 metadata Lorg/apache/cassandra/config/CFMetaData;
29 36 9 iter Lorg/apache/cassandra/io/sstable/KeyIterator;
41 60 7 sstable Lorg/apache/cassandra/io/sstable/format/SSTableReader;
42 60 8 partitioner Lorg/apache/cassandra/dht/IPartitioner;
52 53 9 currentScanner Lorg/apache/cassandra/io/sstable/ISSTableScanner;
54 60 9 currentScanner Lorg/apache/cassandra/io/sstable/ISSTableScanner;
51 52 10 bounds Ljava/util/List<Lorg/apache/cassandra/dht/AbstractBounds<Lorg/apache/cassandra/db/PartitionPosition;>;>;
55 60 10 partitions Ljava/util/stream/Stream<Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;>;
57 58 11 position Ljava/util/concurrent/atomic/AtomicLong;
62 63 6 e Ljava/io/IOException;
Exception table:
from to target type
1 2 3 Class org.apache.commons.cli.ParseException
29 34 35 any
28 37 37 any
25 60 61 Class java.io.IOException
Exceptions:
throws org.apache.cassandra.exceptions.ConfigurationException
MethodParameters:
Name Flags
args
private static void printUsage();
descriptor: ()V
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=5, locals=2, args_size=0
0: ldc "sstabledump <sstable file path> <options>%n"
iconst_0
anewarray java.lang.Object
invokestatic java.lang.String.format:(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String;
astore 0
start local 0 1: ldc "Dump contents of given SSTable to standard output in JSON format."
astore 1
start local 1 2: new org.apache.commons.cli.HelpFormatter
dup
invokespecial org.apache.commons.cli.HelpFormatter.<init>:()V
aload 0
aload 1
getstatic org.apache.cassandra.tools.SSTableExport.options:Lorg/apache/commons/cli/Options;
ldc ""
invokevirtual org.apache.commons.cli.HelpFormatter.printHelp:(Ljava/lang/String;Ljava/lang/String;Lorg/apache/commons/cli/Options;Ljava/lang/String;)V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
1 4 0 usage Ljava/lang/String;
2 4 1 header Ljava/lang/String;
private static void lambda$0(org.apache.cassandra.config.CFMetaData$Builder, java.util.Map$Entry);
descriptor: (Lorg/apache/cassandra/config/CFMetaData$Builder;Ljava/util/Map$Entry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
start local 1 0: getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
aload 1
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
invokevirtual org.apache.cassandra.db.marshal.UTF8Type.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
iconst_1
invokestatic org.apache.cassandra.cql3.ColumnIdentifier.getInterned:(Ljava/lang/String;Z)Lorg/apache/cassandra/cql3/ColumnIdentifier;
astore 2
start local 2 1: aload 0
aload 2
aload 1
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.marshal.AbstractType
invokevirtual org.apache.cassandra.config.CFMetaData$Builder.addStaticColumn:(Lorg/apache/cassandra/cql3/ColumnIdentifier;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/config/CFMetaData$Builder;
pop
end local 2 2: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 entry Ljava/util/Map$Entry<Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
1 2 2 ident Lorg/apache/cassandra/cql3/ColumnIdentifier;
private static void lambda$1(org.apache.cassandra.config.CFMetaData$Builder, java.util.Map$Entry);
descriptor: (Lorg/apache/cassandra/config/CFMetaData$Builder;Ljava/util/Map$Entry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
start local 1 0: getstatic org.apache.cassandra.db.marshal.UTF8Type.instance:Lorg/apache/cassandra/db/marshal/UTF8Type;
aload 1
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.nio.ByteBuffer
invokevirtual org.apache.cassandra.db.marshal.UTF8Type.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
iconst_1
invokestatic org.apache.cassandra.cql3.ColumnIdentifier.getInterned:(Ljava/lang/String;Z)Lorg/apache/cassandra/cql3/ColumnIdentifier;
astore 2
start local 2 1: aload 0
aload 2
aload 1
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast org.apache.cassandra.db.marshal.AbstractType
invokevirtual org.apache.cassandra.config.CFMetaData$Builder.addRegularColumn:(Lorg/apache/cassandra/cql3/ColumnIdentifier;Lorg/apache/cassandra/db/marshal/AbstractType;)Lorg/apache/cassandra/config/CFMetaData$Builder;
pop
end local 2 2: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 3 1 entry Ljava/util/Map$Entry<Ljava/nio/ByteBuffer;Lorg/apache/cassandra/db/marshal/AbstractType<*>;>;
1 2 2 ident Lorg/apache/cassandra/cql3/ColumnIdentifier;
private static boolean lambda$2(java.util.HashSet, java.lang.String);
descriptor: (Ljava/util/HashSet;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 java.util.HashSet.contains:(Ljava/lang/Object;)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 key Ljava/lang/String;
private static org.apache.cassandra.dht.Bounds lambda$6(org.apache.cassandra.dht.Token);
descriptor: (Lorg/apache/cassandra/dht/Token;)Lorg/apache/cassandra/dht/Bounds;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: new org.apache.cassandra.dht.Bounds
dup
aload 0
invokevirtual org.apache.cassandra.dht.Token.minKeyBound:()Lorg/apache/cassandra/dht/Token$KeyBound;
aload 0
invokevirtual org.apache.cassandra.dht.Token.maxKeyBound:()Lorg/apache/cassandra/dht/Token$KeyBound;
invokespecial org.apache.cassandra.dht.Bounds.<init>:(Lorg/apache/cassandra/dht/RingPosition;Lorg/apache/cassandra/dht/RingPosition;)V
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 token Lorg/apache/cassandra/dht/Token;
private static boolean lambda$7(java.util.HashSet, org.apache.cassandra.config.CFMetaData, org.apache.cassandra.db.rows.UnfilteredRowIterator);
descriptor: (Ljava/util/HashSet;Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)Z
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=3
start local 2 0: aload 0
invokevirtual java.util.HashSet.isEmpty:()Z
ifne 1
aload 0
aload 1
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 2
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
invokevirtual java.util.HashSet.contains:(Ljava/lang/Object;)Z
ifeq 1
iconst_0
goto 2
StackMap locals:
StackMap stack:
1: iconst_1
StackMap locals:
StackMap stack: int
2: ireturn
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 3 2 i Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
private static void lambda$8(java.util.concurrent.atomic.AtomicLong, org.apache.cassandra.io.sstable.ISSTableScanner, org.apache.cassandra.config.CFMetaData, org.apache.cassandra.db.rows.UnfilteredRowIterator);
descriptor: (Ljava/util/concurrent/atomic/AtomicLong;Lorg/apache/cassandra/io/sstable/ISSTableScanner;Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=4, args_size=4
start local 3 0: aload 0
aload 1
invokeinterface org.apache.cassandra.io.sstable.ISSTableScanner.getCurrentPosition:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
1: aload 3
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual org.apache.cassandra.db.DeletionTime.isLive:()Z
ifne 5
2: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "["
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 3
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "]@"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
3: aload 0
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionLevelDeletion:()Lorg/apache/cassandra/db/DeletionTime;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
4: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: StackMap locals:
StackMap stack:
aload 3
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
invokeinterface org.apache.cassandra.db.rows.Row.isEmpty:()Z
ifne 9
6: getstatic java.lang.System.out:Ljava/io/PrintStream;
new java.lang.StringBuilder
dup
ldc "["
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 2
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 3
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "]@"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
7: aload 0
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 3
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.staticRow:()Lorg/apache/cassandra/db/rows/Row;
aload 2
iconst_1
invokeinterface org.apache.cassandra.db.rows.Row.toString:(Lorg/apache/cassandra/config/CFMetaData;Z)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
8: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
9: StackMap locals:
StackMap stack:
aload 3
aload 2
aload 3
aload 0
aload 1
invokedynamic accept(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Ljava/util/concurrent/atomic/AtomicLong;Lorg/apache/cassandra/io/sstable/ISSTableScanner;)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/tools/SSTableExport.lambda$9(Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Ljava/util/concurrent/atomic/AtomicLong;Lorg/apache/cassandra/io/sstable/ISSTableScanner;Lorg/apache/cassandra/db/rows/Unfiltered;)V (6)
(Lorg/apache/cassandra/db/rows/Unfiltered;)V
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.forEachRemaining:(Ljava/util/function/Consumer;)V
10: return
end local 3 LocalVariableTable:
Start End Slot Name Signature
0 11 3 partition Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;
private static void lambda$9(org.apache.cassandra.config.CFMetaData, org.apache.cassandra.db.rows.UnfilteredRowIterator, java.util.concurrent.atomic.AtomicLong, org.apache.cassandra.io.sstable.ISSTableScanner, org.apache.cassandra.db.rows.Unfiltered);
descriptor: (Lorg/apache/cassandra/config/CFMetaData;Lorg/apache/cassandra/db/rows/UnfilteredRowIterator;Ljava/util/concurrent/atomic/AtomicLong;Lorg/apache/cassandra/io/sstable/ISSTableScanner;Lorg/apache/cassandra/db/rows/Unfiltered;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=6, locals=5, args_size=5
start local 4 0: getstatic java.lang.System.out:Ljava/io/PrintStream;
1: new java.lang.StringBuilder
dup
ldc "["
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual org.apache.cassandra.config.CFMetaData.getKeyValidator:()Lorg/apache/cassandra/db/marshal/AbstractType;
aload 1
invokeinterface org.apache.cassandra.db.rows.UnfilteredRowIterator.partitionKey:()Lorg/apache/cassandra/db/DecoratedKey;
invokevirtual org.apache.cassandra.db.DecoratedKey.getKey:()Ljava/nio/ByteBuffer;
invokevirtual org.apache.cassandra.db.marshal.AbstractType.getString:(Ljava/nio/ByteBuffer;)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "]@"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: aload 2
invokevirtual java.util.concurrent.atomic.AtomicLong.get:()J
invokevirtual java.lang.StringBuilder.append:(J)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 4
aload 0
iconst_0
iconst_1
invokeinterface org.apache.cassandra.db.rows.Unfiltered.toString:(Lorg/apache/cassandra/config/CFMetaData;ZZ)Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
3: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
4: invokevirtual java.io.PrintStream.println:(Ljava/lang/String;)V
5: aload 2
aload 3
invokeinterface org.apache.cassandra.io.sstable.ISSTableScanner.getCurrentPosition:()J
invokevirtual java.util.concurrent.atomic.AtomicLong.set:(J)V
6: return
end local 4 LocalVariableTable:
Start End Slot Name Signature
0 7 4 row Lorg/apache/cassandra/db/rows/Unfiltered;
}
SourceFile: "SSTableExport.java"
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 Builder = org.apache.cassandra.config.CFMetaData$Builder of org.apache.cassandra.config.CFMetaData
public Component = org.apache.cassandra.db.SerializationHeader$Component of org.apache.cassandra.db.SerializationHeader
public KeyBound = org.apache.cassandra.dht.Token$KeyBound of org.apache.cassandra.dht.Token