Modifier and Type | Field and Description |
---|---|
IPartitioner |
CFMetaData.partitioner |
Modifier and Type | Method and Description |
---|---|
static IPartitioner |
DatabaseDescriptor.getPartitioner() |
static IPartitioner |
DatabaseDescriptor.setPartitionerUnsafe(IPartitioner newPartitioner) |
Modifier and Type | Method and Description |
---|---|
CFMetaData |
CFMetaData.copy(IPartitioner partitioner) |
static CFMetaData |
CFMetaData.create(java.lang.String ksName,
java.lang.String name,
java.util.UUID cfId,
boolean isDense,
boolean isCompound,
boolean isSuper,
boolean isCounter,
boolean isView,
java.util.List<ColumnDefinition> columns,
IPartitioner partitioner) |
static IPartitioner |
DatabaseDescriptor.setPartitionerUnsafe(IPartitioner newPartitioner) |
CFMetaData.Builder |
CFMetaData.Builder.withPartitioner(IPartitioner partitioner) |
Modifier and Type | Method and Description |
---|---|
IPartitioner |
ColumnFamilyStore.getPartitioner() |
IPartitioner |
DecoratedKey.getPartitioner() |
Modifier and Type | Method and Description |
---|---|
static DataRange |
DataRange.allData(IPartitioner partitioner)
Creates a
DataRange to query all data (over the whole ring). |
static DataRange |
DataRange.allData(IPartitioner partitioner,
ClusteringIndexFilter filter)
Creates a
DataRange to query all partitions of the ring using the provided
clustering index filter. |
static int |
DecoratedKey.compareTo(IPartitioner partitioner,
java.nio.ByteBuffer key,
PartitionPosition position) |
PartitionPosition |
PartitionPosition.RowPositionSerializer.deserialize(java.io.DataInput in,
IPartitioner p,
int version) |
static PartitionPosition |
PartitionPosition.ForKey.get(java.nio.ByteBuffer key,
IPartitioner p) |
static java.util.Set<Range<Token>> |
SystemKeyspace.getAvailableRanges(java.lang.String keyspace,
IPartitioner partitioner) |
static java.util.Map<java.net.InetAddress,java.util.Set<Range<Token>>> |
SystemKeyspace.getTransferredRanges(java.lang.String description,
java.lang.String keyspace,
IPartitioner partitioner) |
Constructor and Description |
---|
PartitionerDefinedOrder(IPartitioner partitioner) |
Modifier and Type | Class and Description |
---|---|
class |
ByteOrderedPartitioner |
class |
LocalPartitioner |
class |
Murmur3Partitioner
This class generates a BigIntegerToken using a Murmur3 hash.
|
class |
OrderPreservingPartitioner |
class |
RandomPartitioner
This class generates a BigIntegerToken using MD5 hash.
|
Modifier and Type | Method and Description |
---|---|
IPartitioner |
ByteOrderedPartitioner.BytesToken.getPartitioner() |
IPartitioner |
LocalPartitioner.LocalToken.getPartitioner() |
IPartitioner |
Murmur3Partitioner.LongToken.getPartitioner() |
IPartitioner |
OrderPreservingPartitioner.StringToken.getPartitioner() |
IPartitioner |
RandomPartitioner.BigIntegerToken.getPartitioner() |
IPartitioner |
RingPosition.getPartitioner() |
abstract IPartitioner |
Token.getPartitioner() |
IPartitioner |
Token.KeyBound.getPartitioner() |
Modifier and Type | Method and Description |
---|---|
AbstractBounds<T> |
AbstractBounds.AbstractBoundsSerializer.deserialize(java.io.DataInput in,
IPartitioner p,
int version) |
T |
IPartitionerDependentSerializer.deserialize(java.io.DataInput in,
IPartitioner p,
int version)
Deserialize into the specified DataInputStream instance.
|
Token |
Token.TokenSerializer.deserialize(java.io.DataInput in,
IPartitioner p,
int version) |
java.util.Set<Range<Token>> |
StreamStateStore.getAvailableRanges(java.lang.String keyspace,
IPartitioner partitioner) |
Constructor and Description |
---|
Splitter(IPartitioner partitioner) |
Modifier and Type | Method and Description |
---|---|
static TokenAllocator<java.net.InetAddress> |
TokenAllocatorFactory.createTokenAllocator(java.util.NavigableMap<Token,java.net.InetAddress> sortedTokens,
org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<java.net.InetAddress> strategy,
IPartitioner partitioner) |
Constructor and Description |
---|
NoReplicationTokenAllocator(java.util.NavigableMap<Token,Unit> sortedTokens,
org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<Unit> strategy,
IPartitioner partitioner) |
TokenAllocatorBase(java.util.NavigableMap<Token,Unit> sortedTokens,
org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<Unit> strategy,
IPartitioner partitioner) |
Modifier and Type | Method and Description |
---|---|
static java.util.Collection<Token> |
TokenSerializer.deserialize(IPartitioner partitioner,
java.io.DataInput in) |
static void |
TokenSerializer.serialize(IPartitioner partitioner,
java.util.Collection<Token> tokens,
java.io.DataOutput out) |
Constructor and Description |
---|
VersionedValueFactory(IPartitioner partitioner) |
Modifier and Type | Method and Description |
---|---|
IPartitioner |
SSTable.getPartitioner() |
Modifier and Type | Method and Description |
---|---|
IndexSummary |
IndexSummaryBuilder.build(IPartitioner partitioner) |
IndexSummary |
IndexSummaryBuilder.build(IPartitioner partitioner,
IndexSummaryBuilder.ReadableBoundary boundary) |
IndexSummary |
IndexSummary.IndexSummarySerializer.deserialize(java.io.DataInputStream in,
IPartitioner partitioner,
boolean haveSamplingLevel,
int expectedMinIndexInterval,
int maxIndexInterval) |
Pair<DecoratedKey,DecoratedKey> |
IndexSummary.IndexSummarySerializer.deserializeFirstLastKey(java.io.DataInputStream in,
IPartitioner partitioner,
boolean haveSamplingLevel)
Deserializes the first and last key stored in the summary
Only for use by offline tools like SSTableMetadataViewer, otherwise SSTable.first/last should be used.
|
static IndexSummary |
IndexSummaryBuilder.downsample(IndexSummary existing,
int newSamplingLevel,
int minIndexInterval,
IPartitioner partitioner)
Downsamples an existing index summary to a new sampling level.
|
CQLSSTableWriter.Builder |
CQLSSTableWriter.Builder.withPartitioner(IPartitioner partitioner)
The partitioner to use.
|
Constructor and Description |
---|
IndexSummary(IPartitioner partitioner,
Memory offsets,
int offsetCount,
Memory entries,
long entriesLength,
int sizeAtFullSampling,
int minIndexInterval,
int samplingLevel) |
Modifier and Type | Field and Description |
---|---|
IPartitioner |
TokenMetadata.partitioner |
Modifier and Type | Method and Description |
---|---|
TokenMetadata |
TokenMetadata.cloneWithNewPartitioner(IPartitioner newPartitioner)
To be used by tests only (via
StorageService.setPartitionerUnsafe(org.apache.cassandra.dht.IPartitioner) ). |
Modifier and Type | Method and Description |
---|---|
static IPartitioner |
MessagingService.globalPartitioner() |
Modifier and Type | Method and Description |
---|---|
static RepairOption |
RepairOption.parse(java.util.Map<java.lang.String,java.lang.String> options,
IPartitioner partitioner)
Construct RepairOptions object from given map of Strings.
|
Modifier and Type | Method and Description |
---|---|
IPartitioner |
StorageService.setPartitionerUnsafe(IPartitioner newPartitioner) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<PartitionPosition> |
StorageService.getDiskBoundaries(java.util.List<Range<Token>> localRanges,
IPartitioner partitioner,
Directories.DataDirectory[] dataDirectories)
Returns a list of disk boundaries, the result will differ depending on whether vnodes are enabled or not.
|
IPartitioner |
StorageService.setPartitionerUnsafe(IPartitioner newPartitioner) |
Modifier and Type | Method and Description |
---|---|
static IPartitioner |
FBUtilities.newPartitioner(Descriptor desc)
Create a new instance of a partitioner defined in an SSTable Descriptor
|
static IPartitioner |
FBUtilities.newPartitioner(java.lang.String partitionerClassName) |
IPartitioner |
MerkleTree.partitioner() |
IPartitioner |
MerkleTrees.partitioner()
Get the partitioner in use.
|
Constructor and Description |
---|
MerkleTree(IPartitioner partitioner,
Range<Token> range,
byte hashdepth,
long maxsize) |
MerkleTrees(IPartitioner partitioner)
Creates empty MerkleTrees object.
|
Copyright © 2018 The Apache Software Foundation