cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/PartitionedDataLayer.java [460:492]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                            instance.nodeName(), instance.token(), instance.dataCenter(), partitionId);
                return addPrimary(instance);
            }
            return addBackup(instance);
        }

        public boolean isRepairPrimary(CassandraInstance instance)
        {
            return incrementalRepairPrimary == null || incrementalRepairPrimary.equals(instance);
        }

        public Set<CassandraInstance> primary()
        {
            return primary;
        }

        public ReplicaSet addPrimary(CassandraInstance instance)
        {
            if (incrementalRepairPrimary == null)
            {
                // Pick the first primary replica as a 'repair primary' to read repaired SSTables at CL ONE
                incrementalRepairPrimary = instance;
            }
            primary.add(instance);
            return this;
        }

        public Set<CassandraInstance> backup()
        {
            return backup;
        }

        public ReplicaSet addBackup(CassandraInstance instance)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/ReplicaSet.java [53:85]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        instance.nodeName(), instance.token(), instance.dataCenter(), partitionId);
            return addPrimary(instance);
        }
        return addBackup(instance);
    }

    public boolean isRepairPrimary(CassandraInstance instance)
    {
        return incrementalRepairPrimary == null || incrementalRepairPrimary.equals(instance);
    }

    public Set<CassandraInstance> primary()
    {
        return primary;
    }

    public ReplicaSet addPrimary(CassandraInstance instance)
    {
        if (incrementalRepairPrimary == null)
        {
            // Pick the first primary replica as a 'repair primary' to read repaired SSTables at CL ONE
            incrementalRepairPrimary = instance;
        }
        primary.add(instance);
        return this;
    }

    public Set<CassandraInstance> backup()
    {
        return backup;
    }

    public ReplicaSet addBackup(CassandraInstance instance)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -