Uses of Class
org.apache.cassandra.utils.Pair
-
-
Uses of Pair in org.apache.cassandra.auth
Methods in org.apache.cassandra.auth that return types with arguments of type Pair Modifier and Type Method Description java.util.function.Supplier<java.util.Map<Pair<AuthenticatedUser,IResource>,java.util.Set<Permission>>>CassandraAuthorizer. bulkLoader()Get an initial set of permissions to load into the PermissionsCache at startup -
Uses of Pair in org.apache.cassandra.cache
Methods in org.apache.cassandra.cache that return types with arguments of type Pair Modifier and Type Method Description Future<Pair<K,V>>AutoSavingCache.CacheSerializer. deserialize(DataInputPlus in, ColumnFamilyStore cfs) -
Uses of Pair in org.apache.cassandra.cql3
Fields in org.apache.cassandra.cql3 with type parameters of type Pair Modifier and Type Field Description java.util.List<Pair<Term.Raw,Term.Raw>>Maps.Literal. entriesMethod parameters in org.apache.cassandra.cql3 with type arguments of type Pair Modifier and Type Method Description static <T> AbstractType<?>Maps. getExactMapTypeIfKnown(java.util.List<Pair<T,T>> entries, java.util.function.Function<T,AbstractType<?>> mapper)Returns the exact MapType from the entries if it can be known.static <T> java.lang.StringMaps. mapToString(java.util.List<Pair<T,T>> entries)Create aStringrepresentation of the list containing the specified elements.static <T> java.lang.StringMaps. mapToString(java.util.List<Pair<T,T>> items, java.util.function.Function<T,java.lang.String> mapper)Create aStringrepresentation of the map from the specified items associated to the map entries.static <T extends AssignmentTestable>
AssignmentTestable.TestResultMaps. testMapAssignment(ColumnSpecification receiver, java.util.List<Pair<T,T>> entries)Tests that the map with the specified entries can be assigned to the specified column.Constructor parameters in org.apache.cassandra.cql3 with type arguments of type Pair Constructor Description Literal(java.util.List<Pair<Term.Raw,Term.Raw>> entries) -
Uses of Pair in org.apache.cassandra.cql3.selection
Constructor parameters in org.apache.cassandra.cql3.selection with type arguments of type Pair Constructor Description Raw(java.util.List<Pair<Selectable.Raw,Selectable.Raw>> raws)WithMapOrUdt(TableMetadata cfm, java.util.List<Pair<Selectable.Raw,Selectable.Raw>> raws) -
Uses of Pair in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return types with arguments of type Pair Modifier and Type Method Description java.util.List<Pair<ColumnIdentifier,ColumnCondition.Raw>>ModificationStatement.Parsed. getConditions()Constructor parameters in org.apache.cassandra.cql3.statements with type arguments of type Pair Constructor Description Parsed(QualifiedName name, StatementType type, Attributes.Raw attrs, java.util.List<Pair<ColumnIdentifier,ColumnCondition.Raw>> conditions, boolean ifNotExists, boolean ifExists)ParsedUpdate(QualifiedName name, Attributes.Raw attrs, java.util.List<Pair<ColumnIdentifier,Operation.RawUpdate>> updates, WhereClause whereClause, java.util.List<Pair<ColumnIdentifier,ColumnCondition.Raw>> conditions, boolean ifExists)Creates a new UpdateStatement from a column family name, columns map, consistency level, and key term. -
Uses of Pair in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return types with arguments of type Pair Modifier and Type Method Description static java.util.Map<Range<Token>,Pair<Token,java.lang.Long>>SystemKeyspace. getViewBuildStatus(java.lang.String ksname, java.lang.String viewName)Method parameters in org.apache.cassandra.db with type arguments of type Pair Modifier and Type Method Description static voidSystemKeyspace. updateSizeEstimates(java.lang.String keyspace, java.lang.String table, java.util.Map<Range<Token>,Pair<java.lang.Long,java.lang.Long>> estimates)Writes the current partition count and size estimates into SIZE_ESTIMATES_CFstatic voidSystemKeyspace. updateTableEstimates(java.lang.String keyspace, java.lang.String table, java.lang.String type, java.util.Map<Range<Token>,Pair<java.lang.Long,java.lang.Long>> estimates)Writes the current partition count and size estimates into table_estimates -
Uses of Pair in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction that return Pair Modifier and Type Method Description static Pair<java.lang.Long,java.lang.Long>TimeWindowCompactionStrategy. getWindowBoundsInMillis(java.util.concurrent.TimeUnit windowTimeUnit, int windowTimeSize, long timestampInMillis)Find the lowest and highest timestamps in a given timestamp/unit pair Returns milliseconds, caller should adjust accordinglyMethods in org.apache.cassandra.db.compaction that return types with arguments of type Pair Modifier and Type Method Description static java.util.List<Pair<SSTableReader,java.lang.Long>>SizeTieredCompactionStrategy. createSSTableAndLengthPairs(java.lang.Iterable<SSTableReader> sstables)static java.util.List<Pair<SSTableReader,java.lang.Long>>DateTieredCompactionStrategy. createSSTableAndMinTimestampPairs(java.lang.Iterable<SSTableReader> sstables)Deprecated.Method parameters in org.apache.cassandra.db.compaction with type arguments of type Pair Modifier and Type Method Description static <T> java.util.List<java.util.List<T>>SizeTieredCompactionStrategy. getBuckets(java.util.Collection<Pair<T,java.lang.Long>> files, double bucketHigh, double bucketLow, long minSSTableSize) -
Uses of Pair in org.apache.cassandra.db.marshal
Methods in org.apache.cassandra.db.marshal that return Pair Modifier and Type Method Description Pair<Pair<java.lang.String,java.nio.ByteBuffer>,java.util.List<Pair<java.nio.ByteBuffer,AbstractType>>>TypeParser. getUserTypeParameters()Methods in org.apache.cassandra.db.marshal that return types with arguments of type Pair Modifier and Type Method Description Pair<Pair<java.lang.String,java.nio.ByteBuffer>,java.util.List<Pair<java.nio.ByteBuffer,AbstractType>>>TypeParser. getUserTypeParameters()Pair<Pair<java.lang.String,java.nio.ByteBuffer>,java.util.List<Pair<java.nio.ByteBuffer,AbstractType>>>TypeParser. getUserTypeParameters() -
Uses of Pair in org.apache.cassandra.dht
Methods in org.apache.cassandra.dht that return Pair Modifier and Type Method Description abstract Pair<AbstractBounds<T>,AbstractBounds<T>>AbstractBounds. split(T position)Given token T and AbstractBounds ?L,R?, returns Pair(?L,T], (T,R?), where ? means that the same type of AbstractBounds is returned as the original.Pair<AbstractBounds<T>,AbstractBounds<T>>Bounds. split(T position)Pair<AbstractBounds<T>,AbstractBounds<T>>ExcludingBounds. split(T position)Pair<AbstractBounds<T>,AbstractBounds<T>>IncludingExcludingBounds. split(T position)Pair<AbstractBounds<T>,AbstractBounds<T>>Range. split(T position) -
Uses of Pair in org.apache.cassandra.gms
Methods in org.apache.cassandra.gms that return Pair Modifier and Type Method Description Pair<java.lang.Boolean,CassandraVersion>Gossiper. isUpgradingFromVersionLowerThanC17653(CassandraVersion referenceVersion)Method parameters in org.apache.cassandra.gms with type arguments of type Pair Modifier and Type Method Description voidGossiper. addLocalApplicationStates(java.util.List<Pair<ApplicationState,VersionedValue>> states) -
Uses of Pair in org.apache.cassandra.hadoop
Methods in org.apache.cassandra.hadoop that return Pair Modifier and Type Method Description static Pair<java.lang.String,java.lang.String>ConfigHelper. getInputKeyRange(org.apache.hadoop.conf.Configuration conf)The start and end token of the input key range as a pair. -
Uses of Pair in org.apache.cassandra.index
Methods in org.apache.cassandra.index that return Pair Modifier and Type Method Description static Pair<ColumnMetadata,IndexTarget.Type>TargetParser. parse(TableMetadata metadata, java.lang.String target)static Pair<ColumnMetadata,IndexTarget.Type>TargetParser. parse(TableMetadata metadata, IndexMetadata indexDef) -
Uses of Pair in org.apache.cassandra.index.sasi.disk
Methods in org.apache.cassandra.index.sasi.disk that return Pair Modifier and Type Method Description protected Pair<java.lang.Long,AbstractTokenTreeBuilder.InteriorNode>AbstractTokenTreeBuilder.InteriorNode. splitBlock()Methods in org.apache.cassandra.index.sasi.disk that return types with arguments of type Pair Modifier and Type Method Description java.util.Iterator<Pair<java.lang.Long,com.carrotsearch.hppc.LongSet>>DynamicTokenTreeBuilder. iterator()java.util.Iterator<Pair<java.lang.Long,com.carrotsearch.hppc.LongSet>>StaticTokenTreeBuilder. iterator()Methods in org.apache.cassandra.index.sasi.disk with parameters of type Pair Modifier and Type Method Description protected voidOnDiskIndexBuilder. finish(Descriptor descriptor, Pair<java.nio.ByteBuffer,java.nio.ByteBuffer> range, File file, TermIterator terms)voidOnDiskIndexBuilder. finish(Pair<java.nio.ByteBuffer,java.nio.ByteBuffer> range, File file, TermIterator terms)Method parameters in org.apache.cassandra.index.sasi.disk with type arguments of type Pair Modifier and Type Method Description voidDynamicTokenTreeBuilder. add(java.util.Iterator<Pair<java.lang.Long,com.carrotsearch.hppc.LongSet>> data)voidStaticTokenTreeBuilder. add(java.util.Iterator<Pair<java.lang.Long,com.carrotsearch.hppc.LongSet>> data)voidTokenTreeBuilder. add(java.util.Iterator<Pair<java.lang.Long,com.carrotsearch.hppc.LongSet>> data) -
Uses of Pair in org.apache.cassandra.index.sasi.utils
Methods in org.apache.cassandra.index.sasi.utils that return Pair Modifier and Type Method Description protected Pair<IndexedTerm,TokenTreeBuilder>CombinedTermIterator. computeNext() -
Uses of Pair in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that return Pair Modifier and Type Method Description 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 Pair<Descriptor,Component>Descriptor. fromFilenameWithComponent(File file)Parse a sstable filename, extracting both theDescriptorandComponentpart.static Pair<Descriptor,Component>SSTable. tryComponentFromFilename(File file)Parse a sstable filename into both aDescriptorandComponentobject. -
Uses of Pair in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator that return Pair Modifier and Type Method Description Pair<java.lang.String,java.lang.String>TokenMetadata.Topology. getLocation(InetAddressAndPort addr)Methods in org.apache.cassandra.locator that return types with arguments of type Pair Modifier and Type Method Description java.util.Set<Pair<Token,InetAddressAndPort>>TokenMetadata. getMovingEndpoints()Endpoints which are migrating to the new tokens -
Uses of Pair in org.apache.cassandra.repair
Methods in org.apache.cassandra.repair with parameters of type Pair Modifier and Type Method Description voidRepairSession. trackSyncCompletion(Pair<RepairJobDesc,SyncNodePair> key, CompletableRemoteSyncTask task)voidRepairSession. trackValidationCompletion(Pair<RepairJobDesc,InetAddressAndPort> key, ValidationTask task) -
Uses of Pair in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return Pair Modifier and Type Method Description static Pair<RangesAtEndpoint,RangesAtEndpoint>RangeRelocator. calculateStreamAndFetchRanges(RangesAtEndpoint currentRanges, RangesAtEndpoint updatedRanges)Calculate pair of ranges to stream/fetch for given two range collections (current ranges for keyspace and ranges after move to new token) With transient replication the added wrinkle is that if a range transitions from full to transient then we need to stream the range despite the fact that we are retaining it as transient.Pair<ActiveRepairService.ParentRepairStatus,java.util.List<java.lang.String>>ActiveRepairService. getRepairStatus(java.lang.Integer cmd)Pair<java.lang.Integer,Future<?>>StorageService. repair(java.lang.String keyspace, java.util.Map<java.lang.String,java.lang.String> repairSpec, java.util.List<ProgressListener> listeners)Pair<java.lang.Integer,Future<?>>StorageService. repair(java.lang.String keyspace, RepairOption option, java.util.List<ProgressListener> listeners)Methods in org.apache.cassandra.service that return types with arguments of type Pair Modifier and Type Method Description Future<Pair<CounterCacheKey,ClockAndCount>>CacheService.CounterCacheSerializer. deserialize(DataInputPlus in, ColumnFamilyStore cfs)Future<Pair<KeyCacheKey,RowIndexEntry>>CacheService.KeyCacheSerializer. deserialize(DataInputPlus input, ColumnFamilyStore cfs)Future<Pair<RowCacheKey,IRowCacheEntry>>CacheService.RowCacheSerializer. deserialize(DataInputPlus in, ColumnFamilyStore cfs)java.util.Set<Pair<java.lang.String,java.lang.String>>DataResurrectionCheck. getExcludedTables(java.util.Map<java.lang.String,java.lang.Object> config)java.util.List<Pair<java.lang.String,java.lang.String>>StorageService. getPreparedStatements()java.util.List<Pair<Range<Token>,java.lang.Long>>StorageService. getSplits(java.lang.String keyspaceName, java.lang.String cfName, Range<Token> range, int keysPerSplit) -
Uses of Pair in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport that return Pair Modifier and Type Method Description Pair<DataType,java.lang.Object>DataType.Codec. decodeOne(io.netty.buffer.ByteBuf body, ProtocolVersion version)static Pair<DataType,java.lang.Object>DataType. fromType(AbstractType type, ProtocolVersion version)static Pair<java.util.List<java.lang.String>,java.util.List<java.nio.ByteBuffer>>CBUtil. readNameAndValueList(io.netty.buffer.ByteBuf cb, ProtocolVersion protocolVersion)Methods in org.apache.cassandra.transport with parameters of type Pair Modifier and Type Method Description intDataType.Codec. oneSerializedSize(Pair<DataType,java.lang.Object> option, ProtocolVersion version)static AbstractTypeDataType. toType(Pair<DataType,java.lang.Object> entry)voidDataType.Codec. writeOne(Pair<DataType,java.lang.Object> option, io.netty.buffer.ByteBuf dest, ProtocolVersion version) -
Uses of Pair in org.apache.cassandra.utils
Methods in org.apache.cassandra.utils that return Pair Modifier and Type Method Description static <X,Y>
Pair<X,Y>Pair. create(X x, Y y)static Pair<java.math.BigInteger,java.lang.Boolean>FBUtilities. midpoint(java.math.BigInteger left, java.math.BigInteger right, int sigbits)Given two bit arrays represented as BigIntegers, containing the given number of significant bits, calculate a midpoint.
-