Modifier and Type | Method and Description |
---|---|
SerializationHeader.Component |
SerializationHeader.Serializer.deserialize(Version version,
DataInputPlus in) |
static long |
RowIndexEntry.Serializer.readPosition(DataInputPlus in,
Version version)
Reads only the data 'position' of the index entry and returns it.
|
void |
SerializationHeader.Serializer.serialize(Version version,
SerializationHeader.Component header,
DataOutputPlus out) |
int |
SerializationHeader.Serializer.serializedSize(Version version,
SerializationHeader.Component header) |
static void |
RowIndexEntry.Serializer.skip(DataInputPlus in,
Version version) |
static void |
RowIndexEntry.Serializer.skipForCache(DataInputPlus in,
Version version) |
Constructor and Description |
---|
ColumnIndex(SerializationHeader header,
SequentialWriter writer,
Version version,
java.util.Collection<SSTableFlushObserver> observers,
ISerializer<IndexInfo> indexInfoSerializer) |
Serializer(CFMetaData metadata,
Version version,
SerializationHeader header) |
Modifier and Type | Field and Description |
---|---|
Version |
AbstractSSTableIterator.Reader.version |
Modifier and Type | Method and Description |
---|---|
T |
ISSTableSerializer.deserializeFromSSTable(java.io.DataInput in,
Version version)
Deserialize into the specified DataInputStream instance in the format
suited for SSTables.
|
Modifier and Type | Field and Description |
---|---|
Version |
Descriptor.version
version has the following format:
[a-z]+ |
Constructor and Description |
---|
Descriptor(Version version,
java.io.File directory,
java.lang.String ksname,
java.lang.String cfname,
int generation,
SSTableFormat.Type formatType,
Component digestComponent) |
Serializer(Version version,
ISerializer<ClusteringPrefix> clusteringSerializer) |
Modifier and Type | Method and Description |
---|---|
Version |
SSTableFormat.getLatestVersion() |
Version |
SSTableFormat.getVersion(java.lang.String version) |
Modifier and Type | Method and Description |
---|---|
RowIndexEntry.IndexSerializer<?> |
SSTableFormat.getIndexSerializer(CFMetaData cfm,
Version version,
SerializationHeader header) |
Modifier and Type | Field and Description |
---|---|
static Version |
BigFormat.latestVersion |
Modifier and Type | Method and Description |
---|---|
Version |
BigFormat.getLatestVersion() |
Version |
BigFormat.getVersion(java.lang.String version) |
Modifier and Type | Method and Description |
---|---|
RowIndexEntry.IndexSerializer |
BigFormat.getIndexSerializer(CFMetaData metadata,
Version version,
SerializationHeader header) |
Modifier and Type | Method and Description |
---|---|
CompactionMetadata |
CompactionMetadata.CompactionMetadataSerializer.deserialize(Version version,
DataInputPlus in) |
T |
IMetadataComponentSerializer.deserialize(Version version,
DataInputPlus in)
Deserialize metadata component from given input.
|
StatsMetadata |
StatsMetadata.StatsMetadataSerializer.deserialize(Version version,
DataInputPlus in) |
ValidationMetadata |
ValidationMetadata.ValidationMetadataSerializer.deserialize(Version version,
DataInputPlus in) |
void |
IMetadataSerializer.serialize(java.util.Map<MetadataType,MetadataComponent> components,
DataOutputPlus out,
Version version)
Serialize given metadata components
|
void |
LegacyMetadataSerializer.serialize(java.util.Map<MetadataType,MetadataComponent> components,
DataOutputPlus out,
Version version)
Deprecated.
Legacy serialization is only used for SSTable level reset.
|
void |
MetadataSerializer.serialize(java.util.Map<MetadataType,MetadataComponent> components,
DataOutputPlus out,
Version version) |
void |
CompactionMetadata.CompactionMetadataSerializer.serialize(Version version,
CompactionMetadata component,
DataOutputPlus out) |
void |
StatsMetadata.StatsMetadataSerializer.serialize(Version version,
StatsMetadata component,
DataOutputPlus out) |
void |
IMetadataComponentSerializer.serialize(Version version,
T component,
DataOutputPlus out)
Serialize metadata component to given output.
|
void |
ValidationMetadata.ValidationMetadataSerializer.serialize(Version version,
ValidationMetadata component,
DataOutputPlus out) |
int |
CompactionMetadata.CompactionMetadataSerializer.serializedSize(Version version,
CompactionMetadata component) |
int |
StatsMetadata.StatsMetadataSerializer.serializedSize(Version version,
StatsMetadata component) |
int |
IMetadataComponentSerializer.serializedSize(Version version,
T component)
Calculate and return serialized size.
|
int |
ValidationMetadata.ValidationMetadataSerializer.serializedSize(Version version,
ValidationMetadata component) |
Modifier and Type | Field and Description |
---|---|
protected Version |
StreamReader.inputVersion |
Constructor and Description |
---|
StreamDeserializer(CFMetaData metadata,
java.io.InputStream in,
Version version,
SerializationHeader header,
long totalSize,
java.util.UUID sessionId) |
Modifier and Type | Field and Description |
---|---|
Version |
FileMessageHeader.version
SSTable version
|
Constructor and Description |
---|
FileMessageHeader(java.util.UUID cfId,
int sequenceNumber,
Version version,
SSTableFormat.Type format,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
CompressionInfo compressionInfo,
long repairedAt,
int sstableLevel,
SerializationHeader.Component header) |
FileMessageHeader(java.util.UUID cfId,
int sequenceNumber,
Version version,
SSTableFormat.Type format,
long estimatedKeys,
java.util.List<Pair<java.lang.Long,java.lang.Long>> sections,
CompressionMetadata compressionMetadata,
long repairedAt,
int sstableLevel,
SerializationHeader.Component header) |
Copyright © 2020 The Apache Software Foundation