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 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()
      • session

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