Package org.apache.cassandra.db.streaming

Class CassandraStreamWriter

java.lang.Object

org.apache.cassandra.db.streaming.CassandraStreamWriter

Direct Known Subclasses:

CassandraCompressedStreamWriter

public class CassandraStreamWriter
extends Object

CassandraStreamWriter writes given section of the SSTable to given channel.

Field Summary

Fields

Modifier and Type	Field	Description
protected final StreamManager.StreamRateLimiter	limiter
protected final Collection<SSTableReader.PartitionPositionBounds>	sections
protected final StreamSession	session
protected final SSTableReader	sstable

Constructor Summary

Constructors

Constructor	Description
CassandraStreamWriter(SSTableReader sstable, CassandraStreamHeader header, StreamSession session)

Method Summary

Modifier and Type	Method	Description
protected long	totalSize()
protected long	write(ChannelProxy proxy, DataIntegrityMetadata.ChecksumValidator validator, StreamingDataOutputPlus output, long start, int transferOffset, int toTransfer, int bufferSize)	Sequentially read bytes from the file and write them to the output stream
void	write(StreamingDataOutputPlus out)	Stream file of specified sections to given channel.

Methods inherited from class java.lang.Object

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

Field Details

sstable

protected final SSTableReader sstable

sections

protected final Collection<SSTableReader.PartitionPositionBounds> sections

limiter

protected final StreamManager.StreamRateLimiter limiter

session

protected final StreamSession session

Constructor Details

CassandraStreamWriter

public CassandraStreamWriter(SSTableReader sstable,
 CassandraStreamHeader header,
 StreamSession session)

Method Details

write

public void write(StreamingDataOutputPlus out)
           throws IOException

Stream file of specified sections to given channel.

Parameters:

out - where this writes data to

Throws:

IOException - on any I/O error

totalSize

protected long totalSize()

write

protected long write(ChannelProxy proxy,
 DataIntegrityMetadata.ChecksumValidator validator,
 StreamingDataOutputPlus output,
 long start,
 int transferOffset,
 int toTransfer,
 int bufferSize)
              throws IOException

Sequentially read bytes from the file and write them to the output stream

Parameters:

proxy - The file reader to read from

validator - validator to verify data integrity

start - The readd offset from the beginning of the proxy file.

transferOffset - number of bytes to skip transfer, but include for validation.

toTransfer - The number of bytes to be transferred.

Returns:

Number of bytes transferred.

Throws:

IOException - on any I/O error