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

Class SSTableWriter.Builder<W extends SSTableWriter,B extends SSTableWriter.Builder<W,B>>

java.lang.Object

org.apache.cassandra.io.sstable.SSTable.Builder<W,B>

org.apache.cassandra.io.sstable.format.SSTableWriter.Builder<W,B>

Type Parameters:

W - type of the sstable writer to be build with this builder

B - type of this builder

Direct Known Subclasses:

SortedTableWriter.Builder

Enclosing class:

SSTableWriter

public abstract static class SSTableWriter.Builder<W extends SSTableWriter,B extends SSTableWriter.Builder<W,B>>
extends SSTable.Builder<W,B>

A builder of this sstable writer. It should be extended for each implementation with the specific fields. An implementation should open all the resources when build(LifecycleNewTracker, Owner) and pass them in builder fields to the writer, so that the writer can access them via getters.

Field Summary

Fields inherited from class org.apache.cassandra.io.sstable.SSTable.Builder

descriptor

Constructor Summary

Constructors

Constructor	Description
Builder(Descriptor descriptor)

Method Summary

Modifier and Type	Method	Description
B	addDefaultComponents(Collection<Index.Group> indexGroups)
W	build(LifecycleNewTracker lifecycleNewTracker, SSTable.Owner owner)
protected abstract W	buildInternal(LifecycleNewTracker lifecycleNewTracker, SSTable.Owner owner)
SSTableZeroCopyWriter	createZeroCopyWriter(LifecycleNewTracker lifecycleNewTracker, SSTable.Owner owner)
List<Index.Group>	getIndexGroups()
long	getKeyCount()
MetadataCollector	getMetadataCollector()
abstract MmappedRegionsCache	getMmappedRegionsCache()
TimeUUID	getPendingRepair()
long	getRepairedAt()
SerializationHeader	getSerializationHeader()
boolean	isTransientSSTable()
B	setKeyCount(long keyCount)
B	setMetadataCollector(MetadataCollector metadataCollector)
B	setPendingRepair(TimeUUID pendingRepair)
B	setRepairedAt(long repairedAt)
B	setSecondaryIndexGroups(Collection<Index.Group> indexGroups)
B	setSerializationHeader(SerializationHeader serializationHeader)
B	setTransientSSTable(boolean transientSSTable)

Methods inherited from class org.apache.cassandra.io.sstable.SSTable.Builder

addComponents, getChunkCache, getComponents, getDescriptor, getIOOptions, getTableMetadataRef, setChunkCache, setComponents, setIOOptions, setTableMetadataRef

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder(Descriptor descriptor)

Method Details

setMetadataCollector

public B setMetadataCollector(MetadataCollector metadataCollector)

setKeyCount

public B setKeyCount(long keyCount)

setRepairedAt

public B setRepairedAt(long repairedAt)

setPendingRepair

public B setPendingRepair(TimeUUID pendingRepair)

setTransientSSTable

public B setTransientSSTable(boolean transientSSTable)

setSerializationHeader

public B setSerializationHeader(SerializationHeader serializationHeader)

addDefaultComponents

public B addDefaultComponents(Collection<Index.Group> indexGroups)

setSecondaryIndexGroups

public B setSecondaryIndexGroups(Collection<Index.Group> indexGroups)

getMetadataCollector

public MetadataCollector getMetadataCollector()

getKeyCount

public long getKeyCount()

getRepairedAt

public long getRepairedAt()

getPendingRepair

public TimeUUID getPendingRepair()

isTransientSSTable

public boolean isTransientSSTable()

getSerializationHeader

public SerializationHeader getSerializationHeader()

getIndexGroups

public List<Index.Group> getIndexGroups()

getMmappedRegionsCache

public abstract MmappedRegionsCache getMmappedRegionsCache()

build

public W build(LifecycleNewTracker lifecycleNewTracker,
 SSTable.Owner owner)

buildInternal

protected abstract W buildInternal(LifecycleNewTracker lifecycleNewTracker,
 SSTable.Owner owner)

createZeroCopyWriter

public SSTableZeroCopyWriter createZeroCopyWriter(LifecycleNewTracker lifecycleNewTracker,
 SSTable.Owner owner)