Modifier and Type | Field and Description |
---|---|
static com.google.common.cache.LoadingCache<Pair<AuthenticatedUser,IResource>,java.util.Set<Permission>> |
Auth.permissionsCache |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<Pair<K,V>> |
AutoSavingCache.CacheSerializer.deserialize(java.io.DataInputStream in,
ColumnFamilyStore cfs) |
Modifier and Type | Method and Description |
---|---|
Pair<java.lang.String,java.lang.String> |
Schema.getCF(java.util.UUID cfId) |
Modifier and Type | Field and Description |
---|---|
java.util.List<Pair<Term.Raw,Term.Raw>> |
Maps.Literal.entries |
Constructor and Description |
---|
Maps.Literal(java.util.List<Pair<Term.Raw,Term.Raw>> entries) |
Modifier and Type | Field and Description |
---|---|
protected java.util.List<Pair<ColumnIdentifier,ColumnCondition.Raw>> |
ModificationStatement.Parsed.conditions |
Constructor and Description |
---|
DeleteStatement.Parsed(CFName name,
Attributes.Raw attrs,
java.util.List<Operation.RawDeletion> deletions,
java.util.List<Relation> whereClause,
java.util.List<Pair<ColumnIdentifier,ColumnCondition.Raw>> conditions,
boolean ifExists) |
ModificationStatement.Parsed(CFName name,
Attributes.Raw attrs,
java.util.List<Pair<ColumnIdentifier,ColumnCondition.Raw>> conditions,
boolean ifNotExists,
boolean ifExists) |
UpdateStatement.ParsedUpdate(CFName name,
Attributes.Raw attrs,
java.util.List<Pair<ColumnIdentifier,Operation.RawUpdate>> updates,
java.util.List<Relation> whereClause,
java.util.List<Pair<ColumnIdentifier,ColumnCondition.Raw>> conditions)
Creates a new UpdateStatement from a column family name, columns map, consistency
level, and key term.
|
UpdateStatement.ParsedUpdate(CFName name,
Attributes.Raw attrs,
java.util.List<Pair<ColumnIdentifier,Operation.RawUpdate>> updates,
java.util.List<Relation> whereClause,
java.util.List<Pair<ColumnIdentifier,ColumnCondition.Raw>> conditions)
Creates a new UpdateStatement from a column family name, columns map, consistency
level, and key term.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,Pair<java.lang.Long,java.lang.Long>> |
ColumnFamilyStore.getSnapshotDetails() |
java.util.Map<java.lang.String,Pair<java.lang.Long,java.lang.Long>> |
Directories.getSnapshotDetails() |
static java.util.Map<Pair<java.lang.String,java.lang.String>,java.util.Map<java.lang.Integer,java.util.UUID>> |
SystemKeyspace.getUnfinishedCompactions()
Returns a Map whose keys are KS.CF pairs and whose values are maps from sstable generation numbers to the
task ID of the compaction they were participating in.
|
Modifier and Type | Method and Description |
---|---|
static void |
SnapshotDetailsTabularData.from(java.lang.String snapshot,
java.lang.String ks,
java.lang.String cf,
java.util.Map.Entry<java.lang.String,Pair<java.lang.Long,java.lang.Long>> snapshotDetail,
javax.management.openmbean.TabularDataSupport result) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and Description |
---|---|
Pair<Pair<java.lang.String,java.nio.ByteBuffer>,java.util.List<Pair<java.nio.ByteBuffer,AbstractType>>> |
TypeParser.getUserTypeParameters() |
Modifier and Type | Method and 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() |
Modifier and Type | Method and 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) |
Modifier and Type | Method and Description |
---|---|
void |
Gossiper.addLocalApplicationStates(java.util.List<Pair<ApplicationState,VersionedValue>> states) |
Modifier and Type | Method and Description |
---|---|
CompressionMetadata.Chunk[] |
CompressionMetadata.getChunksForSections(java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections) |
Modifier and Type | Method and Description |
---|---|
Pair<Descriptor,StatsMetadata> |
SSTableWriter.close() |
static Pair<Descriptor,Component> |
Component.fromFilename(java.io.File directory,
java.lang.String name)
Filename of the form "
|
static Pair<Descriptor,java.lang.String> |
Descriptor.fromFilename(java.io.File directory,
java.lang.String name) |
static Pair<Descriptor,java.lang.String> |
Descriptor.fromFilename(java.io.File directory,
java.lang.String name,
boolean skipComponent)
Filename of the form "
|
static Pair<Descriptor,Component> |
SSTable.tryComponentFromFilename(java.io.File dir,
java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Pair<java.lang.Long,java.lang.Long>> |
SSTableReader.getPositionsForRanges(java.util.Collection<Range<Token>> ranges)
Determine the minimal set of sections that can be extracted from this SSTable to cover the given ranges.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<Pair<Token,java.net.InetAddress>> |
TokenMetadata.getMovingEndpoints()
Endpoints which are migrating to the new tokens
|
Modifier and Type | Method and Description |
---|---|
Pair<java.util.Set<Range<Token>>,java.util.Set<Range<Token>>> |
StorageService.calculateStreamAndFetchRanges(java.util.Collection<Range<Token>> current,
java.util.Collection<Range<Token>> updated)
Calculate pair of ranges to stream/fetch for given two range collections
(current ranges for keyspace and ranges after move to new token)
|
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<Pair<CounterCacheKey,ClockAndCount>> |
CacheService.CounterCacheSerializer.deserialize(java.io.DataInputStream in,
ColumnFamilyStore cfs) |
java.util.concurrent.Future<Pair<RowCacheKey,IRowCacheEntry>> |
CacheService.RowCacheSerializer.deserialize(java.io.DataInputStream in,
ColumnFamilyStore cfs) |
java.util.concurrent.Future<Pair<KeyCacheKey,RowIndexEntry>> |
CacheService.KeyCacheSerializer.deserialize(java.io.DataInputStream input,
ColumnFamilyStore cfs) |
java.util.List<Pair<Range<Token>,java.lang.Long>> |
StorageService.getSplits(java.lang.String keyspaceName,
java.lang.String cfName,
Range<Token> range,
int keysPerSplit) |
Modifier and Type | Field and Description |
---|---|
protected java.util.Collection<Pair<java.lang.Long,java.lang.Long>> |
StreamReader.sections |
java.util.List<Pair<java.lang.Long,java.lang.Long>> |
StreamSession.SSTableStreamingSections.sections |
protected java.util.Collection<Pair<java.lang.Long,java.lang.Long>> |
StreamWriter.sections |
Modifier and Type | Method and Description |
---|---|
void |
StreamTransferTask.addTransferFile(SSTableReader sstable,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
long repairedAt) |
Constructor and Description |
---|
StreamSession.SSTableStreamingSections(SSTableReader sstable,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
long estimatedKeys,
long repairedAt) |
StreamWriter(SSTableReader sstable,
java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections,
StreamSession session) |
Constructor and Description |
---|
CompressedStreamWriter(SSTableReader sstable,
java.util.Collection<Pair<java.lang.Long,java.lang.Long>> sections,
CompressionInfo compressionInfo,
StreamSession session) |
Modifier and Type | Field and Description |
---|---|
java.util.List<Pair<java.lang.Long,java.lang.Long>> |
FileMessageHeader.sections |
Constructor and Description |
---|
FileMessageHeader(java.util.UUID cfId,
int sequenceNumber,
java.lang.String version,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
CompressionInfo compressionInfo,
long repairedAt) |
OutgoingFileMessage(SSTableReader sstable,
int sequenceNumber,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
long repairedAt) |
Modifier and Type | Method and Description |
---|---|
Pair<T,java.lang.Object> |
OptionCodec.decodeOne(io.netty.buffer.ByteBuf body,
int version) |
static Pair<DataType,java.lang.Object> |
DataType.fromType(AbstractType type,
int version) |
static Pair<java.util.List<java.lang.String>,java.util.List<java.nio.ByteBuffer>> |
CBUtil.readNameAndValueList(io.netty.buffer.ByteBuf cb) |
Modifier and Type | Method and Description |
---|---|
int |
OptionCodec.oneSerializedSize(Pair<T,java.lang.Object> option,
int version) |
static AbstractType |
DataType.toType(Pair<DataType,java.lang.Object> entry) |
void |
OptionCodec.writeOne(Pair<T,java.lang.Object> option,
io.netty.buffer.ByteBuf dest,
int version) |
Modifier and Type | Method and 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.
|
Constructor and Description |
---|
ExpiringMap(long defaultExpiration,
com.google.common.base.Function<Pair<K,ExpiringMap.CacheableObject<V>>,?> postExpireHook) |
Copyright © 2014 The Apache Software Foundation