Package org.apache.cassandra.io.sstable
Class SimpleSSTableMultiWriter
- java.lang.Object
-
- org.apache.cassandra.io.sstable.SimpleSSTableMultiWriter
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,SSTableMultiWriter
,Transactional
public class SimpleSSTableMultiWriter extends java.lang.Object implements SSTableMultiWriter
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.cassandra.utils.concurrent.Transactional
Transactional.AbstractTransactional
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
SimpleSSTableMultiWriter(SSTableWriter writer, LifecycleNewTracker lifecycleNewTracker)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Throwable
abort(java.lang.Throwable accumulate)
boolean
append(UnfilteredRowIterator partition)
Writes a partition in an implementation specific wayvoid
close()
java.lang.Throwable
commit(java.lang.Throwable accumulate)
static SSTableMultiWriter
create(Descriptor descriptor, long keyCount, long repairedAt, java.util.UUID pendingRepair, boolean isTransient, TableMetadataRef metadata, MetadataCollector metadataCollector, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)
java.util.Collection<SSTableReader>
finish(boolean openResult)
java.util.Collection<SSTableReader>
finish(long repairedAt, long maxDataAge, boolean openResult)
java.util.Collection<SSTableReader>
finished()
java.lang.String
getFilename()
long
getFilePointer()
TableId
getTableId()
void
prepareToCommit()
SSTableMultiWriter
setOpenResult(boolean openResult)
-
-
-
Constructor Detail
-
SimpleSSTableMultiWriter
protected SimpleSSTableMultiWriter(SSTableWriter writer, LifecycleNewTracker lifecycleNewTracker)
-
-
Method Detail
-
append
public boolean append(UnfilteredRowIterator partition)
Description copied from interface:SSTableMultiWriter
Writes a partition in an implementation specific way- Specified by:
append
in interfaceSSTableMultiWriter
- Parameters:
partition
- the partition to append- Returns:
- true if the partition was written, false otherwise
-
finish
public java.util.Collection<SSTableReader> finish(long repairedAt, long maxDataAge, boolean openResult)
- Specified by:
finish
in interfaceSSTableMultiWriter
-
finish
public java.util.Collection<SSTableReader> finish(boolean openResult)
- Specified by:
finish
in interfaceSSTableMultiWriter
-
finished
public java.util.Collection<SSTableReader> finished()
- Specified by:
finished
in interfaceSSTableMultiWriter
-
setOpenResult
public SSTableMultiWriter setOpenResult(boolean openResult)
- Specified by:
setOpenResult
in interfaceSSTableMultiWriter
-
getFilename
public java.lang.String getFilename()
- Specified by:
getFilename
in interfaceSSTableMultiWriter
-
getFilePointer
public long getFilePointer()
- Specified by:
getFilePointer
in interfaceSSTableMultiWriter
-
getTableId
public TableId getTableId()
- Specified by:
getTableId
in interfaceSSTableMultiWriter
-
commit
public java.lang.Throwable commit(java.lang.Throwable accumulate)
- Specified by:
commit
in interfaceTransactional
-
abort
public java.lang.Throwable abort(java.lang.Throwable accumulate)
- Specified by:
abort
in interfaceTransactional
-
prepareToCommit
public void prepareToCommit()
- Specified by:
prepareToCommit
in interfaceTransactional
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceTransactional
-
create
public static SSTableMultiWriter create(Descriptor descriptor, long keyCount, long repairedAt, java.util.UUID pendingRepair, boolean isTransient, TableMetadataRef metadata, MetadataCollector metadataCollector, SerializationHeader header, java.util.Collection<Index> indexes, LifecycleNewTracker lifecycleNewTracker)
-
-