Package org.apache.cassandra.db.streaming

Class CassandraIncomingFile

java.lang.Object

org.apache.cassandra.db.streaming.CassandraIncomingFile

All Implemented Interfaces:

IncomingStream

public class CassandraIncomingFile
extends Object
implements IncomingStream

used to receive the part(or whole) of a SSTable data file. This class deserializes the data stream into partitions and rows, and writes that out as an sstable

Constructor Summary

Constructors

Constructor	Description
CassandraIncomingFile(ColumnFamilyStore cfs, StreamSession session, StreamMessageHeader header)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
String	getName()
int	getNumFiles()
long	getSize()
SSTableMultiWriter	getSSTable()
TableId	getTableId()
int	hashCode()
boolean	isEntireSSTable()
void	read(DataInputPlus in, int version)	Read in the stream data.
StreamSession	session()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

CassandraIncomingFile

public CassandraIncomingFile(ColumnFamilyStore cfs,
 StreamSession session,
 StreamMessageHeader header)

Method Details

session

public StreamSession session()

Specified by:

session in interface IncomingStream

Returns:

stream session used to receive given file

read

public void read(DataInputPlus in,
 int version)
          throws Throwable

Description copied from interface: IncomingStream

Read in the stream data.

Specified by:

read in interface IncomingStream

Throws:

Throwable

getName

public String getName()

Specified by:

getName in interface IncomingStream

getSize

public long getSize()

Specified by:

getSize in interface IncomingStream

getNumFiles

public int getNumFiles()

Specified by:

getNumFiles in interface IncomingStream

isEntireSSTable

public boolean isEntireSSTable()

getTableId

public TableId getTableId()

Specified by:

getTableId in interface IncomingStream

toString

public String toString()

Overrides:

toString in class Object

getSSTable

public SSTableMultiWriter getSSTable()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object