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.
  • 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 
public final class org.apache.cassandra.db.view.ViewUtils
  minor version: 0
  major version: 59
  flags: flags: (0x0031) ACC_PUBLIC, ACC_FINAL, ACC_SUPER
  this_class: org.apache.cassandra.db.view.ViewUtils
  super_class: java.lang.Object
{
  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=1, locals=0, args_size=0
         0: .line 33
            ldc Lorg/apache/cassandra/db/view/ViewUtils;
            invokevirtual java.lang.Class.desiredAssertionStatus:()Z
            ifne 1
            iconst_1
            goto 2
      StackMap locals:
      StackMap stack:
         1: iconst_0
      StackMap locals:
      StackMap stack: int
         2: putstatic org.apache.cassandra.db.view.ViewUtils.$assertionsDisabled:Z
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.apache.cassandra.db.view.ViewUtils this
         0: .line 35
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 37
            return
        end local 0 // org.apache.cassandra.db.view.ViewUtils this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/apache/cassandra/db/view/ViewUtils;

  public static java.util.Optional<java.net.InetAddress> getViewNaturalEndpoint(java.lang.String, org.apache.cassandra.dht.Token, org.apache.cassandra.dht.Token);
    descriptor: (Ljava/lang/String;Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/Token;)Ljava/util/Optional;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=3, locals=9, args_size=3
        start local 0 // java.lang.String keyspaceName
        start local 1 // org.apache.cassandra.dht.Token baseToken
        start local 2 // org.apache.cassandra.dht.Token viewToken
         0: .line 63
            aload 0 /* keyspaceName */
            invokestatic org.apache.cassandra.db.Keyspace.open:(Ljava/lang/String;)Lorg/apache/cassandra/db/Keyspace;
            invokevirtual org.apache.cassandra.db.Keyspace.getReplicationStrategy:()Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            astore 3 /* replicationStrategy */
        start local 3 // org.apache.cassandra.locator.AbstractReplicationStrategy replicationStrategy
         1: .line 65
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEndpointSnitch:()Lorg/apache/cassandra/locator/IEndpointSnitch;
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
            astore 4 /* localDataCenter */
        start local 4 // java.lang.String localDataCenter
         2: .line 66
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 5 /* baseEndpoints */
        start local 5 // java.util.List baseEndpoints
         3: .line 67
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 6 /* viewEndpoints */
        start local 6 // java.util.List viewEndpoints
         4: .line 68
            aload 3 /* replicationStrategy */
            aload 1 /* baseToken */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getNaturalEndpoints:(Lorg/apache/cassandra/dht/RingPosition;)Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
            astore 8
            goto 9
      StackMap locals: java.lang.String org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.String java.util.List java.util.List top java.util.Iterator
      StackMap stack:
         5: aload 8
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 7 /* baseEndpoint */
        start local 7 // java.net.InetAddress baseEndpoint
         6: .line 71
            aload 3 /* replicationStrategy */
            instanceof org.apache.cassandra.locator.NetworkTopologyStrategy
            ifeq 8
         7: .line 72
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEndpointSnitch:()Lorg/apache/cassandra/locator/IEndpointSnitch;
            aload 7 /* baseEndpoint */
            invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
            aload 4 /* localDataCenter */
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 9
         8: .line 73
      StackMap locals: java.lang.String org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.String java.util.List java.util.List java.net.InetAddress java.util.Iterator
      StackMap stack:
            aload 5 /* baseEndpoints */
            aload 7 /* baseEndpoint */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 7 // java.net.InetAddress baseEndpoint
         9: .line 68
      StackMap locals: java.lang.String org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.String java.util.List java.util.List top java.util.Iterator
      StackMap stack:
            aload 8
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 5
        10: .line 76
            aload 3 /* replicationStrategy */
            aload 2 /* viewToken */
            invokevirtual org.apache.cassandra.locator.AbstractReplicationStrategy.getNaturalEndpoints:(Lorg/apache/cassandra/dht/RingPosition;)Ljava/util/ArrayList;
            invokevirtual java.util.ArrayList.iterator:()Ljava/util/Iterator;
            astore 8
            goto 19
      StackMap locals:
      StackMap stack:
        11: aload 8
            invokeinterface java.util.Iterator.next:()Ljava/lang/Object;
            checkcast java.net.InetAddress
            astore 7 /* viewEndpoint */
        start local 7 // java.net.InetAddress viewEndpoint
        12: .line 79
            aload 7 /* viewEndpoint */
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokevirtual java.net.InetAddress.equals:(Ljava/lang/Object;)Z
            ifeq 14
        13: .line 80
            aload 7 /* viewEndpoint */
            invokestatic java.util.Optional.of:(Ljava/lang/Object;)Ljava/util/Optional;
            areturn
        14: .line 84
      StackMap locals: java.lang.String org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.String java.util.List java.util.List java.net.InetAddress java.util.Iterator
      StackMap stack:
            aload 5 /* baseEndpoints */
            aload 7 /* viewEndpoint */
            invokeinterface java.util.List.contains:(Ljava/lang/Object;)Z
            ifeq 16
        15: .line 85
            aload 5 /* baseEndpoints */
            aload 7 /* viewEndpoint */
            invokeinterface java.util.List.remove:(Ljava/lang/Object;)Z
            pop
            goto 19
        16: .line 86
      StackMap locals:
      StackMap stack:
            aload 3 /* replicationStrategy */
            instanceof org.apache.cassandra.locator.NetworkTopologyStrategy
            ifeq 18
        17: .line 87
            invokestatic org.apache.cassandra.config.DatabaseDescriptor.getEndpointSnitch:()Lorg/apache/cassandra/locator/IEndpointSnitch;
            aload 7 /* viewEndpoint */
            invokeinterface org.apache.cassandra.locator.IEndpointSnitch.getDatacenter:(Ljava/net/InetAddress;)Ljava/lang/String;
            aload 4 /* localDataCenter */
            invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
            ifeq 19
        18: .line 88
      StackMap locals:
      StackMap stack:
            aload 6 /* viewEndpoints */
            aload 7 /* viewEndpoint */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
        end local 7 // java.net.InetAddress viewEndpoint
        19: .line 76
      StackMap locals: java.lang.String org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.String java.util.List java.util.List top java.util.Iterator
      StackMap stack:
            aload 8
            invokeinterface java.util.Iterator.hasNext:()Z
            ifne 11
        20: .line 94
            getstatic org.apache.cassandra.db.view.ViewUtils.$assertionsDisabled:Z
            ifne 21
            aload 5 /* baseEndpoints */
            invokeinterface java.util.List.size:()I
            aload 6 /* viewEndpoints */
            invokeinterface java.util.List.size:()I
            if_icmpeq 21
            new java.lang.AssertionError
            dup
            ldc "Replication strategy should have the same number of endpoints for the base and the view"
            invokespecial java.lang.AssertionError.<init>:(Ljava/lang/Object;)V
            athrow
        21: .line 95
      StackMap locals: java.lang.String org.apache.cassandra.dht.Token org.apache.cassandra.dht.Token org.apache.cassandra.locator.AbstractReplicationStrategy java.lang.String java.util.List java.util.List
      StackMap stack:
            aload 5 /* baseEndpoints */
            invokestatic org.apache.cassandra.utils.FBUtilities.getBroadcastAddress:()Ljava/net/InetAddress;
            invokeinterface java.util.List.indexOf:(Ljava/lang/Object;)I
            istore 7 /* baseIdx */
        start local 7 // int baseIdx
        22: .line 97
            iload 7 /* baseIdx */
            ifge 24
        23: .line 99
            invokestatic java.util.Optional.empty:()Ljava/util/Optional;
            areturn
        24: .line 101
      StackMap locals: int
      StackMap stack:
            aload 6 /* viewEndpoints */
            iload 7 /* baseIdx */
            invokeinterface java.util.List.get:(I)Ljava/lang/Object;
            checkcast java.net.InetAddress
            invokestatic java.util.Optional.of:(Ljava/lang/Object;)Ljava/util/Optional;
            areturn
        end local 7 // int baseIdx
        end local 6 // java.util.List viewEndpoints
        end local 5 // java.util.List baseEndpoints
        end local 4 // java.lang.String localDataCenter
        end local 3 // org.apache.cassandra.locator.AbstractReplicationStrategy replicationStrategy
        end local 2 // org.apache.cassandra.dht.Token viewToken
        end local 1 // org.apache.cassandra.dht.Token baseToken
        end local 0 // java.lang.String keyspaceName
      LocalVariableTable:
        Start  End  Slot                 Name  Signature
            0   25     0         keyspaceName  Ljava/lang/String;
            0   25     1            baseToken  Lorg/apache/cassandra/dht/Token;
            0   25     2            viewToken  Lorg/apache/cassandra/dht/Token;
            1   25     3  replicationStrategy  Lorg/apache/cassandra/locator/AbstractReplicationStrategy;
            2   25     4      localDataCenter  Ljava/lang/String;
            3   25     5        baseEndpoints  Ljava/util/List<Ljava/net/InetAddress;>;
            4   25     6        viewEndpoints  Ljava/util/List<Ljava/net/InetAddress;>;
            6    9     7         baseEndpoint  Ljava/net/InetAddress;
           12   19     7         viewEndpoint  Ljava/net/InetAddress;
           22   25     7              baseIdx  I
    Signature: (Ljava/lang/String;Lorg/apache/cassandra/dht/Token;Lorg/apache/cassandra/dht/Token;)Ljava/util/Optional<Ljava/net/InetAddress;>;
    MethodParameters:
              Name  Flags
      keyspaceName  
      baseToken     
      viewToken     
}
SourceFile: "ViewUtils.java"