Package org.apache.cassandra.streaming

Interface IncomingStream

All Known Implementing Classes:
CassandraIncomingFile
public interface IncomingStream
The counterpart of OutgoingStream 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 by StreamReceiver. 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 Details

    • read

      void read(DataInputPlus inputPlus, int version) throws Throwable
      Read in the stream data.
      Throws:
      Throwable

    • getName

      String getName()

    • getSize

      long getSize()

    • getNumFiles

      int getNumFiles()

    • getTableId

      TableId getTableId()

    • session

      StreamSession session()
      Returns:
      stream session used to receive given file