Package org.apache.cassandra.streaming
Interface IncomingStream
-
- All Known Implementing Classes:
CassandraIncomingFile
public interface IncomingStream
The counterpart ofOutgoingStream
on 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.String
getName()
int
getNumFiles()
long
getSize()
TableId
getTableId()
void
read(DataInputPlus inputPlus, int version)
Read in the stream data.StreamSession
session()
-
-
-
Method Detail
-
read
void read(DataInputPlus inputPlus, int version) throws java.io.IOException
Read in the stream data.- Throws:
java.io.IOException
-
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
-
-