Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.db.compaction.writers | |
org.apache.cassandra.service |
Modifier and Type | Field and Description |
---|---|
static Directories.DataDirectory[] |
Directories.dataDirectories |
Modifier and Type | Method and Description |
---|---|
Directories.DataDirectory |
Directories.getDataDirectoryForFile(java.io.File directory) |
static Directories.DataDirectory[] |
ColumnFamilyStore.getInitialDirectories() |
Directories.DataDirectory |
Directories.getWriteableLocation(long writeSize)
Returns a non-blacklisted data directory that _currently_ has
writeSize bytes as usable space, null if
there is not enough space left in all directories. |
Directories.DataDirectory[] |
Directories.getWriteableLocations() |
Modifier and Type | Method and Description |
---|---|
static void |
ColumnFamilyStore.addInitialDirectories(Directories.DataDirectory[] newDirectories)
A hook to add additional directories to initialDirectories.
|
static java.util.List<java.io.File> |
Directories.getKSChildDirectories(java.lang.String ksName,
Directories.DataDirectory[] directories) |
java.io.File |
Directories.getLocationForDisk(Directories.DataDirectory dataDirectory)
Returns SSTable location which is inside given data directory.
|
Constructor and Description |
---|
Directories(CFMetaData metadata,
Directories.DataDirectory[] paths)
Create Directories of given ColumnFamily.
|
Constructor and Description |
---|
Directories(CFMetaData metadata,
java.util.Collection<Directories.DataDirectory> paths) |
Modifier and Type | Method and Description |
---|---|
Directories.DataDirectory |
CompactionAwareWriter.getWriteDirectory(java.lang.Iterable<SSTableReader> sstables,
long estimatedWriteSize)
Return a directory where we can expect expectedWriteSize to fit.
|
Modifier and Type | Method and Description |
---|---|
protected abstract void |
CompactionAwareWriter.switchCompactionLocation(Directories.DataDirectory directory)
Implementations of this method should finish the current sstable writer and start writing to this directory.
|
void |
DefaultCompactionWriter.switchCompactionLocation(Directories.DataDirectory directory) |
void |
MajorLeveledCompactionWriter.switchCompactionLocation(Directories.DataDirectory location) |
void |
MaxSSTableSizeWriter.switchCompactionLocation(Directories.DataDirectory location) |
void |
SplittingSizeTieredCompactionWriter.switchCompactionLocation(Directories.DataDirectory location) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<PartitionPosition> |
StorageService.getDiskBoundaries(ColumnFamilyStore cfs,
Directories.DataDirectory[] directories) |
static java.util.List<PartitionPosition> |
StorageService.getDiskBoundaries(java.util.List<Range<Token>> localRanges,
IPartitioner partitioner,
Directories.DataDirectory[] dataDirectories)
Returns a list of disk boundaries, the result will differ depending on whether vnodes are enabled or not.
|
Copyright © 2018 The Apache Software Foundation