org.apache.cassandra/cassandra-all/3.11.5 : org/apache/cassandra/service/StorageService$7.class

StorageService$7

https://cassandra.apache.org: The Apache Cassandra Project develops a highly scalable second-generation distributed database, bringing together Dynamo's fully distributed design and Bigtable's ColumnFamily-based data model.

The Apache Software License, Version 2.0

Andres de la Peña
Avinash Lakshman
Aleksey Yeschenko
Aaron Morton
Ariel Weisberg
Blake Eggleston
Benedict Elliott Smith
Benjamin Lerer
Branimir Lambov
Brandon Williams
Carl Yeksigian
David Brosiusd
Dikang Gu
Eric Evans
Gary Dusbabek
Chris Goffinet
Alex Petrov
Laine Jaakko Olavi
T Jake Luciani
Jason Brown
Jonathan Ellis
Jake Farrell
Jeff Jirsa
Joel Knighton
Josh McKenzie
Johan Oskarsson
Jun Rao
Jay Zhuang
Sankalp Kohli
Marcus Eriksson
Michael Semb Wever
Mikhail Stepura
Michael Shuler
Paulo Motta
Prashant Malik
Robert Stupp
Peter Schuller
Sam Tunnicliffe
Sylvain Lebresne
Stefania Alborghetti
Tyler Hobbs
Vijay Parthasarathy
Pavel Yaskevich
Yuki Morishita
Nate McCall

