Modifier and Type | Method and Description |
---|---|
static IPartitioner |
DatabaseDescriptor.getPartitioner() |
static IPartitioner |
DatabaseDescriptor.setPartitionerUnsafe(IPartitioner newPartitioner) |
Modifier and Type | Method and Description |
---|---|
static IPartitioner |
DatabaseDescriptor.setPartitionerUnsafe(IPartitioner newPartitioner) |
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 SystemKeyspace.AvailableRanges |
SystemKeyspace.getAvailableRanges(java.lang.String keyspace,
IPartitioner partitioner)
List of the streamed ranges, where transientness is encoded based on the source, where range was streamed from.
|
static java.util.Map<InetAddressAndPort,java.util.Set<Range<Token>>> |
SystemKeyspace.getTransferredRanges(java.lang.String description,
java.lang.String keyspace,
IPartitioner partitioner) |
static java.util.Set<Range<Token>> |
SystemKeyspace.rawRangesToRangeSet(java.util.Set<java.nio.ByteBuffer> rawRanges,
IPartitioner partitioner) |
Constructor and Description |
---|
PartitionerDefinedOrder(IPartitioner partitioner) |
Modifier and Type | Method and Description |
---|---|
CassandraStreamHeader |
CassandraStreamHeader.CassandraStreamHeaderSerializer.deserialize(DataInputPlus in,
int version,
java.util.function.Function<TableId,IPartitioner> partitionerMapper) |
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() |
static IPartitioner |
IPartitioner.global() |
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) |
SystemKeyspace.AvailableRanges |
StreamStateStore.getAvailableRanges(java.lang.String keyspace,
IPartitioner partitioner) |
Constructor and Description |
---|
Splitter(IPartitioner partitioner) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<OfflineTokenAllocator.FakeNode> |
OfflineTokenAllocator.allocate(int rf,
int numTokens,
int[] nodesPerRack,
OutputHandler logger,
IPartitioner partitioner) |
static TokenAllocator<InetAddressAndPort> |
TokenAllocatorFactory.createTokenAllocator(java.util.NavigableMap<Token,InetAddressAndPort> sortedTokens,
org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<InetAddressAndPort> 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 |
---|---|
static IPartitioner |
ConfigHelper.getInputPartitioner(org.apache.hadoop.conf.Configuration conf) |
static IPartitioner |
ConfigHelper.getOutputPartitioner(org.apache.hadoop.conf.Configuration conf) |
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,
int expectedMinIndexInterval,
int maxIndexInterval) |
Pair<DecoratedKey,DecoratedKey> |
IndexSummary.IndexSummarySerializer.deserializeFirstLastKey(java.io.DataInputStream in,
IPartitioner partitioner)
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 RepairOption |
RepairOption.parse(java.util.Map<java.lang.String,java.lang.String> options,
IPartitioner partitioner)
Construct RepairOptions object from given map of Strings.
|
static java.util.Set<Range<Token>> |
RepairOption.parseRanges(java.lang.String rangesStr,
IPartitioner partitioner) |
Modifier and Type | Field and Description |
---|---|
IPartitioner |
TableMetadata.partitioner |
Modifier and Type | Method and Description |
---|---|
TableMetadata.Builder |
TableMetadata.Builder.partitioner(IPartitioner val) |
Modifier and Type | Method and Description |
---|---|
IPartitioner |
StorageService.setPartitionerUnsafe(IPartitioner newPartitioner) |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
static int |
MerkleTree.estimatedMaxDepthForBytes(IPartitioner partitioner,
long numBytes,
int bytesPerHash)
Estimate the allowable depth while keeping the resulting heap usage of this tree under the provided
number of bytes.
|
Constructor and Description |
---|
MerkleTree(IPartitioner partitioner,
Range<Token> range,
int hashdepth,
long maxsize) |
MerkleTrees(IPartitioner partitioner)
Creates empty MerkleTrees object.
|
Copyright © 2009-2022 The Apache Software Foundation