Package org.apache.cassandra.db.streaming

Class CassandraEntireSSTableStreamWriter

java.lang.Object

org.apache.cassandra.db.streaming.CassandraEntireSSTableStreamWriter

public class CassandraEntireSSTableStreamWriter
extends Object

CassandraEntireSSTableStreamWriter streams the entire SSTable to given channel.

Constructor Summary

Constructors

Constructor	Description
CassandraEntireSSTableStreamWriter(SSTableReader sstable, StreamSession session, ComponentContext context)

Method Summary

Modifier and Type	Method	Description
void	write(StreamingDataOutputPlus out)	Stream the entire file to given channel.

Methods inherited from class java.lang.Object

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

Constructor Details

CassandraEntireSSTableStreamWriter

public CassandraEntireSSTableStreamWriter(SSTableReader sstable,
 StreamSession session,
 ComponentContext context)

Method Details

write

public void write(StreamingDataOutputPlus out)
           throws IOException

Stream the entire file to given channel.

TODO: this currently requires a companion thread, but could be performed entirely asynchronously

Parameters:

out - where this writes data to

Throws:

IOException - on any I/O error