public void addRangeTombstoneMarker()

in cassandra-bridge/src/main/java/org/apache/cassandra/spark/reader/Rid.java [181:203]

21 lines of code
7 McCabe index (conditional complexity)


    public void addRangeTombstoneMarker(RangeTombstoneMarker marker)
    {
        if (rangeTombstoneMarkers == null)
        {
            rangeTombstoneMarkers = new ArrayList<>();
        }

        // Ensure the marker list is valid
        if (rangeTombstoneMarkers.isEmpty())
        {
            Preconditions.checkArgument(!marker.isBoundary() && marker.isOpen(false),
                                        "The first marker should be an open bound");
            rangeTombstoneMarkers.add(marker);
        }
        else
        {
            RangeTombstoneMarker lastMarker = rangeTombstoneMarkers.get(rangeTombstoneMarkers.size() - 1);
            Preconditions.checkArgument((lastMarker.isOpen(false) && marker.isClose(false))
                                     || (lastMarker.isClose(false) && marker.isOpen(false)),
                                        "Current marker should close or open a new range");
            rangeTombstoneMarkers.add(marker);
        }
    }