Package org.apache.cassandra.io.sstable.metadata

Class MetadataSerializer

java.lang.Object

org.apache.cassandra.io.sstable.metadata.MetadataSerializer

All Implemented Interfaces:

IMetadataSerializer

public class MetadataSerializer
extends Object
implements IMetadataSerializer

Metadata serializer for SSTables version >= 'na'.

 File format := | number of components (4 bytes) | crc | toc | crc | component1 | c1 crc | component2 | c2 crc | ... |
 toc         := | component type (4 bytes) | position of component |
 

IMetadataComponent.Type's ordinal() defines the order of serialization.

Constructor Summary

Constructors

Constructor	Description
MetadataSerializer()

Method Summary

Modifier and Type	Method	Description
Map<MetadataType,MetadataComponent>	deserialize(Descriptor descriptor, EnumSet<MetadataType> types)	Deserialize specified metadata components from given descriptor.
MetadataComponent	deserialize(Descriptor descriptor, MetadataType type)	Deserialized only metadata component specified from given descriptor.
Map<MetadataType,MetadataComponent>	deserialize(Descriptor descriptor, FileDataInput in, EnumSet<MetadataType> selectedTypes)
void	mutate(Descriptor descriptor, String description, UnaryOperator<StatsMetadata> transform)	Mutate SSTable Metadata NOTE: mutating stats metadata of a live sstable will race with entire-sstable-streaming, please use SSTableReader.mutateLevelAndReload(int) instead on live sstable.
void	mutateLevel(Descriptor descriptor, int newLevel)	Mutate SSTable level NOTE: mutating stats metadata of a live sstable will race with entire-sstable-streaming, please use SSTableReader.mutateLevelAndReload(int) instead on live sstable.
void	mutateRepairMetadata(Descriptor descriptor, long newRepairedAt, TimeUUID newPendingRepair, boolean isTransient)	Mutate the repairedAt time, pendingRepair ID, and transient status.
void	rewriteSSTableMetadata(Descriptor descriptor, Map<MetadataType,MetadataComponent> currentComponents)	Replace the sstable metadata file (-Statistics.db) with the given components.
void	serialize(Map<MetadataType,MetadataComponent> components, DataOutputPlus out, Version version)	Serialize given metadata components

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MetadataSerializer

public MetadataSerializer()

Method Details

serialize

public void serialize(Map<MetadataType,MetadataComponent> components,
 DataOutputPlus out,
 Version version)
               throws IOException

Description copied from interface: IMetadataSerializer

Serialize given metadata components

Specified by:

serialize in interface IMetadataSerializer

Parameters:

components - Metadata components to serialize

Throws:

IOException

deserialize

public Map<MetadataType,MetadataComponent> deserialize(Descriptor descriptor,
 EnumSet<MetadataType> types)
                                                throws IOException

Description copied from interface: IMetadataSerializer

Deserialize specified metadata components from given descriptor.

Specified by:

deserialize in interface IMetadataSerializer

Parameters:

descriptor - SSTable descriptor

Returns:

Deserialized metadata components, in deserialized order.

Throws:

IOException

deserialize

public MetadataComponent deserialize(Descriptor descriptor,
 MetadataType type)
                              throws IOException

Description copied from interface: IMetadataSerializer

Deserialized only metadata component specified from given descriptor.

Specified by:

deserialize in interface IMetadataSerializer

Parameters:

descriptor - SSTable descriptor

type - Metadata component type to deserialize

Returns:

Deserialized metadata component. Can be null if specified type does not exist.

Throws:

IOException

deserialize

public Map<MetadataType,MetadataComponent> deserialize(Descriptor descriptor,
 FileDataInput in,
 EnumSet<MetadataType> selectedTypes)
                                                throws IOException

Throws:

IOException

mutate

public void mutate(Descriptor descriptor,
 String description,
 UnaryOperator<StatsMetadata> transform)
            throws IOException

Description copied from interface: IMetadataSerializer

Mutate SSTable Metadata NOTE: mutating stats metadata of a live sstable will race with entire-sstable-streaming, please use SSTableReader.mutateLevelAndReload(int) instead on live sstable.

Specified by:

mutate in interface IMetadataSerializer

Parameters:

descriptor - SSTable descriptor

description - on changed attributions

transform - function to mutate sstable metadata

Throws:

IOException

mutateLevel

public void mutateLevel(Descriptor descriptor,
 int newLevel)
                 throws IOException

Description copied from interface: IMetadataSerializer

Mutate SSTable level NOTE: mutating stats metadata of a live sstable will race with entire-sstable-streaming, please use SSTableReader.mutateLevelAndReload(int) instead on live sstable.

Specified by:

mutateLevel in interface IMetadataSerializer

Parameters:

descriptor - SSTable descriptor

newLevel - new SSTable level

Throws:

IOException

mutateRepairMetadata

public void mutateRepairMetadata(Descriptor descriptor,
 long newRepairedAt,
 TimeUUID newPendingRepair,
 boolean isTransient)
                          throws IOException

Description copied from interface: IMetadataSerializer

Mutate the repairedAt time, pendingRepair ID, and transient status. NOTE: mutating stats metadata of a live sstable will race with entire-sstable-streaming, please use SSTableReader.mutateLevelAndReload(int) instead on live sstable.

Specified by:

mutateRepairMetadata in interface IMetadataSerializer

Throws:

IOException

rewriteSSTableMetadata

public void rewriteSSTableMetadata(Descriptor descriptor,
 Map<MetadataType,MetadataComponent> currentComponents)
                            throws IOException

Description copied from interface: IMetadataSerializer

Replace the sstable metadata file (-Statistics.db) with the given components.

Specified by:

rewriteSSTableMetadata in interface IMetadataSerializer

Throws:

IOException