Modifier and Type | Field and Description |
---|---|
Descriptor |
KeyCacheKey.desc |
Constructor and Description |
---|
KeyCacheKey(Descriptor desc,
java.nio.ByteBuffer key) |
Modifier and Type | Method and Description |
---|---|
CFMetaData |
Schema.getCFMetaData(Descriptor descriptor) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<Descriptor,java.util.Set<Component>> |
Directories.SSTableLister.list() |
Modifier and Type | Method and Description |
---|---|
static java.io.File |
Directories.getBackupsDirectory(Descriptor desc) |
static java.io.File |
Directories.getSnapshotDirectory(Descriptor desc,
java.lang.String snapshotName) |
Modifier and Type | Method and Description |
---|---|
static void |
LeveledManifest.mutateLevel(Pair<SSTableMetadata,java.util.Set<java.lang.Integer>> oldMetadata,
Descriptor descriptor,
java.lang.String filename,
int level)
Scary method mutating existing sstable component
Tries to do it safely by moving the new file on top of the old one
Caller needs to reload the sstable metadata (sstableReader.reloadSSTableMetadata())
|
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<?> |
CompactionManager.submitUserDefined(ColumnFamilyStore cfs,
java.util.Collection<Descriptor> dataFiles,
int gcBefore) |
Modifier and Type | Field and Description |
---|---|
Descriptor |
SSTable.descriptor |
Modifier and Type | Method and Description |
---|---|
Descriptor |
Descriptor.asTemporary(boolean temporary) |
static Descriptor |
Descriptor.fromFilename(java.lang.String filename) |
static Descriptor |
Descriptor.fromFilename(java.lang.String filename,
boolean skipComponent) |
Descriptor |
Descriptor.withGeneration(int newGeneration) |
Modifier and Type | Method and Description |
---|---|
Pair<Descriptor,SSTableMetadata> |
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 |
---|---|
protected static void |
SSTable.appendTOC(Descriptor descriptor,
java.util.Collection<Component> components)
Appends new component names to the TOC component.
|
static java.util.Set<Component> |
SSTable.componentsFor(Descriptor desc)
Discovers existing components for the descriptor.
|
static boolean |
SSTable.delete(Descriptor desc,
java.util.Set<Component> components)
We use a ReferenceQueue to manage deleting files that have been compacted
and for which no more SSTable references exist.
|
Pair<SSTableMetadata,java.util.Set<java.lang.Integer>> |
SSTableMetadata.SSTableMetadataSerializer.deserialize(java.io.DataInputStream in,
Descriptor desc) |
Pair<SSTableMetadata,java.util.Set<java.lang.Integer>> |
SSTableMetadata.SSTableMetadataSerializer.deserialize(java.io.DataInputStream in,
Descriptor desc,
boolean loadSSTableLevel) |
Pair<SSTableMetadata,java.util.Set<java.lang.Integer>> |
SSTableMetadata.SSTableMetadataSerializer.deserialize(Descriptor descriptor)
deserializes the metadata
returns a pair containing the part of the metadata meant to be kept-in memory and the part
that should not.
|
Pair<SSTableMetadata,java.util.Set<java.lang.Integer>> |
SSTableMetadata.SSTableMetadataSerializer.deserialize(Descriptor descriptor,
boolean loadSSTableLevel) |
void |
SSTableMetadata.SSTableMetadataSerializer.legacySerialize(SSTableMetadata sstableStats,
java.util.Set<java.lang.Integer> ancestors,
Descriptor legacyDesc,
java.io.DataOutput out)
Deprecated.
will be removed when it is assumed that the minimum upgrade-from-version is the version that this
patch made it into
|
static void |
SSTableReader.logOpenException(Descriptor descriptor,
java.io.IOException e) |
static SSTableReader |
SSTableReader.open(Descriptor descriptor) |
static SSTableReader |
SSTableReader.open(Descriptor desc,
CFMetaData metadata) |
static SSTableReader |
SSTableReader.open(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
IPartitioner partitioner) |
static SSTableReader |
SSTableReader.openForBatch(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
IPartitioner partitioner) |
static SSTableReader |
SSTableReader.openNoValidation(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata) |
protected static java.util.Set<Component> |
SSTable.readTOC(Descriptor descriptor)
Reads the list of components from the TOC component.
|
static void |
SSTableWriter.rename(Descriptor tmpdesc,
Descriptor newdesc,
java.util.Set<Component> components) |
Modifier and Type | Method and Description |
---|---|
static java.util.Collection<SSTableReader> |
SSTableReader.openAll(java.util.Set<java.util.Map.Entry<Descriptor,java.util.Set<Component>>> entries,
CFMetaData metadata,
IPartitioner partitioner) |
Constructor and Description |
---|
KeyIterator(Descriptor desc) |
SSTable(Descriptor descriptor,
CFMetaData metadata,
IPartitioner partitioner) |
SSTable(Descriptor descriptor,
java.util.Set<Component> components,
CFMetaData metadata,
IPartitioner partitioner) |
Modifier and Type | Method and Description |
---|---|
static DataIntegrityMetadata.ChecksumValidator |
DataIntegrityMetadata.checksumValidator(Descriptor desc) |
static DataIntegrityMetadata.ChecksumWriter |
DataIntegrityMetadata.checksumWriter(Descriptor desc) |
Constructor and Description |
---|
DataIntegrityMetadata.ChecksumValidator(Descriptor desc) |
DataIntegrityMetadata.ChecksumWriter(Descriptor desc) |
Modifier and Type | Field and Description |
---|---|
protected Descriptor |
StreamReader.desc |
Modifier and Type | Method and Description |
---|---|
void |
StreamSession.progress(Descriptor desc,
ProgressInfo.Direction direction,
long bytes,
long total) |
Modifier and Type | Method and Description |
---|---|
static void |
SSTableExport.enumeratekeys(Descriptor desc,
java.io.PrintStream outs)
Enumerate row keys from an SSTableReader and write the result to a PrintStream.
|
static void |
SSTableExport.export(Descriptor desc,
java.io.PrintStream outs,
java.util.Collection<java.lang.String> toExport,
java.lang.String[] excludes)
Export specific rows from an SSTable and write the resulting JSON to a PrintStream.
|
static void |
SSTableExport.export(Descriptor desc,
java.io.PrintStream outs,
java.lang.String[] excludes)
Export an SSTable and write the resulting JSON to a PrintStream.
|
static void |
SSTableExport.export(Descriptor desc,
java.lang.String[] excludes)
Export an SSTable and write the resulting JSON to standard out.
|
Copyright © 2014 The Apache Software Foundation