Uses of Class
org.apache.cassandra.utils.Pair
-
-
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 java.util.concurrent.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. entries
Method 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.String
Maps. mapToString(java.util.List<Pair<T,T>> entries)
Create aString
representation of the list containing the specified elements.static <T> java.lang.String
Maps. mapToString(java.util.List<Pair<T,T>> items, java.util.function.Function<T,java.lang.String> mapper)
Create aString
representation 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 void
SystemKeyspace. 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 void
SystemKeyspace. 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
Method parameters in org.apache.cassandra.gms with type arguments of type Pair Modifier and Type Method Description void
Gossiper. 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 void
OnDiskIndexBuilder. finish(Descriptor descriptor, Pair<java.nio.ByteBuffer,java.nio.ByteBuffer> range, java.io.File file, TermIterator terms)
void
OnDiskIndexBuilder. finish(Pair<java.nio.ByteBuffer,java.nio.ByteBuffer> range, java.io.File file, TermIterator terms)
Method parameters in org.apache.cassandra.index.sasi.disk with type arguments of type Pair Modifier and Type Method Description void
DynamicTokenTreeBuilder. add(java.util.Iterator<Pair<java.lang.Long,com.carrotsearch.hppc.LongSet>> data)
void
StaticTokenTreeBuilder. add(java.util.Iterator<Pair<java.lang.Long,com.carrotsearch.hppc.LongSet>> data)
void
TokenTreeBuilder. 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(java.io.File file)
Parse a sstable filename, extracting both theDescriptor
andComponent
part.static Pair<Descriptor,Component>
SSTable. tryComponentFromFilename(java.io.File file)
Parse a sstable filename into both aDescriptor
andComponent
object. -
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 void
RepairSession. trackSyncCompletion(Pair<RepairJobDesc,SyncNodePair> key, CompletableRemoteSyncTask task)
void
RepairSession. 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<java.lang.Integer,java.util.concurrent.Future<?>>
StorageService. repair(java.lang.String keyspace, java.util.Map<java.lang.String,java.lang.String> repairSpec, java.util.List<ProgressListener> listeners)
Methods in org.apache.cassandra.service that return types with arguments of type Pair Modifier and Type Method Description java.util.concurrent.Future<Pair<CounterCacheKey,ClockAndCount>>
CacheService.CounterCacheSerializer. deserialize(DataInputPlus in, ColumnFamilyStore cfs)
java.util.concurrent.Future<Pair<KeyCacheKey,RowIndexEntry>>
CacheService.KeyCacheSerializer. deserialize(DataInputPlus input, ColumnFamilyStore cfs)
java.util.concurrent.Future<Pair<RowCacheKey,IRowCacheEntry>>
CacheService.RowCacheSerializer. deserialize(DataInputPlus in, ColumnFamilyStore cfs)
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 int
DataType.Codec. oneSerializedSize(Pair<DataType,java.lang.Object> option, ProtocolVersion version)
static AbstractType
DataType. toType(Pair<DataType,java.lang.Object> entry)
void
DataType.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.
-