Package org.apache.cassandra.streaming

Interface OutgoingStream

All Known Implementing Classes:

CassandraOutgoingFile

public interface OutgoingStream

Some subset of data to be streamed. Implementations handle writing out their data via the write method. On the receiving end, IncomingStream streams the data in. All the data contained in a given stream needs to have the same repairedAt timestamp (or 0) and pendingRepair id (or null).

Method Summary

Modifier and Type	Method	Description
void	finish()	Release any resources held by the stream
long	getEstimatedSize()
String	getName()
int	getNumFiles()
TimeUUID	getPendingRepair()
long	getRepairedAt()
TableId	getTableId()
void	write(StreamSession session, StreamingDataOutputPlus output, int version)	Write the streams data into the socket

Method Details

write

void write(StreamSession session,
 StreamingDataOutputPlus output,
 int version)
    throws IOException

Write the streams data into the socket

Throws:

IOException

finish

void finish()

Release any resources held by the stream

getRepairedAt

long getRepairedAt()

getPendingRepair

TimeUUID getPendingRepair()

getName

String getName()

getEstimatedSize

long getEstimatedSize()

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

TableId getTableId()

getNumFiles

int getNumFiles()