Package org.apache.cassandra.streaming
Interface IncomingStream
-
- All Known Implementing Classes:
CassandraIncomingFile
public interface IncomingStreamThe counterpart ofOutgoingStreamon the receiving side. Data streamed in can (and should) be persisted, but must not be included in the table's live data set until added byStreamReceiver. If the stream fails, the stream receiver will delete the streamed data, but implementations still need to handle the case where it's process dies during streaming, and it has data left around on startup, in which case it should be deleted.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.lang.StringgetName()intgetNumFiles()longgetSize()TableIdgetTableId()voidread(DataInputPlus inputPlus, int version)Read in the stream data.StreamSessionsession()
-
-
-
Method Detail
-
read
void read(DataInputPlus inputPlus, int version) throws java.lang.Throwable
Read in the stream data.- Throws:
java.lang.Throwable
-
getName
java.lang.String getName()
-
getSize
long getSize()
-
getNumFiles
int getNumFiles()
-
getTableId
TableId getTableId()
-
session
StreamSession session()
- Returns:
- stream session used to receive given file
-
-