Package org.apache.cassandra.db.streaming

Class CassandraOutgoingFile

java.lang.Object

org.apache.cassandra.db.streaming.CassandraOutgoingFile

All Implemented Interfaces:

OutgoingStream

public class CassandraOutgoingFile
extends java.lang.Object
implements OutgoingStream

used to transfer the part(or whole) of a SSTable data file

Constructor Summary

Constructors

Constructor	Description
CassandraOutgoingFile(StreamOperation operation, Ref<SSTableReader> ref, java.util.List<SSTableReader.PartitionPositionBounds> sections, java.util.List<Range<Token>> normalizedRanges, long estimatedKeys)

Method Summary

Modifier and Type	Method	Description
boolean	computeShouldStreamEntireSSTables()
boolean	contained(java.util.List<SSTableReader.PartitionPositionBounds> sections, SSTableReader sstable)
boolean	equals(java.lang.Object o)
void	finish()	Release any resources held by the stream
static CassandraOutgoingFile	fromStream(OutgoingStream stream)
long	getEstimatedSize()
java.lang.String	getName()
int	getNumFiles()
TimeUUID	getPendingRepair()
Ref<SSTableReader>	getRef()
long	getRepairedAt()
TableId	getTableId()
int	hashCode()
java.lang.String	toString()
void	write(StreamSession session, StreamingDataOutputPlus out, int version)	Write the streams data into the socket

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraOutgoingFile

public CassandraOutgoingFile(StreamOperation operation,
                             Ref<SSTableReader> ref,
                             java.util.List<SSTableReader.PartitionPositionBounds> sections,
                             java.util.List<Range<Token>> normalizedRanges,
                             long estimatedKeys)

Method Detail

fromStream

public static CassandraOutgoingFile fromStream(OutgoingStream stream)

getRef

public Ref<SSTableReader> getRef()

getName

public java.lang.String getName()

Specified by:

getName in interface OutgoingStream

getEstimatedSize

public long getEstimatedSize()

Specified by:

getEstimatedSize in interface OutgoingStream

Returns:

estimated file size to be streamed. This should only be used for metrics, because concurrent stats metadata update and index redistribution will change file sizes.

getTableId

public TableId getTableId()

Specified by:

getTableId in interface OutgoingStream

getNumFiles

public int getNumFiles()

Specified by:

getNumFiles in interface OutgoingStream

getRepairedAt

public long getRepairedAt()

Specified by:

getRepairedAt in interface OutgoingStream

getPendingRepair

public TimeUUID getPendingRepair()

Specified by:

getPendingRepair in interface OutgoingStream

write

public void write(StreamSession session,
                  StreamingDataOutputPlus out,
                  int version)
           throws java.io.IOException

Description copied from interface: OutgoingStream

Write the streams data into the socket

Specified by:

write in interface OutgoingStream

Throws:

java.io.IOException

computeShouldStreamEntireSSTables

public boolean computeShouldStreamEntireSSTables()

contained

public boolean contained(java.util.List<SSTableReader.PartitionPositionBounds> sections,
                         SSTableReader sstable)

finish

public void finish()

Description copied from interface: OutgoingStream

Release any resources held by the stream

Specified by:

finish in interface OutgoingStream

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object