Class StreamingRepairTask

  • All Implemented Interfaces:
    com.google.common.util.concurrent.FutureCallback<StreamState>, java.lang.Runnable, StreamEventHandler

    public class StreamingRepairTask
    extends java.lang.Object
    implements java.lang.Runnable, StreamEventHandler
    StreamingRepairTask performs data streaming between two remote replicas, neither of which is repair coordinator. Task will send SyncResponse message back to coordinator upon streaming completion.
    • Method Detail

      • run

        public void run()
        Specified by:
        run in interface java.lang.Runnable
      • onSuccess

        public void onSuccess​(StreamState state)
        If we succeeded on both stream in and out, respond back to coordinator
        Specified by:
        onSuccess in interface com.google.common.util.concurrent.FutureCallback<StreamState>
      • onFailure

        public void onFailure​(java.lang.Throwable t)
        If we failed on either stream in or out, respond fail to coordinator
        Specified by:
        onFailure in interface com.google.common.util.concurrent.FutureCallback<StreamState>