Package org.apache.cassandra.db.streaming

Class CassandraStreamReader

java.lang.Object

org.apache.cassandra.db.streaming.CassandraStreamReader

All Implemented Interfaces:

IStreamReader

Direct Known Subclasses:

CassandraCompressedStreamReader

public class CassandraStreamReader
extends Object
implements IStreamReader

CassandraStreamReader reads from stream and writes to SSTable.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CassandraStreamReader.StreamDeserializer

Field Summary

Fields

Modifier and Type	Field	Description
protected final long	estimatedKeys
protected final int	fileSeqNum
protected final SerializationHeader.Component	header
protected final Version	inputVersion
protected final TimeUUID	pendingRepair
protected final long	repairedAt
protected final Collection<SSTableReader.PartitionPositionBounds>	sections
protected final StreamSession	session
protected final int	sstableLevel
protected final TableId	tableId

Constructor Summary

Constructors

Constructor	Description
CassandraStreamReader(StreamMessageHeader header, CassandraStreamHeader streamHeader, StreamSession session)

Method Summary

Modifier and Type	Method	Description
protected SSTableMultiWriter	createWriter(ColumnFamilyStore cfs, long totalSize, long repairedAt, TimeUUID pendingRepair, SSTableFormat<?,?> format)
protected CassandraStreamReader.StreamDeserializer	getDeserializer(TableMetadata metadata, TrackedDataInputPlus in, Version inputVersion, StreamSession session, SSTableMultiWriter writer)
protected SerializationHeader	getHeader(TableMetadata metadata)
SSTableMultiWriter	read(DataInputPlus inputPlus)
protected long	totalSize()
protected void	writePartition(CassandraStreamReader.StreamDeserializer deserializer, SSTableMultiWriter writer)

Methods inherited from class java.lang.Object

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

Field Details

tableId

protected final TableId tableId

estimatedKeys

protected final long estimatedKeys

sections

protected final Collection<SSTableReader.PartitionPositionBounds> sections

session

protected final StreamSession session

inputVersion

protected final Version inputVersion

repairedAt

protected final long repairedAt

pendingRepair

protected final TimeUUID pendingRepair

sstableLevel

protected final int sstableLevel

header

protected final SerializationHeader.Component header

fileSeqNum

protected final int fileSeqNum

Constructor Details

CassandraStreamReader

public CassandraStreamReader(StreamMessageHeader header,
 CassandraStreamHeader streamHeader,
 StreamSession session)

Method Details

read

public SSTableMultiWriter read(DataInputPlus inputPlus)
                        throws Throwable

Specified by:

read in interface IStreamReader

Parameters:

inputPlus - where this reads data from

Returns:

SSTable transferred

Throws:

IOException - if reading the remote sstable fails. Will throw an RTE if local write fails.

Throwable

getDeserializer

protected CassandraStreamReader.StreamDeserializer getDeserializer(TableMetadata metadata,
 TrackedDataInputPlus in,
 Version inputVersion,
 StreamSession session,
 SSTableMultiWriter writer)
                                                            throws IOException

Throws:

IOException

getHeader

protected SerializationHeader getHeader(TableMetadata metadata)
                                 throws UnknownColumnException

Throws:

UnknownColumnException

createWriter

protected SSTableMultiWriter createWriter(ColumnFamilyStore cfs,
 long totalSize,
 long repairedAt,
 TimeUUID pendingRepair,
 SSTableFormat<?,?> format)
                                   throws IOException

Throws:

IOException

totalSize

protected long totalSize()

writePartition

protected void writePartition(CassandraStreamReader.StreamDeserializer deserializer,
 SSTableMultiWriter writer)
                       throws IOException

Throws:

IOException