cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/ReplicaSet.java [69:78]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    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;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/PartitionedDataLayer.java [476:485]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        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;
        }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -