Package org.apache.cassandra.streaming
Interface OutgoingStream
-
- All Known Implementing Classes:
CassandraOutgoingFile
public interface OutgoingStreamSome subset of data to be streamed. Implementations handle writing out their data via the write method. On the receiving end,IncomingStreamstreams 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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidfinish()Release any resources held by the streamlonggetEstimatedSize()java.lang.StringgetName()intgetNumFiles()TimeUUIDgetPendingRepair()longgetRepairedAt()TableIdgetTableId()voidwrite(StreamSession session, StreamingDataOutputPlus output, int version)Write the streams data into the socket
-
-
-
Method Detail
-
write
void write(StreamSession session, StreamingDataOutputPlus output, int version) throws java.io.IOException
Write the streams data into the socket- Throws:
java.io.IOException
-
finish
void finish()
Release any resources held by the stream
-
getRepairedAt
long getRepairedAt()
-
getPendingRepair
TimeUUID getPendingRepair()
-
getName
java.lang.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()
-
-