Package org.apache.cassandra.io.sstable.format

Class SortedTablePartitionWriter

java.lang.Object

org.apache.cassandra.io.sstable.format.SortedTablePartitionWriter

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

BigFormatPartitionWriter

public abstract class SortedTablePartitionWriter
extends Object
implements AutoCloseable

Field Summary

Fields

Modifier and Type	Field	Description
protected ClusteringPrefix<?>	firstClustering
protected ClusteringPrefix<?>	lastClustering
protected DeletionTime	openMarker
protected DeletionTime	startOpenMarker
protected long	startPosition
protected final UnfilteredSerializer	unfilteredSerializer
protected int	written

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SortedTablePartitionWriter(SerializationHeader header, SequentialWriter writer, Version version)

Method Summary

Modifier and Type	Method	Description
void	addStaticRow(Row staticRow)
void	addUnfiltered(Unfiltered unfiltered)
protected long	currentPosition()
protected long	finish()
long	getHeaderLength()
long	getInitialPosition()
protected void	reset()
void	start(DecoratedKey key, DeletionTime partitionLevelDeletion)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.AutoCloseable

close

Field Details

unfilteredSerializer

protected final UnfilteredSerializer unfilteredSerializer

startPosition

protected long startPosition

written

protected int written

firstClustering

protected ClusteringPrefix<?> firstClustering

lastClustering

protected ClusteringPrefix<?> lastClustering

openMarker

protected DeletionTime openMarker

startOpenMarker

protected DeletionTime startOpenMarker

Constructor Details

SortedTablePartitionWriter

protected SortedTablePartitionWriter(SerializationHeader header,
 SequentialWriter writer,
 Version version)

Method Details

reset

protected void reset()

getHeaderLength

public long getHeaderLength()

start

public void start(DecoratedKey key,
 DeletionTime partitionLevelDeletion)
           throws IOException

Throws:

IOException

addStaticRow

public void addStaticRow(Row staticRow)
                  throws IOException

Throws:

IOException

addUnfiltered

public void addUnfiltered(Unfiltered unfiltered)
                   throws IOException

Throws:

IOException

finish

protected long finish()
               throws IOException

Throws:

IOException

currentPosition

protected long currentPosition()

getInitialPosition

public long getInitialPosition()