Package org.apache.cassandra.streaming

Class StreamCoordinator

java.lang.Object

org.apache.cassandra.streaming.StreamCoordinator

public class StreamCoordinator
extends Object

StreamCoordinator is a helper class that abstracts away maintaining multiple StreamSession and ProgressInfo instances per peer. This class coordinates multiple SessionStreams per peer in both the outgoing StreamPlan context and on the inbound StreamResultFuture context.

Constructor Summary

Constructors

Constructor	Description
StreamCoordinator(StreamOperation streamOperation, int connectionsPerHost, StreamingChannel.Factory factory, boolean follower, boolean connectSequentially, TimeUUID pendingRepair, PreviewKind previewKind)

Method Summary

Modifier and Type	Method	Description
void	addSessionInfo(SessionInfo session)
void	connect(StreamResultFuture future)
Set<SessionInfo>	getAllSessionInfo()
Collection<StreamSession>	getAllStreamSessions()
StreamSession	getOrCreateInboundSession(InetAddressAndPort from, StreamingChannel channel, int messagingVersion, int id)
StreamSession	getOrCreateOutboundSession(InetAddressAndPort peer)
Set<InetSocketAddress>	getPeers()
TimeUUID	getPendingRepair()
StreamSession	getSessionById(InetAddressAndPort peer, int id)
boolean	hasActiveSessions()
boolean	isFollower()
void	setConnectionFactory(StreamingChannel.Factory factory)
void	transferStreams(InetAddressAndPort to, Collection<OutgoingStream> streams)
void	updateProgress(ProgressInfo info)

Methods inherited from class java.lang.Object

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

Constructor Details

StreamCoordinator

public StreamCoordinator(StreamOperation streamOperation,
 int connectionsPerHost,
 StreamingChannel.Factory factory,
 boolean follower,
 boolean connectSequentially,
 TimeUUID pendingRepair,
 PreviewKind previewKind)

Method Details

setConnectionFactory

public void setConnectionFactory(StreamingChannel.Factory factory)

hasActiveSessions

public boolean hasActiveSessions()

Returns:

true if any stream session is active

getAllStreamSessions

public Collection<StreamSession> getAllStreamSessions()

isFollower

public boolean isFollower()

connect

public void connect(StreamResultFuture future)

getPeers

public Set<InetSocketAddress> getPeers()

getOrCreateOutboundSession

public StreamSession getOrCreateOutboundSession(InetAddressAndPort peer)

getOrCreateInboundSession

public StreamSession getOrCreateInboundSession(InetAddressAndPort from,
 StreamingChannel channel,
 int messagingVersion,
 int id)

getSessionById

public StreamSession getSessionById(InetAddressAndPort peer,
 int id)

updateProgress

public void updateProgress(ProgressInfo info)

addSessionInfo

public void addSessionInfo(SessionInfo session)

getAllSessionInfo

public Set<SessionInfo> getAllSessionInfo()

transferStreams

public void transferStreams(InetAddressAndPort to,
 Collection<OutgoingStream> streams)

getPendingRepair

public TimeUUID getPendingRepair()