Package org.apache.cassandra.db

Class SerializationHeader

java.lang.Object

org.apache.cassandra.db.SerializationHeader

public class SerializationHeader
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SerializationHeader.Component	We need the TableMetadata to properly deserialize a SerializationHeader but it's clunky to pass that to a SSTable component, so we use this temporary object to delay the actual need for the metadata.
static class	SerializationHeader.Serializer

Field Summary

Fields

Modifier and Type	Field	Description
static final SerializationHeader.Serializer	serializer

Constructor Summary

Constructors

Constructor	Description
SerializationHeader(boolean isForSSTable, TableMetadata metadata, RegularAndStaticColumns columns, EncodingStats stats)

Method Summary

Modifier and Type	Method	Description
List<AbstractType<?>>	clusteringTypes()
RegularAndStaticColumns	columns()
Columns	columns(boolean isStatic)
long	deletionTimeSerializedSize(DeletionTime dt)
AbstractType<?>	getType(ColumnMetadata column)
boolean	hasStatic()
boolean	isForSSTable()
AbstractType<?>	keyType()
long	localDeletionTimeSerializedSize(long localDeletionTime)
static SerializationHeader	make(TableMetadata metadata, Collection<SSTableReader> sstables)
static SerializationHeader	makeWithoutStats(TableMetadata metadata)
DeletionTime	readDeletionTime(DataInputPlus in)
long	readLocalDeletionTime(DataInputPlus in)
long	readTimestamp(DataInputPlus in)
int	readTTL(DataInputPlus in)
void	skipDeletionTime(DataInputPlus in)
void	skipLocalDeletionTime(DataInputPlus in)
void	skipTimestamp(DataInputPlus in)
void	skipTTL(DataInputPlus in)
EncodingStats	stats()
long	timestampSerializedSize(long timestamp)
SerializationHeader.Component	toComponent()
String	toString()
long	ttlSerializedSize(int ttl)
void	writeDeletionTime(DeletionTime dt, DataOutputPlus out)
void	writeLocalDeletionTime(long localDeletionTime, DataOutputPlus out)
void	writeTimestamp(long timestamp, DataOutputPlus out)
void	writeTTL(int ttl, DataOutputPlus out)

Methods inherited from class java.lang.Object

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

Field Details

serializer

public static final SerializationHeader.Serializer serializer

Constructor Details

SerializationHeader

public SerializationHeader(boolean isForSSTable,
 TableMetadata metadata,
 RegularAndStaticColumns columns,
 EncodingStats stats)

Method Details

makeWithoutStats

public static SerializationHeader makeWithoutStats(TableMetadata metadata)

make

public static SerializationHeader make(TableMetadata metadata,
 Collection<SSTableReader> sstables)

columns

public RegularAndStaticColumns columns()

hasStatic

public boolean hasStatic()

isForSSTable

public boolean isForSSTable()

stats

public EncodingStats stats()

keyType

public AbstractType<?> keyType()

clusteringTypes

public List<AbstractType<?>> clusteringTypes()

columns

public Columns columns(boolean isStatic)

getType

public AbstractType<?> getType(ColumnMetadata column)

writeTimestamp

public void writeTimestamp(long timestamp,
 DataOutputPlus out)
                    throws IOException

Throws:

IOException

writeLocalDeletionTime

public void writeLocalDeletionTime(long localDeletionTime,
 DataOutputPlus out)
                            throws IOException

Throws:

IOException

writeTTL

public void writeTTL(int ttl,
 DataOutputPlus out)
              throws IOException

Throws:

IOException

writeDeletionTime

public void writeDeletionTime(DeletionTime dt,
 DataOutputPlus out)
                       throws IOException

Throws:

IOException

readTimestamp

public long readTimestamp(DataInputPlus in)
                   throws IOException

Throws:

IOException

readLocalDeletionTime

public long readLocalDeletionTime(DataInputPlus in)
                           throws IOException

Throws:

IOException

readTTL

public int readTTL(DataInputPlus in)
            throws IOException

Throws:

IOException

readDeletionTime

public DeletionTime readDeletionTime(DataInputPlus in)
                              throws IOException

Throws:

IOException

timestampSerializedSize

public long timestampSerializedSize(long timestamp)

localDeletionTimeSerializedSize

public long localDeletionTimeSerializedSize(long localDeletionTime)

ttlSerializedSize

public long ttlSerializedSize(int ttl)

deletionTimeSerializedSize

public long deletionTimeSerializedSize(DeletionTime dt)

skipTimestamp

public void skipTimestamp(DataInputPlus in)
                   throws IOException

Throws:

IOException

skipLocalDeletionTime

public void skipLocalDeletionTime(DataInputPlus in)
                           throws IOException

Throws:

IOException

skipTTL

public void skipTTL(DataInputPlus in)
             throws IOException

Throws:

IOException

skipDeletionTime

public void skipDeletionTime(DataInputPlus in)
                      throws IOException

Throws:

IOException

toComponent

public SerializationHeader.Component toComponent()

toString

public String toString()

Overrides:

toString in class Object