Package 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	Description
CassandraCompressedStreamWriter(SSTableReader sstable, CassandraStreamHeader header, StreamSession session)

Method Summary

Modifier and Type	Method	Description
protected long	totalSize()
void	write(StreamingDataOutputPlus out)	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,
                                       CassandraStreamHeader header,
                                       StreamSession session)

Method Detail

write

public void write(StreamingDataOutputPlus out)
           throws java.io.IOException

Description copied from class: CassandraStreamWriter

Stream file of specified sections to given channel.

Overrides:

write in class CassandraStreamWriter

Parameters:

out - where this writes data to

Throws:

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

totalSize

protected long totalSize()

Overrides:

totalSize in class CassandraStreamWriter