Package org.apache.cassandra.db.rows

Class RangeTombstoneBoundaryMarker

java.lang.Object

org.apache.cassandra.db.rows.AbstractRangeTombstoneMarker<ClusteringBoundary<?>>

org.apache.cassandra.db.rows.RangeTombstoneBoundaryMarker

All Implemented Interfaces:

IMeasurableMemory, Clusterable, RangeTombstoneMarker, Unfiltered

public class RangeTombstoneBoundaryMarker
extends AbstractRangeTombstoneMarker<ClusteringBoundary<?>>

A range tombstone marker that represents a boundary between 2 range tombstones (i.e. it closes one range and open another).

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.cassandra.db.rows.RangeTombstoneMarker

RangeTombstoneMarker.Merger

Nested classes/interfaces inherited from interface org.apache.cassandra.db.rows.Unfiltered

Unfiltered.Kind

Field Summary

Fields inherited from class org.apache.cassandra.db.rows.AbstractRangeTombstoneMarker

bound

Constructor Summary

Constructors

Constructor	Description
RangeTombstoneBoundaryMarker(ClusteringBoundary<?> bound, DeletionTime endDeletion, DeletionTime startDeletion)

Method Summary

Modifier and Type	Method	Description
RangeTombstoneBoundaryMarker	clone(ByteBufferCloner cloner)
ClusteringBound<?>	closeBound(boolean reversed)
DeletionTime	closeDeletionTime(boolean reversed)
boolean	closeIsInclusive(boolean reversed)
RangeTombstoneBoundMarker	createCorrespondingCloseMarker(boolean reversed)
RangeTombstoneBoundMarker	createCorrespondingOpenMarker(boolean reversed)
void	digest(Digest digest)	Digest the atom using the provided Digest.
DeletionTime	endDeletionTime()	The deletion time for the range tombstone this boundary ends (in clustering order).
boolean	equals(java.lang.Object other)
static <V> RangeTombstoneBoundaryMarker	exclusiveCloseInclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime closeDeletion, DeletionTime openDeletion)
static <V> RangeTombstoneBoundaryMarker	exclusiveCloseInclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime closeDeletion, DeletionTime openDeletion)
int	hashCode()
boolean	hasInvalidDeletions()	Do a quick validation of the deletions of the unfiltered (if any)
static <V> RangeTombstoneBoundaryMarker	inclusiveCloseExclusiveOpen(boolean reversed, ClusteringPrefix<V> from, DeletionTime closeDeletion, DeletionTime openDeletion)
static <V> RangeTombstoneBoundaryMarker	inclusiveCloseExclusiveOpen(boolean reversed, V[] boundValues, ValueAccessor<V> accessor, DeletionTime closeDeletion, DeletionTime openDeletion)
boolean	isClose(boolean reversed)
boolean	isOpen(boolean reversed)
static <V1,V2> RangeTombstoneBoundaryMarker	makeBoundary(boolean reversed, ClusteringBound<V1> close, ClusteringBound<V2> open, DeletionTime closeDeletion, DeletionTime openDeletion)
ClusteringBound<?>	openBound(boolean reversed)
DeletionTime	openDeletionTime(boolean reversed)
boolean	openIsInclusive(boolean reversed)
DeletionTime	startDeletionTime()	The deletion time for the range tombstone this boundary starts (in clustering order).
java.lang.String	toString(TableMetadata metadata)
long	unsharedHeapSize()
RangeTombstoneBoundaryMarker	withNewOpeningDeletionTime(boolean reversed, DeletionTime newDeletionTime)

Methods inherited from class org.apache.cassandra.db.rows.AbstractRangeTombstoneMarker

clustering, isBoundary, kind, toString, toString, validateData

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.cassandra.db.rows.RangeTombstoneMarker

isEmpty

Methods inherited from interface org.apache.cassandra.db.rows.Unfiltered

isRangeTombstoneMarker, isRow

Constructor Detail

RangeTombstoneBoundaryMarker

public RangeTombstoneBoundaryMarker(ClusteringBoundary<?> bound,
                                    DeletionTime endDeletion,
                                    DeletionTime startDeletion)

