cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/ReplicaSet.java [48:57]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public ReplicaSet add(CassandraInstance instance)
    {
        if (primary.size() < minReplicas)
        {
            LOGGER.info("Selecting instance as primary replica nodeName={} token={} dataCenter={} partitionId={}",
                        instance.nodeName(), instance.token(), instance.dataCenter(), partitionId);
            return addPrimary(instance);
        }
        return addBackup(instance);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/PartitionedDataLayer.java [455:464]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        public ReplicaSet add(CassandraInstance instance)
        {
            if (primary.size() < minReplicas)
            {
                LOGGER.info("Selecting instance as primary replica nodeName={} token={} dc={} partitionId={}",
                            instance.nodeName(), instance.token(), instance.dataCenter(), partitionId);
                return addPrimary(instance);
            }
            return addBackup(instance);
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -