Uses of Interface
org.apache.cassandra.dht.IPartitioner
-
-
Uses of IPartitioner in org.apache.cassandra.config
Methods in org.apache.cassandra.config that return IPartitioner Modifier and Type Method Description static IPartitioner
DatabaseDescriptor. getPartitioner()
static IPartitioner
DatabaseDescriptor. setPartitionerUnsafe(IPartitioner newPartitioner)
Methods in org.apache.cassandra.config with parameters of type IPartitioner Modifier and Type Method Description static IPartitioner
DatabaseDescriptor. setPartitionerUnsafe(IPartitioner newPartitioner)
-
Uses of IPartitioner in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return IPartitioner Modifier and Type Method Description IPartitioner
ColumnFamilyStore. getPartitioner()
IPartitioner
DecoratedKey. getPartitioner()
Methods in org.apache.cassandra.db with parameters of type IPartitioner Modifier and Type Method Description static DataRange
DataRange. allData(IPartitioner partitioner)
Creates aDataRange
to query all data (over the whole ring).static DataRange
DataRange. allData(IPartitioner partitioner, ClusteringIndexFilter filter)
Creates aDataRange
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)
-
Uses of IPartitioner in org.apache.cassandra.db.marshal
Constructors in org.apache.cassandra.db.marshal with parameters of type IPartitioner Constructor Description PartitionerDefinedOrder(IPartitioner partitioner)
-
Uses of IPartitioner in org.apache.cassandra.db.streaming
Method parameters in org.apache.cassandra.db.streaming with type arguments of type IPartitioner Modifier and Type Method Description CassandraStreamHeader
CassandraStreamHeader.CassandraStreamHeaderSerializer. deserialize(DataInputPlus in, int version, java.util.function.Function<TableId,IPartitioner> partitionerMapper)
-
Uses of IPartitioner in org.apache.cassandra.dht
Classes in org.apache.cassandra.dht that implement IPartitioner Modifier and Type Class 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.Methods in org.apache.cassandra.dht that return IPartitioner Modifier and Type Method 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()
Methods in org.apache.cassandra.dht with parameters of type IPartitioner Modifier and Type Method 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)
Constructors in org.apache.cassandra.dht with parameters of type IPartitioner Constructor Description Splitter(IPartitioner partitioner)
-
Uses of IPartitioner in org.apache.cassandra.dht.tokenallocator
Methods in org.apache.cassandra.dht.tokenallocator with parameters of type IPartitioner Modifier and Type Method 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)
Constructors in org.apache.cassandra.dht.tokenallocator with parameters of type IPartitioner Constructor 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)
-
Uses of IPartitioner in org.apache.cassandra.gms
Methods in org.apache.cassandra.gms with parameters of type IPartitioner Modifier and Type Method 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)
Constructors in org.apache.cassandra.gms with parameters of type IPartitioner Constructor Description VersionedValueFactory(IPartitioner partitioner)
-
Uses of IPartitioner in org.apache.cassandra.hadoop
Methods in org.apache.cassandra.hadoop that return IPartitioner Modifier and Type Method Description static IPartitioner
ConfigHelper. getInputPartitioner(org.apache.hadoop.conf.Configuration conf)
static IPartitioner
ConfigHelper. getOutputPartitioner(org.apache.hadoop.conf.Configuration conf)
-
Uses of IPartitioner in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that return IPartitioner Modifier and Type Method Description IPartitioner
SSTable. getPartitioner()
Methods in org.apache.cassandra.io.sstable with parameters of type IPartitioner Modifier and Type Method 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.Constructors in org.apache.cassandra.io.sstable with parameters of type IPartitioner Constructor Description IndexSummary(IPartitioner partitioner, Memory offsets, int offsetCount, Memory entries, long entriesLength, int sizeAtFullSampling, int minIndexInterval, int samplingLevel)
-
Uses of IPartitioner in org.apache.cassandra.locator
Fields in org.apache.cassandra.locator declared as IPartitioner Modifier and Type Field Description IPartitioner
TokenMetadata. partitioner
Methods in org.apache.cassandra.locator with parameters of type IPartitioner Modifier and Type Method Description TokenMetadata
TokenMetadata. cloneWithNewPartitioner(IPartitioner newPartitioner)
To be used by tests only (viaStorageService.setPartitionerUnsafe(org.apache.cassandra.dht.IPartitioner)
). -
Uses of IPartitioner in org.apache.cassandra.repair.messages
Methods in org.apache.cassandra.repair.messages with parameters of type IPartitioner Modifier and Type Method 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)
-
Uses of IPartitioner in org.apache.cassandra.schema
Fields in org.apache.cassandra.schema declared as IPartitioner Modifier and Type Field Description IPartitioner
TableMetadata. partitioner
Methods in org.apache.cassandra.schema with parameters of type IPartitioner Modifier and Type Method Description TableMetadata.Builder
TableMetadata.Builder. partitioner(IPartitioner val)
-
Uses of IPartitioner in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return IPartitioner Modifier and Type Method Description IPartitioner
StorageService. setPartitionerUnsafe(IPartitioner newPartitioner)
Methods in org.apache.cassandra.service with parameters of type IPartitioner Modifier and Type Method Description IPartitioner
StorageService. setPartitionerUnsafe(IPartitioner newPartitioner)
-
Uses of IPartitioner in org.apache.cassandra.utils
Methods in org.apache.cassandra.utils that return IPartitioner Modifier and Type Method Description static IPartitioner
FBUtilities. newPartitioner(java.lang.String partitionerClassName)
static IPartitioner
FBUtilities. newPartitioner(Descriptor desc)
Create a new instance of a partitioner defined in an SSTable DescriptorIPartitioner
MerkleTree. partitioner()
IPartitioner
MerkleTrees. partitioner()
Get the partitioner in use.Methods in org.apache.cassandra.utils with parameters of type IPartitioner Modifier and Type Method 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.Constructors in org.apache.cassandra.utils with parameters of type IPartitioner Constructor Description MerkleTree(IPartitioner partitioner, Range<Token> range, int hashdepth, long maxsize)
MerkleTrees(IPartitioner partitioner)
Creates empty MerkleTrees object.
-