Package org.apache.cassandra.streaming

Class StreamState

java.lang.Object

org.apache.cassandra.streaming.StreamState

All Implemented Interfaces:

Serializable

public class StreamState
extends Object
implements Serializable

Current snapshot of streaming progress.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
final TimeUUID	planId
final Set<SessionInfo>	sessions
final StreamOperation	streamOperation

Constructor Summary

Constructors

Constructor	Description
StreamState(TimeUUID planId, StreamOperation streamOperation, Set<SessionInfo> sessions)

Method Summary

Modifier and Type	Method	Description
List<SessionSummary>	createSummaries()
boolean	hasAbortedSession()
boolean	hasFailedSession()
Set<SessionInfo>	sessions()

Methods inherited from class java.lang.Object

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

Field Details

planId

public final TimeUUID planId

streamOperation

public final StreamOperation streamOperation

sessions

public final Set<SessionInfo> sessions

Constructor Details

StreamState

public StreamState(TimeUUID planId,
 StreamOperation streamOperation,
 Set<SessionInfo> sessions)

Method Details

hasFailedSession

public boolean hasFailedSession()

hasAbortedSession

public boolean hasAbortedSession()

createSummaries

public List<SessionSummary> createSummaries()

sessions

public Set<SessionInfo> sessions()