Uses of Interface
org.apache.cassandra.dht.IPartitioner
Packages that use IPartitioner
Package
Description
File transfer
-
Uses of IPartitioner in org.apache.cassandra.config
Methods in org.apache.cassandra.config that return IPartitionerModifier and TypeMethodDescriptionstatic IPartitionerDatabaseDescriptor.getPartitioner()static IPartitionerDatabaseDescriptor.setPartitionerUnsafe(IPartitioner newPartitioner) Methods in org.apache.cassandra.config with parameters of type IPartitionerModifier and TypeMethodDescriptionstatic IPartitionerDatabaseDescriptor.setPartitionerUnsafe(IPartitioner newPartitioner) -
Uses of IPartitioner in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return IPartitionerModifier and TypeMethodDescriptionColumnFamilyStore.getPartitioner()DecoratedKey.getPartitioner()Methods in org.apache.cassandra.db with parameters of type IPartitionerModifier and TypeMethodDescriptionstatic 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, ByteBuffer key, PartitionPosition position) PartitionPosition.RowPositionSerializer.deserialize(DataInput in, IPartitioner p, int version) static BufferDecoratedKeyBufferDecoratedKey.fromByteComparable(ByteComparable byteComparable, ByteComparable.Version version, IPartitioner partitioner) A factory method that translates the given byte-comparable representation to aBufferDecoratedKeyinstance.ColumnFamilyStore.fullWeightedRange(long ringVersion, IPartitioner partitioner) static PartitionPositionPartitionPosition.ForKey.get(ByteBuffer key, IPartitioner p) SystemKeyspace.getAvailableRanges(String keyspace, IPartitioner partitioner) List of the streamed ranges, where transientness is encoded based on the source, where range was streamed from.static Map<InetAddressAndPort,Set<Range<Token>>> SystemKeyspace.getTransferredRanges(String description, String keyspace, IPartitioner partitioner) static byte[]DecoratedKey.keyFromByteSource(ByteSource.Peekable peekableByteSource, ByteComparable.Version version, IPartitioner partitioner) SystemKeyspace.rawRangesToRangeSet(Set<ByteBuffer> rawRanges, IPartitioner partitioner) -
Uses of IPartitioner in org.apache.cassandra.db.compaction
Constructors in org.apache.cassandra.db.compaction with parameters of type IPartitioner -
Uses of IPartitioner in org.apache.cassandra.db.marshal
Constructors in org.apache.cassandra.db.marshal with parameters of type IPartitionerModifierConstructorDescriptionPartitionerDefinedOrder(IPartitioner partitioner) PartitionerDefinedOrder(IPartitioner partitioner, AbstractType<?> partitionKeyType) -
Uses of IPartitioner in org.apache.cassandra.db.streaming
Method parameters in org.apache.cassandra.db.streaming with type arguments of type IPartitionerModifier and TypeMethodDescriptionCassandraStreamHeader.CassandraStreamHeaderSerializer.deserialize(DataInputPlus in, int version, Function<TableId, IPartitioner> partitionerMapper) -
Uses of IPartitioner in org.apache.cassandra.dht
Classes in org.apache.cassandra.dht that implement IPartitionerModifier and TypeClassDescriptionclassclassclassThis class generates a BigIntegerToken using a Murmur3 hash.classclassThis class generates a BigIntegerToken using MD5 hash.Methods in org.apache.cassandra.dht that return IPartitionerModifier and TypeMethodDescriptionByteOrderedPartitioner.BytesToken.getPartitioner()LocalPartitioner.LocalToken.getPartitioner()Murmur3Partitioner.LongToken.getPartitioner()OrderPreservingPartitioner.StringToken.getPartitioner()RandomPartitioner.BigIntegerToken.getPartitioner()RingPosition.getPartitioner()abstract IPartitionerToken.getPartitioner()Token.KeyBound.getPartitioner()static IPartitionerIPartitioner.global()Methods in org.apache.cassandra.dht with parameters of type IPartitionerModifier and TypeMethodDescriptionAbstractBounds.AbstractBoundsSerializer.deserialize(DataInput in, IPartitioner p, int version) IPartitionerDependentSerializer.deserialize(DataInput in, IPartitioner p, int version) Deserialize into the specified DataInputStream instance.Token.TokenSerializer.deserialize(DataInput in, IPartitioner p, int version) StreamStateStore.getAvailableRanges(String keyspace, IPartitioner partitioner) Constructors in org.apache.cassandra.dht with parameters of type IPartitioner -
Uses of IPartitioner in org.apache.cassandra.dht.tokenallocator
Methods in org.apache.cassandra.dht.tokenallocator with parameters of type IPartitionerModifier and TypeMethodDescriptionstatic List<OfflineTokenAllocator.FakeNode>OfflineTokenAllocator.allocate(int rf, int numTokens, int[] nodesPerRack, OutputHandler logger, IPartitioner partitioner) static TokenAllocator<InetAddressAndPort>TokenAllocatorFactory.createTokenAllocator(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 IPartitionerModifierConstructorDescriptionNoReplicationTokenAllocator(NavigableMap<Token, Unit> sortedTokens, org.apache.cassandra.dht.tokenallocator.ReplicationStrategy<Unit> strategy, IPartitioner partitioner) protectedTokenAllocatorBase(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 IPartitionerModifier and TypeMethodDescriptionstatic Collection<Token>TokenSerializer.deserialize(IPartitioner partitioner, DataInput in) static voidTokenSerializer.serialize(IPartitioner partitioner, Collection<Token> tokens, DataOutput out) Constructors in org.apache.cassandra.gms with parameters of type IPartitioner -
Uses of IPartitioner in org.apache.cassandra.index.sai.disk.format
Methods in org.apache.cassandra.index.sai.disk.format with parameters of type IPartitionerModifier and TypeMethodDescriptionstatic IndexDescriptorIndexDescriptor.create(Descriptor descriptor, IPartitioner partitioner, ClusteringComparator clusteringComparator) -
Uses of IPartitioner in org.apache.cassandra.index.sai.utils
Constructors in org.apache.cassandra.index.sai.utils with parameters of type IPartitionerModifierConstructorDescriptionFactory(IPartitioner partitioner, ClusteringComparator clusteringComparator) -
Uses of IPartitioner in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that return IPartitionerMethods in org.apache.cassandra.io.sstable with parameters of type IPartitionerModifier and TypeMethodDescriptionCQLSSTableWriter.Builder.withPartitioner(IPartitioner partitioner) The partitioner to use.Constructors in org.apache.cassandra.io.sstable with parameters of type IPartitionerModifierConstructorDescriptionKeyIterator(KeyReader it, IPartitioner partitioner, long totalBytes, ReadWriteLock fileAccessLock) -
Uses of IPartitioner in org.apache.cassandra.io.sstable.format
Methods in org.apache.cassandra.io.sstable.format with parameters of type IPartitionerModifier and TypeMethodDescriptionSSTableFormat.SSTableReaderFactory.readKeyRange(Descriptor descriptor, IPartitioner partitioner) Retrieves a key range for the given sstable at the lowest cost - that is, without opening all sstables files if possible. -
Uses of IPartitioner in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big with parameters of type IPartitionerModifier and TypeMethodDescriptionstatic Pair<DecoratedKey,DecoratedKey> IndexSummaryComponent.loadFirstAndLastKey(File summaryFile, IPartitioner partitioner) -
Uses of IPartitioner in org.apache.cassandra.io.sstable.format.bti
Methods in org.apache.cassandra.io.sstable.format.bti with parameters of type IPartitionerModifier and TypeMethodDescriptionstatic PartitionIndexPartitionIndex.load(FileHandle.Builder fhBuilder, IPartitioner partitioner, boolean preload) static PartitionIndexPartitionIndex.load(FileHandle fh, IPartitioner partitioner, boolean preload) static Pair<DecoratedKey,DecoratedKey> PartitionIndex.readFirstAndLastKey(File file, IPartitioner partitioner) -
Uses of IPartitioner in org.apache.cassandra.io.sstable.indexsummary
Methods in org.apache.cassandra.io.sstable.indexsummary with parameters of type IPartitionerModifier and TypeMethodDescriptionIndexSummaryBuilder.build(IPartitioner partitioner) IndexSummaryBuilder.build(IPartitioner partitioner, IndexSummaryBuilder.ReadableBoundary boundary) <T extends InputStream & DataInputPlus>
IndexSummaryIndexSummary.IndexSummarySerializer.deserialize(T in, IPartitioner partitioner, int expectedMinIndexInterval, int maxIndexInterval) IndexSummary.IndexSummarySerializer.deserializeFirstLastKey(DataInputPlus.DataInputStreamPlus in, IPartitioner partitioner) Deserializes the first and last key stored in the summarystatic IndexSummaryIndexSummaryBuilder.downsample(IndexSummary existing, int newSamplingLevel, int minIndexInterval, IPartitioner partitioner) Downsamples an existing index summary to a new sampling level.Constructors in org.apache.cassandra.io.sstable.indexsummary with parameters of type IPartitionerModifierConstructorDescriptionIndexSummary(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 IPartitionerMethods in org.apache.cassandra.locator with parameters of type IPartitionerModifier and TypeMethodDescriptionTokenMetadata.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 IPartitionerModifier and TypeMethodDescriptionstatic RepairOptionRepairOption.parse(Map<String, String> options, IPartitioner partitioner) Construct RepairOptions object from given map of Strings.RepairOption.parseRanges(String rangesStr, IPartitioner partitioner) -
Uses of IPartitioner in org.apache.cassandra.schema
Fields in org.apache.cassandra.schema declared as IPartitionerMethods in org.apache.cassandra.schema with parameters of type IPartitioner -
Uses of IPartitioner in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return IPartitionerModifier and TypeMethodDescriptionStorageService.setPartitionerUnsafe(IPartitioner newPartitioner) Methods in org.apache.cassandra.service with parameters of type IPartitionerModifier and TypeMethodDescriptionStorageService.setPartitionerUnsafe(IPartitioner newPartitioner) -
Uses of IPartitioner in org.apache.cassandra.utils
Methods in org.apache.cassandra.utils that return IPartitionerModifier and TypeMethodDescriptionstatic IPartitionerFBUtilities.newPartitioner(String partitionerClassName) static IPartitionerFBUtilities.newPartitioner(Descriptor desc) Create a new instance of a partitioner defined in an SSTable DescriptorMerkleTree.partitioner()MerkleTrees.partitioner()Get the partitioner in use.Methods in org.apache.cassandra.utils with parameters of type IPartitionerModifier and TypeMethodDescriptionstatic 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 IPartitionerModifierConstructorDescriptionMerkleTree(IPartitioner partitioner, Range<Token> range, int hashdepth, long maxsize) MerkleTrees(IPartitioner partitioner) Creates empty MerkleTrees object.