Method Detail

exclusiveCloseInclusiveOpen

public static <V> RangeTombstoneBoundaryMarker exclusiveCloseInclusiveOpen(boolean reversed,
                                                                           V[] boundValues,
                                                                           ValueAccessor<V> accessor,
                                                                           DeletionTime closeDeletion,
                                                                           DeletionTime openDeletion)

exclusiveCloseInclusiveOpen

public static <V> RangeTombstoneBoundaryMarker exclusiveCloseInclusiveOpen(boolean reversed,
                                                                           ClusteringPrefix<V> from,
                                                                           DeletionTime closeDeletion,
                                                                           DeletionTime openDeletion)

inclusiveCloseExclusiveOpen

public static <V> RangeTombstoneBoundaryMarker inclusiveCloseExclusiveOpen(boolean reversed,
                                                                           V[] boundValues,
                                                                           ValueAccessor<V> accessor,
                                                                           DeletionTime closeDeletion,
                                                                           DeletionTime openDeletion)

inclusiveCloseExclusiveOpen

public static <V> RangeTombstoneBoundaryMarker inclusiveCloseExclusiveOpen(boolean reversed,
                                                                           ClusteringPrefix<V> from,
                                                                           DeletionTime closeDeletion,
                                                                           DeletionTime openDeletion)

endDeletionTime

public DeletionTime endDeletionTime()

The deletion time for the range tombstone this boundary ends (in clustering order).

startDeletionTime

public DeletionTime startDeletionTime()

The deletion time for the range tombstone this boundary starts (in clustering order).

closeDeletionTime

public DeletionTime closeDeletionTime(boolean reversed)

openDeletionTime

public DeletionTime openDeletionTime(boolean reversed)

openIsInclusive

public boolean openIsInclusive(boolean reversed)

openBound

public ClusteringBound<?> openBound(boolean reversed)

closeBound

public ClusteringBound<?> closeBound(boolean reversed)

closeIsInclusive

public boolean closeIsInclusive(boolean reversed)

isOpen

public boolean isOpen(boolean reversed)

Specified by:

isOpen in interface RangeTombstoneMarker

Overrides:

isOpen in class AbstractRangeTombstoneMarker<ClusteringBoundary<?>>

isClose

public boolean isClose(boolean reversed)

Specified by:

isClose in interface RangeTombstoneMarker

Overrides:

isClose in class AbstractRangeTombstoneMarker<ClusteringBoundary<?>>

hasInvalidDeletions

public boolean hasInvalidDeletions()

Description copied from interface: Unfiltered

Do a quick validation of the deletions of the unfiltered (if any)

Returns:

true if any deletion is invalid

clone

public RangeTombstoneBoundaryMarker clone(ByteBufferCloner cloner)

withNewOpeningDeletionTime

public RangeTombstoneBoundaryMarker withNewOpeningDeletionTime(boolean reversed,
                                                               DeletionTime newDeletionTime)

makeBoundary

public static <V1,V2> RangeTombstoneBoundaryMarker makeBoundary(boolean reversed,
                                                                      ClusteringBound<V1> close,
                                                                      ClusteringBound<V2> open,
                                                                      DeletionTime closeDeletion,
                                                                      DeletionTime openDeletion)

createCorrespondingCloseMarker

public RangeTombstoneBoundMarker createCorrespondingCloseMarker(boolean reversed)

createCorrespondingOpenMarker

public RangeTombstoneBoundMarker createCorrespondingOpenMarker(boolean reversed)

digest

public void digest(Digest digest)

Description copied from interface: Unfiltered

Digest the atom using the provided Digest.

Parameters:

digest - the {@see Digest} to use.

unsharedHeapSize

public long unsharedHeapSize()

Returns:

the amount of on-heap memory retained by the object that might be reclaimed if the object were reclaimed, i.e. it should try to exclude globally cached data where possible, or counting portions of arrays that are referenced by the object but used by other objects only (e.g. slabbed byte-buffers), etc.

toString

public java.lang.String toString(TableMetadata metadata)

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object