Package org.apache.cassandra.streaming

Interface StreamReceiver

All Known Implementing Classes:
CassandraStreamReceiver
public interface StreamReceiver
StreamReceiver acts as a staging area for incoming data. Received data ends up here, and is kept separate from the live data until all streams for a session have been received successfully

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    abort()
    Called when something went wrong with a stream session.
    void
    cleanup()
    Called after finished has returned and we've sent any messages to other nodes.
    void
    discardStream(IncomingStream stream)
    This is called when we've received stream data we can't add to the received set for some reason, usually when we've received data for a session which has been closed.
    void
    finished()
    Called when a stream session has succesfully completed.
    void
    received(IncomingStream stream)
    Called after we've finished receiving stream data.

  • Method Details

    • received

      void received(IncomingStream stream)
      Called after we've finished receiving stream data. The data covered by the given stream should be kept isolated from the live dataset for it's table.

    • discardStream

      void discardStream(IncomingStream stream)
      This is called when we've received stream data we can't add to the received set for some reason, usually when we've received data for a session which has been closed. The data backing this stream should be deleted, and any resources associated with the given stream should be released.

    • abort

      void abort()
      Called when something went wrong with a stream session. All data associated with this receiver should be deleted, and any associated resources should be cleaned up

    • finished

      void finished()
      Called when a stream session has succesfully completed. All stream data being held by this receiver should be added to the live data sets for their respective tables before this method returns.

    • cleanup

      void cleanup()
      Called after finished has returned and we've sent any messages to other nodes. Mainly for signaling that mvs and cdc should cleanup.