Package org.apache.cassandra.index.sai.disk.v1

Class SkinnyPrimaryKeyMap

java.lang.Object

org.apache.cassandra.index.sai.disk.v1.SkinnyPrimaryKeyMap

All Implemented Interfaces:

Closeable, AutoCloseable, PrimaryKeyMap

Direct Known Subclasses:

WidePrimaryKeyMap

@NotThreadSafe
public class SkinnyPrimaryKeyMap
extends Object
implements PrimaryKeyMap

A PrimaryKeyMap for skinny tables (those with no clustering columns).

This uses the following on-disk structures:

• A block-packed structure for rowId to token value lookups using BlockPackedReader. Uses the IndexComponent.ROW_TO_TOKEN component
• A monotonic block packed structure for rowId to partitionId lookups using MonotonicBlockPackedReader. Uses the IndexComponent.ROW_TO_PARTITION component
• A key store for rowId to PrimaryKey and PrimaryKey to rowId lookups using KeyLookup. Uses the IndexComponent.PARTITION_KEY_BLOCKS and IndexComponent.PARTITION_KEY_BLOCK_OFFSETS components

While the SkinnyPrimaryKeyMap.Factory is threadsafe, individual instances of the SkinnyPrimaryKeyMap are not.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SkinnyPrimaryKeyMap.Factory

Field Summary

Fields

Modifier and Type	Field	Description
protected final KeyLookup.Cursor	partitionKeyCursor
protected final PrimaryKey.Factory	primaryKeyFactory
protected final LongArray	rowIdToPartitionIdArray
protected final LongArray	rowIdToTokenArray
protected final SSTableId	sstableId

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SkinnyPrimaryKeyMap(LongArray rowIdToTokenArray, LongArray rowIdToPartitionIdArray, KeyLookup.Cursor partitionKeyCursor, PrimaryKey.Factory primaryKeyFactory, SSTableId sstableId)

Method Summary

Modifier and Type	Method	Description
long	ceiling(Token token)	Returns the first row ID of the nearest Token greater than or equal to the given Token, or a negative value if not found
void	close()
long	floor(Token token)	Returns the last row ID of the nearest Token less than or equal to the given Token, or a negative value if the Token is at its minimum value
SSTableId	getSSTableId()	Returns the SSTableId associated with this PrimaryKeyMap
PrimaryKey	primaryKeyFromRowId(long sstableRowId)	Returns a PrimaryKey for a row ID
protected DecoratedKey	readPartitionKey(long sstableRowId)
long	rowIdFromPrimaryKey(PrimaryKey primaryKey)	Returns a row ID for a PrimaryKey
protected long	tokenCollisionDetection(PrimaryKey primaryKey, long rowId)

Methods inherited from class java.lang.Object

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

Field Details

rowIdToTokenArray

protected final LongArray rowIdToTokenArray

rowIdToPartitionIdArray

protected final LongArray rowIdToPartitionIdArray

partitionKeyCursor

protected final KeyLookup.Cursor partitionKeyCursor

primaryKeyFactory

protected final PrimaryKey.Factory primaryKeyFactory

sstableId

protected final SSTableId sstableId

Constructor Details

SkinnyPrimaryKeyMap

protected SkinnyPrimaryKeyMap(LongArray rowIdToTokenArray,
 LongArray rowIdToPartitionIdArray,
 KeyLookup.Cursor partitionKeyCursor,
 PrimaryKey.Factory primaryKeyFactory,
 SSTableId sstableId)

Method Details

getSSTableId

public SSTableId getSSTableId()

Description copied from interface: PrimaryKeyMap

Returns the SSTableId associated with this PrimaryKeyMap

Specified by:

getSSTableId in interface PrimaryKeyMap

Returns:

an SSTableId

primaryKeyFromRowId

public PrimaryKey primaryKeyFromRowId(long sstableRowId)

Description copied from interface: PrimaryKeyMap

Returns a PrimaryKey for a row ID

Specified by:

primaryKeyFromRowId in interface PrimaryKeyMap

Parameters:

sstableRowId - the row ID to lookup

Returns:

the PrimaryKey associated with the row ID

rowIdFromPrimaryKey

public long rowIdFromPrimaryKey(PrimaryKey primaryKey)

Description copied from interface: PrimaryKeyMap

Returns a row ID for a PrimaryKey

Specified by:

rowIdFromPrimaryKey in interface PrimaryKeyMap

Parameters:

primaryKey - the PrimaryKey to lookup

Returns:

the row ID associated with the PrimaryKey

ceiling

public long ceiling(Token token)

Description copied from interface: PrimaryKeyMap

Returns the first row ID of the nearest Token greater than or equal to the given Token, or a negative value if not found

Specified by:

ceiling in interface PrimaryKeyMap

Parameters:

token - the Token to lookup

Returns:

the ceiling row ID associated with the Token or a negative value

floor

public long floor(Token token)

Description copied from interface: PrimaryKeyMap

Returns the last row ID of the nearest Token less than or equal to the given Token, or a negative value if the Token is at its minimum value

Specified by:

floor in interface PrimaryKeyMap

Parameters:

token - the Token to lookup

Returns:

the floor row ID associated with the Token

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface PrimaryKeyMap

tokenCollisionDetection

protected long tokenCollisionDetection(PrimaryKey primaryKey,
 long rowId)

readPartitionKey

protected DecoratedKey readPartitionKey(long sstableRowId)