class org.apache.cassandra.service.StorageService$7 extends org.apache.cassandra.io.sstable.SSTableLoader$Client
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.apache.cassandra.service.StorageService$7
  super_class: org.apache.cassandra.io.sstable.SSTableLoader$Client
{
  private java.lang.String keyspace;
    descriptor: Ljava/lang/String;
    flags: (0x0002) ACC_PRIVATE

  final org.apache.cassandra.service.StorageService this$0;
    descriptor: Lorg/apache/cassandra/service/StorageService;
    flags: (0x1010) ACC_FINAL, ACC_SYNTHETIC

  void <init>(org.apache.cassandra.service.StorageService);
    descriptor: (Lorg/apache/cassandra/service/StorageService;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.apache.cassandra.service.StorageService$7 this
         0: .line 5173
            aload 0 /* this */
            aload 1
            putfield org.apache.cassandra.service.StorageService$7.this$0:Lorg/apache/cassandra/service/StorageService;
            aload 0 /* this */
            invokespecial org.apache.cassandra.io.sstable.SSTableLoader$Client.<init>:()V
            return
        end local 0 // org.apache.cassandra.service.StorageService$7 this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/apache/cassandra/service/StorageService$7;
    MethodParameters:
        Name  Flags
      this$0  final

  public void init(java.lang.String);
    descriptor: (Ljava/lang/String;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=7, args_size=2
        start local 0 // org.apache.cassandra.service.StorageService$7 this
        start local 1 // java.lang.String keyspace
         0: .line 5179
            aload 0 /* this */
            aload 1 /* keyspace */
            putfield org.apache.cassandra.service.StorageService$7.keyspace:Ljava/lang/String;
         1: .line 5182
            getstatic org.apache.cassandra.service.StorageService.instance:Lorg/apache/cassandra/service/StorageService;
            aload 1 /* keyspace */
            invokevirtual org.apache.cassandra.service.StorageService.getRangeToAddressMap:(Ljava/lang/String;)Ljava/util/Map;
            invokeinterface java.util.Map.entrySet:()Ljava/util/Set;
            invokeinterface java.util.Set.iterator:()Ljava/util/Iterator;
            astore 3
            goto 8
      StackMap locals: org.apache.cassandra.service.StorageService$7 java.lang.String top java.util.Iterator
      StackMap stack:
         2: aload 3
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.util.Map$Entry
            astore 2 /* entry */
        start local 2 // java.util.Map$Entry entry
         3: .line 5184
            aload 2 /* entry */
            invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
            checkcast org.apache.cassandra.dht.Range
            astore 4 /* range */
        start local 4 // org.apache.cassandra.dht.Range range
         4: .line 5185
            aload 2 /* entry */
            invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
            checkcast java.util.List
            invokeinterface java.util.List.iterator:()Ljava/util/Iterator;
            astore 6
            goto 7
      StackMap locals: org.apache.cassandra.service.StorageService$7 java.lang.String java.util.Map$Entry java.util.Iterator org.apache.cassandra.dht.Range top java.util.Iterator
      StackMap stack:
         5: aload 6
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 5 /* endpoint */
        start local 5 // java.net.InetAddress endpoint
         6: .line 5186
            aload 0 /* this */
            aload 4 /* range */
            aload 5 /* endpoint */
            invokevirtual org.apache.cassandra.service.StorageService$7.addRangeForEndpoint:(Lorg/apache/cassandra/dht/Range;Ljava/net/InetAddress;)V
        end local 5 // java.net.InetAddress endpoint
         7: .line 5185
      StackMap locals:
      StackMap stack:
            aload 6
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
        end local 4 // org.apache.cassandra.dht.Range range
        end local 2 // java.util.Map$Entry entry
         8: .line 5182
      StackMap locals: org.apache.cassandra.service.StorageService$7 java.lang.String top java.util.Iterator
      StackMap stack:
            aload 3
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 2
         9: .line 5188
            goto 12
        10: .line 5189
      StackMap locals: org.apache.cassandra.service.StorageService$7 java.lang.String
      StackMap stack: java.lang.Exception
            astore 2 /* e */
        start local 2 // java.lang.Exception e
        11: .line 5191
            new java.lang.RuntimeException
            dup
            aload 2 /* e */
            invokespecial java.lang.RuntimeException.<init>:(Ljava/lang/Throwable;)V
            athrow
        end local 2 // java.lang.Exception e
        12: .line 5193
      StackMap locals:
      StackMap stack:
            return
        end local 1 // java.lang.String keyspace
        end local 0 // org.apache.cassandra.service.StorageService$7 this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0   13     0      this  Lorg/apache/cassandra/service/StorageService$7;
            0   13     1  keyspace  Ljava/lang/String;
            3    8     2     entry  Ljava/util/Map$Entry<Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;Ljava/util/List<Ljava/net/InetAddress;>;>;
            4    8     4     range  Lorg/apache/cassandra/dht/Range<Lorg/apache/cassandra/dht/Token;>;
            6    7     5  endpoint  Ljava/net/InetAddress;
           11   12     2         e  Ljava/lang/Exception;
      Exception table:
        from    to  target  type
           1     9      10  Class java.lang.Exception
    MethodParameters:
          Name  Flags
      keyspace  

  public org.apache.cassandra.config.CFMetaData getTableMetadata(java.lang.String);
    descriptor: (Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.apache.cassandra.service.StorageService$7 this
        start local 1 // java.lang.String tableName
         0: .line 5197
            getstatic org.apache.cassandra.config.Schema.instance:Lorg/apache/cassandra/config/Schema;
            aload 0 /* this */
            getfield org.apache.cassandra.service.StorageService$7.keyspace:Ljava/lang/String;
            aload 1 /* tableName */
            invokevirtual org.apache.cassandra.config.Schema.getCFMetaData:(Ljava/lang/String;Ljava/lang/String;)Lorg/apache/cassandra/config/CFMetaData;
            areturn
        end local 1 // java.lang.String tableName
        end local 0 // org.apache.cassandra.service.StorageService$7 this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    1     0       this  Lorg/apache/cassandra/service/StorageService$7;
            0    1     1  tableName  Ljava/lang/String;
    MethodParameters:
           Name  Flags
      tableName  
}
SourceFile: "StorageService.java"
EnclosingMethod: org.apache.cassandra.service.StorageService.bulkLoadInternal:(Ljava/lang/String;)Lorg/apache/cassandra/streaming/StreamResultFuture;
NestHost: org.apache.cassandra.service.StorageService
InnerClasses:
  public abstract Entry = java.util.Map$Entry of java.util.Map
  public abstract Client = org.apache.cassandra.io.sstable.SSTableLoader$Client of org.apache.cassandra.io.sstable.SSTableLoader
  org.apache.cassandra.service.StorageService$7

/

org.apache.cassandra/ cassandra-all/ 3.11.5/ org/apache/cassandra/service/StorageService$7.class