Package org.apache.cassandra.repair

Class StreamingRepairTask

java.lang.Object

org.apache.cassandra.repair.StreamingRepairTask

All Implemented Interfaces:

com.google.common.util.concurrent.FutureCallback<StreamState>, Runnable, StreamEventHandler

public class StreamingRepairTask
extends Object
implements 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.

Constructor Summary

Constructors

Constructor	Description
StreamingRepairTask(SharedContext ctx, SyncState state, RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, Collection<Range<Token>> ranges, TimeUUID pendingRepair, PreviewKind previewKind, boolean asymmetric)

Method Summary

Modifier and Type	Method	Description
void	handleStreamEvent(StreamEvent event)	Callback for various streaming events.
void	onFailure(Throwable t)	If we failed on either stream in or out, respond fail to coordinator
void	onSuccess(StreamState state)	If we succeeded on both stream in and out, respond back to coordinator
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

StreamingRepairTask

public StreamingRepairTask(SharedContext ctx,
 SyncState state,
 RepairJobDesc desc,
 InetAddressAndPort initiator,
 InetAddressAndPort src,
 InetAddressAndPort dst,
 Collection<Range<Token>> ranges,
 TimeUUID pendingRepair,
 PreviewKind previewKind,
 boolean asymmetric)

Method Details

run

public void run()

Specified by:

run in interface Runnable

handleStreamEvent

public void handleStreamEvent(StreamEvent event)

Description copied from interface: StreamEventHandler

Callback for various streaming events.

Specified by:

handleStreamEvent in interface StreamEventHandler

Parameters:

event - Stream event.

See Also:

• StreamEvent.Type

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(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>