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 IPartitionerDatabaseDescriptor. getPartitioner()static IPartitionerDatabaseDescriptor. setPartitionerUnsafe(IPartitioner newPartitioner)Methods in org.apache.cassandra.config with parameters of type IPartitioner Modifier and Type Method Description static IPartitionerDatabaseDescriptor. 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 IPartitionerColumnFamilyStore. getPartitioner()IPartitionerDecoratedKey. getPartitioner()Methods in org.apache.cassandra.db with parameters of type IPartitioner Modifier and Type Method Description static DataRangeDataRange. allData(IPartitioner partitioner)Creates aDataRangeto query all data (over the whole ring).static DataRangeDataRange. allData(IPartitioner partitioner, ClusteringIndexFilter filter)Creates aDataRangeto query all partitions of the ring using the provided clustering index filter.static intDecoratedKey. compareTo(IPartitioner partitioner, java.nio.ByteBuffer key, PartitionPosition position)PartitionPositionPartitionPosition.RowPositionSerializer. deserialize(java.io.DataInput in, IPartitioner p, int version)static PartitionPositionPartitionPosition.ForKey. get(java.nio.ByteBuffer key, IPartitioner p)static SystemKeyspace.AvailableRangesSystemKeyspace. 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 CassandraStreamHeaderCassandraStreamHeader.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 classByteOrderedPartitionerclassLocalPartitionerclassMurmur3PartitionerThis class generates a BigIntegerToken using a Murmur3 hash.classOrderPreservingPartitionerclassRandomPartitionerThis class generates a BigIntegerToken using MD5 hash.Methods in org.apache.cassandra.dht that return IPartitioner Modifier and Type Method Description IPartitionerByteOrderedPartitioner.BytesToken. getPartitioner()IPartitionerLocalPartitioner.LocalToken. getPartitioner()IPartitionerMurmur3Partitioner.LongToken. getPartitioner()IPartitionerOrderPreservingPartitioner.StringToken. getPartitioner()IPartitionerRandomPartitioner.BigIntegerToken. getPartitioner()IPartitionerRingPosition. getPartitioner()abstract IPartitionerToken. getPartitioner()IPartitionerToken.KeyBound. getPartitioner()static IPartitionerIPartitioner. 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)TIPartitionerDependentSerializer. deserialize(java.io.DataInput in, IPartitioner p, int version)Deserialize into the specified DataInputStream instance.TokenToken.TokenSerializer. deserialize(java.io.DataInput in, IPartitioner p, int version)SystemKeyspace.AvailableRangesStreamStateStore. 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 voidTokenSerializer. 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 IPartitionerConfigHelper. getInputPartitioner(org.apache.hadoop.conf.Configuration conf)static IPartitionerConfigHelper. 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 IPartitionerSSTable. getPartitioner()Methods in org.apache.cassandra.io.sstable with parameters of type IPartitioner Modifier and Type Method Description IndexSummaryIndexSummaryBuilder. build(IPartitioner partitioner)IndexSummaryIndexSummaryBuilder. build(IPartitioner partitioner, IndexSummaryBuilder.ReadableBoundary boundary)IndexSummaryIndexSummary.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 IndexSummaryIndexSummaryBuilder. downsample(IndexSummary existing, int newSamplingLevel, int minIndexInterval, IPartitioner partitioner)Downsamples an existing index summary to a new sampling level.CQLSSTableWriter.BuilderCQLSSTableWriter.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 IPartitionerTokenMetadata. partitionerMethods in org.apache.cassandra.locator with parameters of type IPartitioner Modifier and Type Method Description TokenMetadataTokenMetadata. 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 RepairOptionRepairOption. 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 IPartitionerTableMetadata. partitionerMethods in org.apache.cassandra.schema with parameters of type IPartitioner Modifier and Type Method Description TableMetadata.BuilderTableMetadata.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 IPartitionerStorageService. setPartitionerUnsafe(IPartitioner newPartitioner)Methods in org.apache.cassandra.service with parameters of type IPartitioner Modifier and Type Method Description IPartitionerStorageService. 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 IPartitionerFBUtilities. newPartitioner(java.lang.String partitionerClassName)static IPartitionerFBUtilities. newPartitioner(Descriptor desc)Create a new instance of a partitioner defined in an SSTable DescriptorIPartitionerMerkleTree. partitioner()IPartitionerMerkleTrees. partitioner()Get the partitioner in use.Methods in org.apache.cassandra.utils with parameters of type IPartitioner Modifier and Type Method Description static intMerkleTree. 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.
-