org.apache.cassandra.db.streaming

Class CassandraCompressedStreamWriter

java.lang.Object

org.apache.cassandra.db.streaming.CassandraStreamWriter

org.apache.cassandra.db.streaming.CassandraCompressedStreamWriter

public class CassandraCompressedStreamWriter
extends CassandraStreamWriter

CassandraStreamWriter for compressed SSTable.

Field Summary

Fields inherited from class org.apache.cassandra.db.streaming.CassandraStreamWriter

limiter, sections, session, sstable

Constructor Summary

Constructors

Constructor and Description
CassandraCompressedStreamWriter(SSTableReader sstable, java.util.Collection<SSTableReader.PartitionPositionBounds> sections, CompressionInfo compressionInfo, StreamSession session)

Method Summary

Modifier and Type	Method and Description
protected long	totalSize()
void	write(DataOutputStreamPlus output) Stream file of specified sections to given channel.

Methods inherited from class org.apache.cassandra.db.streaming.CassandraStreamWriter

write

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraCompressedStreamWriter

public CassandraCompressedStreamWriter(SSTableReader sstable,
                                       java.util.Collection<SSTableReader.PartitionPositionBounds> sections,
                                       CompressionInfo compressionInfo,
                                       StreamSession session)

Method Detail

write

public void write(DataOutputStreamPlus output)
           throws java.io.IOException

Description copied from class: CassandraStreamWriter

Stream file of specified sections to given channel. CassandraStreamWriter uses LZF compression on wire to decrease size to transfer.

Overrides:

write in class CassandraStreamWriter

Parameters:

output - where this writes data to

Throws:

java.io.IOException - on any I/O error

totalSize

protected long totalSize()

Overrides:

totalSize in class CassandraStreamWriter