BigFormatPartitionWriter (apache-cassandra API)

java.lang.Object

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

org.apache.cassandra.io.sstable.format.big.BigFormatPartitionWriter

All Implemented Interfaces:: AutoCloseable

public class BigFormatPartitionWriter extends SortedTablePartitionWriter

Column index builder used by BigTableWriter. For index entries that exceed Config.column_index_cache_size, this uses the serialization logic as in RowIndexEntry.

Field Summary

Fields

Modifier and Type

Field

Description

static final int

DEFAULT_GRANULARITY

Fields inherited from class org.apache.cassandra.io.sstable.format.SortedTablePartitionWriter
firstClustering, lastClustering, openMarker, startOpenMarker, startPosition, unfilteredSerializer, written
Method Summary

Modifier and Type

Method

Description

void

addUnfiltered(Unfiltered unfiltered)

ByteBuffer

buffer()

void

close()

long

finish()

int

getColumnIndexCount()

int

indexInfoSerializedSize()

List<IndexInfo>

indexSamples()

int[]

offsets()

void

reset()

Methods inherited from class org.apache.cassandra.io.sstable.format.SortedTablePartitionWriter
addStaticRow, currentPosition, getHeaderLength, getInitialPosition, start

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- DEFAULT_GRANULARITY
  
  public static final int DEFAULT_GRANULARITY
  See Also:
  
  Constant Field Values
Method Details
- reset
  
  public void reset()
  
  Overrides:
  
  reset in class SortedTablePartitionWriter
- getColumnIndexCount
  
  public int getColumnIndexCount()
- buffer
  
  public ByteBuffer buffer()
- indexSamples
  
  public List<IndexInfo> indexSamples()
- offsets
  
  public int[] offsets()
- addUnfiltered
  
  public void addUnfiltered(Unfiltered unfiltered) throws IOException
  
  Overrides:
  
  addUnfiltered in class SortedTablePartitionWriter
  
  Throws:
  
  IOException
- finish
  
  public long finish() throws IOException
  
  Overrides:
  
  finish in class SortedTablePartitionWriter
  
  Throws:
  
  IOException
- indexInfoSerializedSize
  
  public int indexInfoSerializedSize()
- close
  
  public void close()